16 卡牌服务端（修复排行榜数据重复bug；暂去除排行榜功能开启上榜限制；）

hxp

昨天 38edc85d505fbcc7fa8a7e550266482674264ef5

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
ó 
P.hc@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).\\ServersRoute\NetCore\AsyncoreServer.pyRs

c


Cs|jj
ƒ
dS(
N(RtprocessSendQueue(
R    ((s).\\ServersRoute\NetCore\AsyncoreServer.pytruns
c

Cs1tj
|ƒ

tjd
|jƒ|jfƒ

dS(NsThread %s(%s) start!(RtstartRtinfotgetNametident(
R    ((s).\\ServersRoute\NetCore\AsyncoreServer.pyR s
 
(t__name__t
__module__RRR (((s).\\ServersRoute\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).\\ServersRoute\NetCore\AsyncoreServer.pyR%s


    



    
    
c


Cs |jj
ƒS(
N(RtgetClientCnt(
R    ((s).\\ServersRoute\NetCore\AsyncoreServer.pytGetClientCnt3s
cCstj
d
ƒ

dS(s×ÓÀàʵÏÖs
unhandled!N(Rtwarning(R    tsocktaddrtonClientDisconnectt    recvQueue((s).\\ServersRoute\NetCore\AsyncoreServer.pytonAcceptClient6scCs|jj
|
ƒ
S(
N(Rt    getClient(R    t    sessionID((s).\\ServersRoute\NetCore\AsyncoreServer.pytFindClientBySessionID>s
c


Cs |jj
ƒS(
N(Rtqsize(
R    ((s).\\ServersRoute\NetCore\AsyncoreServer.pyt sendQueueSizeAs
cCs|jj
|
ƒ

dS(
N(Rtput(R    tpack((s).\\ServersRoute\NetCore\AsyncoreServer.pytpushSendDs
c


Cs |jj
ƒS(
s#recv queue item cnt,but no reliable(RR-(
R    ((s).\\ServersRoute\NetCore\AsyncoreServer.pytrecvQueueCntKsc
Cs/y|jj
ƒ}
Wntjk
r*


dSX|
S(
N(Rt
get_nowaitRtEmptyR (R    R0((s).\\ServersRoute\NetCore\AsyncoreServer.pytrecvQueuePopNoWaitOs




c

Cs|jj
ƒ}
|
S(
N(Rtget(R    trecvPack((s).\\ServersRoute\NetCore\AsyncoreServer.pytrecvQueuePopWs
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_excRR#tfilenotcloseRR)t#_AsynCoreServer__onClientDisconnectRRt    addClient(R    R%R&twhytclient((s).\\ServersRoute\NetCore\AsyncoreServer.pyt handle_accept\s





$
#




c

Cstj
d
|jƒ

dS(Ns    %s close!(RRR(
R    ((s).\\ServersRoute\NetCore\AsyncoreServer.pythandle_closens
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    RD((s).\\ServersRoute\NetCore\AsyncoreServer.pyt__onClientDisconnectqs


#

    
c
Cs?
x8
|jr:
y|j
jƒ}
Wntjk
r;


d}
n
X|
dkrLPn|
jƒd
krª|jjƒ}x4|D],}t    j
|
jƒƒ

|j|
j ƒƒ

qtWqn|jj|
jƒƒ
}|dkr
t    j
d|jjtjƒd
d|
jƒ|
jƒfƒ

qn|j|
j ƒƒ

tjƒj|
ƒ

qWdS(Nis#%s.%s sessionID = %s ignore pack %si(RRR3RR4R tgetSessionIDRt getClientListRRHtoutputStringR1tgetPackDataR*RIRRJRKRtgetPackPooltfree(R    R0t
clientListRDtserverClient((s).\\ServersRoute\NetCore\AsyncoreServer.pyRxs(








 




#


cCs*tj
d
|
ƒ

t|_|jj|
ƒ
S(s?¸²¸Ç¸¸ÀàµÄͬÃû·½·¨£¬¸¸ÀàÔÚNTϵͳÏ£¬ÏÞÖÆÁËÁ¬½Ó¶ÓÁеÄ×î´óÊýÁ¿Îª5sServer start with backlog = %s(RRHtTruet    acceptingR:tlisten(R    tconnectionQueueSize((s).\\ServersRoute\NetCore\AsyncoreServer.pyRW“s
    
icCspt|_
|jtjtjƒ
d
|
f}tjd|j|
fƒ

|j    |ƒ

tjdƒ

|j
|ƒ

dS(Nts%s starting at port = %s...sbind ok!start listenning...(RURt create_socketR:tAF_INETtSOCK_STREAMRRRtbindRW(R    tportRXtbindAddr((s).\\ServersRoute\NetCore\AsyncoreServer.pyR ™s    



 
 
c

Cs4|js dSt
jd
ƒ

t|_t
jdƒ

dS(NsStoping server...sStop server OK!(RRRR(
R    ((s).\\ServersRoute\NetCore\AsyncoreServer.pytstop¥s

    

 
    (RRRR#R)R,R.R1R2R5R8RERFRARRWR R`(((s).\\ServersRoute\NetCore\AsyncoreServer.pyR#s                                                     c
Cs9tj
ƒr5d
dl}
tjd|
j|ƒ
ƒ

ndS(Niÿÿÿÿsbuf = %s(RtIsDebugtbinasciiRRHtb2a_hex(tbufRb((s).\\ServersRoute\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    InitMyLogRRRet    OnGetPackR RURtloopRR R
R:R;R=R>t    ExceptionR<(tServert
e((s).\\ServersRoute\NetCore\AsyncoreServer.pyttest²s



    


    



 



t__main__(R:RRtCommonRR=ttimeR
Rt    threadingRtDBCommonRRJRt
__import__tDBConfigRRRReRmR(((s).\\ServersRoute\NetCore\AsyncoreServer.pyt<module>
s"










Š