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

hch

2025-10-14 ea3377678e9179f4265bcc0d749c4686a69be158

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
38
39
40
41
ó 
œÔíhc@sédd
lm
Z

ddlZddlmZ
ddlZddlmZ
ddlZddl    m
Z

ddlmZ
ddl    mZm
Z
m Z 
ddlZddlZedƒ
Zd    e
j
f
d
„ƒYZdad„Zd„ZdS( iÿÿÿÿ(
tAsyncoreClientN(
tmylog(
tMergeServerRecvProtocol(
tCommonDefine(
t
MMORPGPack(tSingletonObjectRterrorsConfig.DBConfigtServerRouteClientc
Bs‰eZ
dZd
Zd„Zd„Zd„Zd„Zd„Zd„Z    d„Z
d    „Zd
„Zd„Z d„Zd „Zd„ZRS(iicCs~tjj
|ƒ

|
|_||_|j|
|fƒ

t|_tjƒ|_tjƒ|_    tjƒ|_
tjƒ|_dS(
N( Rt__init__tiptporttconnecttTruetis_reconnectttimetlastReconnectTimetlast_heartbeat_timetlast_ServerHeartbeat_timetQueuet_ServerRouteClient__recvQueue(tselfR    R
((s$.\\ServersRoute\ServerRouteClient.pyRs

    
    

    



c

Cs|jt
ƒ

|jƒ
dS(
N(t    SetActiveRtLogin(
R((s$.\\ServersRoute\ServerRouteClient.pythandle_connect(s
 
cCsÑtj
r&tjd
tj|
ƒ
ƒ

ntjƒjƒ}d|j    |
ƒ
kr‰t
jdt
jdƒ}tj
|ƒ

tjƒj |ƒ

dStjd|jjƒƒ

|jj|ƒ

tjd|jjƒƒ

dS(s»ñµÃ²ð½âºóµÄ·â°üsbuf = %siÿÿÿÿRserror in pack.readDataNsbefore put:recv queue cnt = %ssafter put:recv queue cnt = %s(Rt
DUMPPACKETR
tdebugtbinasciitb2a_hexRtgetPackPooltalloctreadDataRt    formatMsgtERROR_NO_135tfreeRtqsizetput(Rtbuftpacktmsg((s$.\\ServersRoute\ServerRouteClient.pyt    onGetPack-s    



 



c
Cs
tj
d
|j|jfƒ

tjƒ|_tjƒ|_t|_t    j
ƒ}
tj|
_ ttjƒ
|
_tttjƒƒ
ƒ
|
_t|
jƒ
|
_tjƒ}|j|
j |
jƒ

|jƒ}||
_t|ƒ
|
_tj|
_ttjƒ
|
_|j|
jƒƒ

dS(sÁ¬½Ó³É¹¦ºóµÄ´¦ÀísConnected to %s:%s now loginN(R
tinfoR    R
RRRtFalseR RttagLPLoginPacktDBConfigt    GroupNamet
ClientGUIDtlentGUIDLentstrtintt    TimeStamptTimeLentmd5tnewtupdatet    hexdigestt
VerifyCodetCodeLentNameLent
SendStringt    GetBuffer(RR%tmd5Objtresult((s$.\\ServersRoute\ServerRouteClient.pyR@s"

    







    


cCs[tj
ƒjƒ}tj|jƒ_|j|
ƒ

|j|j    ƒƒ

tj
ƒj
|ƒ

dS(
N(RRRRt
atMergeSystgetPackHeadttypet    setBuffertpushSendtgetPackDataR!(RR$tsendPack((s$.\\ServersRoute\ServerRouteClient.pyR;[s



 cCs|j|
j
ƒƒ

dS(
N(RCRD(RR%((s$.\\ServersRoute\ServerRouteClient.pytSendPackesc

Cs$|jƒ
t
|_tjd
ƒ

dS(s¶Ï¿ªÁ¬½ÓºóµÄ´¦ÀítDisconnectedN(t
disconnectRR R
R((
R((s$.\\ServersRoute\ServerRouteClient.pythandle_closeis

    
c
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitRtEmptytNone(RR%((s$.\\ServersRoute\ServerRouteClient.pytrecvQueuePopNoWaitqs




c


Cs|jƒ
|j
ƒ
d
S(s¸üз½·¨N(t    ReConnecttsend_heartbeat(
R((s$.\\ServersRoute\ServerRouteClient.pytUpdate{s

c

Cs¡|js d
St
j
ƒ|j|jkr-d
St
j
ƒ|_tjdƒ

|jr_|jƒ
n|jtj    tj
ƒ
|j|j|j fƒ

t
j
ƒ|_d
S(s
ÖØÁ¬½Ó·½·¨NtReconnecting(R RRtReconnectIntervalR
R(tsockettcloset create_sockettAF_INETtSOCK_STREAMRR    R
R(
R((s$.\\ServersRoute\ServerRouteClient.pyRNs    



     
 

c

Cstjƒ|_
dS(
N(RR(
R((s$.\\ServersRoute\ServerRouteClient.pytRefreshServerHeartbeat’s
c
CsÎ|jr d
St
j
ƒ|j|jkr-d
Stjdƒ

tjƒ}
|j|
j    ƒƒ

t
j
ƒ|_t
j
ƒ|j
|jdkrÊtjdƒ

tjƒ}
|j|
j    ƒƒ

|j ƒ
t|_nd
S(s
·¢ËÍÐÄÌø°üNisServer heartbeat timeout(R RRtHeartbeatIntervalR
RRttagLPHeartbeatR;R<RR(ttagLPLogoutPackRHR(RR%((s$.\\ServersRoute\ServerRouteClient.pyRO–s    


 

 
 




c
Cs#tj
ƒ}
|j|
jƒƒ

dS(
N(RR[R;R<(RR%((s$.\\ServersRoute\ServerRouteClient.pytLogOut¬s

(t__name__t
__module__RYRRRRR'RR;RFRIRMRPRNRXROR\(((s$.\\ServersRoute\ServerRouteClient.pyRs
                     
            
                c


Cs
|adS(
N(
t__ServersRouteChild(
R((s$.\\ServersRoute\ServerRouteClient.pytSetServersRouteChild²sc
CstS(
N(
R_(((s$.\\ServersRoute\ServerRouteClient.pytGetServersRouteChild¶s(tNetCoreRRtCommonR
RStProtocolRR4tDBCommonRRRRRRt
__import__R+RRLR_R`Ra(((s$.\\ServersRoute\ServerRouteClient.pyt<module>s









š