admin
2023-08-04 ca310f014336d93eba73ed5010c1c5645424a1e0
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
B
¡¡—d³
ã@s*ddlZddlZddlZGdd„dƒZdS)éNc@speZdZiZedd„ƒZedd„ƒZedd„ƒZedd„ƒZed    d
„ƒZ    ed d „ƒZ
ed d„ƒZ edd„ƒZ dS)ÚSendResponseSkManagercCs(||jkr| |¡}||j|<|j|S)N)Ú-_SendResponseSkManager__send_response_sk_dictÚcreate_send_response_sk)ÚclsÚtypeÚclient©rú.D:\workspace\GP\trade_huaxin\client_network.pyÚget_send_response_sk
s
 
 
z*SendResponseSkManager.get_send_response_skcCs||jkr|j |¡dS)N)rÚpop)rrrrr    Údel_send_response_sks
z*SendResponseSkManager.del_send_response_skcCs(tjtj}}t ¡}| ||f¡|S)N)ÚconstantÚ    SERVER_IPÚ SERVER_PORTÚsocketÚconnect)rrÚaddrÚportrrrr    rsz-SendResponseSkManager.create_send_response_skc
Cs | || ||d|dœ¡¡dS)Né)ÚcodeÚmsg)Úsend_normal_responseÚ load_response)rrÚ
request_idÚ    client_idrrrr    Úsend_error_responsesz)SendResponseSkManager.send_error_responsecCsL| |¡}| |¡| d¡}|rH| d¡}t |¡}| d¡dkrHdSdS)Nizutf-8rrTF)Úformat_responseÚsendÚrecvÚdecodeÚjsonÚloadsÚget)rÚskrÚresultÚ result_jsonrrr    Z__send_normal_response!s
 
 
 
 
z,SendResponseSkManager.__send_normal_responsec
Cs´y4t |¡}| ||¡rdSt |¡}| ||¡SWnztk
rr}z t |¡t |¡}| ||¡Sd}~XYn>tk
r®}z t |¡t |¡}| ||¡Sd}~XYnXdS)NT)rr
Ú,_SendResponseSkManager__send_normal_responseÚConnectionResetErrorr ÚBrokenPipeError)rrrr#Úerrr    r0s
 
 
 
 
 
z*SendResponseSkManager.send_normal_responsecCst d|||dœ¡ d¡S)NÚresponse)rÚdatarrzutf-8)r ÚdumpsÚencode)rrrZ    data_jsonrrr    rCs
 
z#SendResponseSkManager.load_responsecCsdt|ƒ}| d¡|S)Nz##%08dzutf-8)Úlenr-)rZ
data_bytesZslenrrr    rIs z%SendResponseSkManager.format_responseN) Ú__name__Ú
__module__Ú __qualname__rÚ classmethodr
r rrr&rrrrrrr    rs       r)r rr rrrrr    Ú<module>s