10263 【英文】【越南】【BT】【砍树】后端支持NPC仿真实玩家战斗和快速战斗（防范剩余血量计算报错；）

hxp

2025-06-09 ce13cefb478f3181792d4e290c4d47f2e55f8774

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
ó 
IxÙfc@sÿdd
lZdd
l
Z
dd
lZddlmZ
dd
lZddlmZ
dd
lZddl    m
Z

ddlmZ
dd
l Z ddlmZ
edƒ
Zde
f
d    „ƒYZd
e
jf
d„ƒYZd„Zd „Zedkrûeƒ
nd
S(iÿÿÿÿN(
tmylog(
tsleep(
tThread(
tSingletonObject(
tCommonDefinesConfig.DBConfigtSendPackDispatchThreadc
Bs#eZ
d„Zd
„Zd„ZRS(cCs tj
|d
dƒ


|
|_dS(NtnameR(Rt__init__t'_SendPackDispatchThread__asyncoreServer(tselftasyncoreServer((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRs

c

Cs4|jj
ƒ
tjr0tjd
|jƒƒ

ndS(Nsend of thread %s!(RtprocessSendQueuetDBConfigtMultiThreadingRtinfotgetName(
R    ((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytruns
 
    
c

Cs1tj
|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(RtstartRRRtident(
R    ((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyR!s
 
(t__name__t
__module__RRR(((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRs
        tAsynCoreServercBsžeZ
dd
„
Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z    d    „Z
d
„Zd„Zd„Z d „Zd„Zdd„
Zd„ZRS(iÿÿÿÿcCsttj
j|ƒ

t|ƒ
|_|
|_tjƒ|_t    j    ƒ|_
t    j    ƒ|_t|_ ||_d|_dS(
N(tasyncoret
dispatcherRRt'_AsynCoreServer__sendPackDispatchThreadRtAsynServerClienttAsynServerClientMgrt    clientMgrtQueuet_AsynCoreServer__recvQueuet    sendQueuetFalset_AsynCoreServer__activetMaxClientCnttNonetonClientDisconnectEx(R    RR!((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyR's


    



    
    
c


Cs |jj
ƒS(
N(RtgetClientCnt(
R    ((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytGetClientCnt5s
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(Rtwarning(R    tsocktaddrtonClientDisconnectt    recvQueue((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytonAcceptClient8scCs|jj
|
ƒ
S(
N(Rt    getClient(R    t    sessionID((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytFindClientBySessionID@s
c


Cs |jj
ƒS(
N(Rtqsize(
R    ((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt sendQueueSizeCs
cCs|jj
|
ƒ

dS(
N(Rtput(R    tpack((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytpushSendFs
c


Cs |jj
ƒS(
s#recv queue item cnt,but no reliable(RR/(
R    ((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytrecvQueueCntMsc
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitRtEmptyR"(R    R2((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytrecvQueuePopNoWaitQs




c

Cs|jj
ƒ}
|
S(
N(Rtget(R    trecvPack((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytrecvQueuePopYs
c
Csúy|jƒ\}
}Wn=t
jk
rU
}
tjt|ƒ
ƒ

tjtjƒƒ

dSX|jd
kr«|j    ƒ|jkr«tjd|j||
j
ƒfƒ

|
jƒ
dStjd||
j
ƒfƒ

|j |
||j|jƒ}|jj|ƒ

dS(Niÿÿÿÿs:ClientCnt > %d ,close new Client(addr = %s, SocketID = %s)s)connect accepted!addr = %s, SocketID = %s(taccepttsocketterrorRR&tunicodet    tracebackt
format_excR!R%tfilenotcloseRR+t#_AsynCoreServer__onClientDisconnectRRt    addClient(R    R'R(twhytclient((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt handle_accept^s





$
#




c

Cstj
d
|jƒ

dS(Ns    %s close!(RRR(
R    ((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pythandle_closeps
cCsf|jj
|
ƒ
sFtjd
|jjtjƒdd|
jfƒ

n|j    rb|j    |
jƒ

ndS(Ns&%s.%s del client failed!sessionID = %sii(
Rt    delClientRtdebugt    __class__RtinspecttstackR-R#(R    RF((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt__onClientDisconnectss


#

    
c
CsX
xQ
|jrS
y|j
jƒ}
Wntjk
r;


d}
n
X|
dkretjratd
ƒ

qqePn|
j    ƒdkrÃ|j
jƒ}x4|D],}tj |
jƒƒ

|j|
jƒƒ

qWqn|j
j|
j    ƒƒ
}|dkr*
tj d|jjtjƒdd|
j    ƒ|
jƒfƒ

qn|j|
jƒƒ

tjƒj|
ƒ

qWdS(Ngü©ñÒMbP?is#%s.%s sessionID = %s ignore pack %si(R RR5RR6R"RR R
tgetSessionIDRt getClientListRRJtoutputStringR3tgetPackDataR,RKRRLRMRtgetPackPooltfree(R    R2t
clientListRFtserverClient((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRzs.







    



 




#


cCs*tj
d
|
ƒ

t|_|jj|
ƒ
S(s?¸²¸Ç¸¸ÀàµÄͬÃû·½·¨£¬¸¸ÀàÔÚNTϵͳÏ£¬ÏÞÖÆÁËÁ¬½Ó¶ÓÁеÄ×î´óÊýÁ¿Îª5sServer start with backlog = %s(RRJtTruet    acceptingR<tlisten(R    tconnectionQueueSize((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRY˜s
    
icCs‰t|_
tjr"|jjƒ
n|jtjtj    ƒ
d
|
f}t
jd|j|
fƒ

|j |ƒ

t
jdƒ

|j|ƒ

dS(Nts%s starting at port = %s...sbind ok!start listenning...(RWR RR RRt create_socketR<tAF_INETtSOCK_STREAMRRRtbindRY(R    tportRZtbindAddr((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyRžs    
    




 
 
c

Csp|js dSt
jd
ƒ

t|_tjr_|jjdƒ

x |jjƒr[t    dƒ

q?Wnt
jdƒ

dS(NsStoping server...igš™™™™™¹?sStop server OK!(
R RRRRR RtjointisAliveR
(
R    ((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytstop¬s
    

 
    
    



(RRRR%R+R.R0R3R4R7R:RGRHRCRRYRRd(((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyR%s                                                     c
Cs9tj
ƒr5d
dl}
tjd|
j|ƒ
ƒ

ndS(Niÿÿÿÿsbuf = %s(RtIsDebugtbinasciiRRJtb2a_hex(tbufRf((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pytOnGetMMORPGPacket·s


cCsÔyatj
d
tƒ

tdƒ
}t|_|jƒ
x*tr_tj    dt
ddƒ
tdƒ

q6WWnlt jk
r—


tjdƒ

tjtjƒƒ

n9tk
rÏ
}

tjt|
ƒ
ƒ

tjtjƒƒ

n
XdS(Ns%s.logtDBServergð?i
gš™™™™™¹?s socket error!(Rt    InitMyLogRRRit    OnGetPackRRWRtloopRR"R
R<R=R?R@t    ExceptionR>(tServert
e((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyttest¼s



    


    



 



t__main__(R<RRtCommonRR?ttimeR
Rt    threadingRtDBCommonRRLRt
__import__RRRRRiRqR(((s[.\db»º´æ³Ø\TCode\TeamServer\Server4\Servers\PyMongoDataServer\src\NetCore\AsyncoreServer.pyt<module>
s"










’