15 卡牌服务端搭建 - 跨服支持PY自定义封包通信

hch

2025-10-14 193a90f580f5ff6870d906e37821f27d350dc08f

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
ó 
œÔíhc@sÒdd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
dd
lZddlm    Z    m
Z

dd
lZdd
lZdd
l Z dd
lZedƒ
Zdejf
d„ƒYZdd
d    „ƒYZd
S(iÿÿÿÿN(
tmylog(
tPacketDispatcher(tCommonDefinetStatsConfig.DBConfigtAsynServerClientc
BsYeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
RS(    cCswtj
j||
ƒ
ttjƒƒ
|_||_tjƒ|_    |j
|j    _
||_||_d
|_ t|_dS(Nt(tasyncoret
dispatchert__init__tstrtuuidtuuid4t    sessionIDtaddrR
t!_AsynServerClient__packDispatchertOnGetPackett_AsynServerClient__onCloset_AsynServerClient__recvQueuetsendBuftTruet_AsynServerClient__active(tselftsockR tOnCloset    recvQueue((s+.\\ServersRoute\NetCore\AsynServerClient.pyRs


    


    
        
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(Rtwarning(Rtbuf((s+.\\ServersRoute\NetCore\AsynServerClient.pyR$sc
Cs
|js dSyŸ|j
tjƒ
}
t|
ƒ
d
k
rB|jƒ
dStjƒjt|
ƒ
7_tj    r›t
jdt|
ƒ
tj |
ƒ
|jjƒfƒ

n|jj|
ƒ

Wndtk
r

}
t
jd|jjƒ|fƒ

t
jd|jjƒtjƒfƒ

|jƒ
dSXdS(Nis*recv len = %s data = %s from socketID = %sssocketID = %s error = %sssocketID = %s %s(RtrecvRtMAX_RECVtlentcloseRtGetStatt    RecvBytest
DUMPPACKETRtdebugtbinasciitb2a_hextsockettfilenoRtonRecvOrginPackett    ExceptionRt    tracebackt
format_exc(RtrecvBuft
e((s+.\\ServersRoute\NetCore\AsynServerClient.pythandle_read+s 
    





    
5

 
&


c

Cst|j
ƒ
d
kS(Ni(RR(
R((s+.\\ServersRoute\NetCore\AsynServerClient.pytwritableDs
c
Cs^|jst
|jƒ
d
k
r#dS|j|jƒ
}
|j|
|_tjƒj|
7_dS(Ni(RRRtsendRRt    SendBytes(Rtsent((s+.\\ServersRoute\NetCore\AsynServerClient.pyt __processSendGs




c


Cs|jƒ
dS(
N(
t_AsynServerClient__processSend(
R((s+.\\ServersRoute\NetCore\AsynServerClient.pythandle_writeOs
c

CsW|js dSt
|_tjd
|jjƒƒ

|jrI|j|ƒ

n|jƒ
dS(NssockID = %s closed!(RtFalseRtinfoR%R&RR(
R((s+.\\ServersRoute\NetCore\AsynServerClient.pythandle_closeRs
    

    

    

cCsy|jj
|
ƒ
}|j|7_t|jƒ
tjkrktjd
t|jƒ
tj|jj    ƒfƒ

n|j
ƒ
dS(Ns;send buf (len = %s) > (MAX_PACK_LEN = %s) via socketID = %s(RtpackDataRRRtMAX_PACK_LENRterrorR%R&R3(RRtpackBuf((s+.\\ServersRoute\NetCore\AsynServerClient.pytpushSend]s




2c

Cs(tj
d
|jjƒƒ

|jƒ
dS(NsDisconnect socketID = %s(RR6R%R&R7(
R((s+.\\ServersRoute\NetCore\AsynServerClient.pyt
disconnectes

(t__name__t
__module__RRR-R.R3R4R7R<R=(((s+.\\ServersRoute\NetCore\AsynServerClient.pyRs
                                tAsynServerClientMgrc
BsGeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„ZRS(c

Cs i|_dS(
N(
t sessionIDDict(
R((s+.\\ServersRoute\NetCore\AsynServerClient.pyRjscCsT|
s
dSt|
t
ƒsdStjd
|
jjƒ|
jfƒ

|
|j|
j<dS(NssocketID = %s sessionID = %s(t
isinstanceRRR"R%R&RRA(Rtclient((s+.\\ServersRoute\NetCore\AsynServerClient.pyt    addClientns




#
cCsV|jj
|
jƒ
r:tjd
|
jƒ

|j|
j=tStjd|
jƒ

tSdS(Nsdel sessionID = %s Success!sdel sessionID = %s failed!(RAthas_keyRRR6RRR5(RRC((s+.\\ServersRoute\NetCore\AsynServerClient.pyt    delClientvs


 

c

Cs t|j
ƒ
S(
N(RRA(
R((s+.\\ServersRoute\NetCore\AsynServerClient.pytgetClientCnts
cCs|jj
|
ƒ
S(
N(RAtget(RR((s+.\\ServersRoute\NetCore\AsynServerClient.pyt    getClient‚s
cCs0|jj
ƒ}|
t|ƒ
kr%d
S||
jS(Niÿÿÿÿ(RAtvaluesRR(Rtindext
clientList((s+.\\ServersRoute\NetCore\AsynServerClient.pytgetClientSessionIDByIndex…s



c


Cs |jj
ƒS(
N(RARJ(
R((s+.\\ServersRoute\NetCore\AsynServerClient.pyt getClientList‹s
(    R>R?RRDRFRGRIRMRN(((s+.\\ServersRoute\NetCore\AsynServerClient.pyR@is
                            ((RR%R)tCommonRtProtocolR
R#tDBCommonRRtQueuetinspectR
ttimet
__import__tDBConfigRRR@(((s+.\\ServersRoute\NetCore\AsynServerClient.pyt<module>
s










R