增加并行数量

admin

2025-04-08 70b51a2636858fb8cfbf39d3764d88d07286d8ad

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
42
43
B  
I\âfÏ    ã@s`dZd
dl
Z
d
dlZd
dlZd
dlZGdd„dƒZdd„Zedkr\xeeƒƒ

e     d¡

qDWdS)    u
华鑫 L1数据接口
éNc@s<eZ
dZed
d„ƒ
Zedd„ƒ
Zedd„ƒ
Zedd„ƒ
Zd    S)
Ú
SocketUtilcCs t 
¡}| |
 d
¡
¡

| ¡S)Nzutf-8)ÚhashlibÚmd5ÚupdateÚencodeÚ    hexdigest)ÚclsÚvaluer©r
õ6D:\量化低吸\low_suction_hx\strategy\l1_data_api.pyÚmd5_encrypts

zSocketUtil.md5_encryptcCs"t tj
tj¡}| |
|f¡

|S)
N)ÚsocketÚAF_INETÚSOCK_STREAMÚconnect)rÚaddrÚportÚclientr
r
rÚ create_sockets

zSocketUtil.create_socketcCsd
t|
ƒ
}| 
d¡
|
S)Nz##%08dzutf-8)Úlenr)rZ
data_bytesZslenr
r
rÚload_headers
zSocketUtil.load_headerc    CsÂd
}d}|
 d¡
}|d|…}|rº| 
d¡
}| d¡
r¢t|dd…ƒ
}d}|t||d…ƒ
7}|||d…7}xJ||ksž|
 d¡
}|t|ƒ
7}|| 
d¡
7}qpWn|
 d    ¡
}|| 
d¡
}||fS)
NÚé
izutf-8z##ér
i(i)ÚrecvÚdecodeÚ
startswithÚintr)    rÚskÚdataZheader_sizeÚbufZ
header_strZcontent_lengthZ received_sizeZr_datar
r
rÚ    recv_datas$


 
 
 
 
 


zSocketUtil.recv_dataN)Ú__name__Ú
__module__Ú__qualname__Úclassmethodrrrr!r
r
r
rr
srcCsbt 
d
d¡}t t dddœ¡
 d¡
¡
}
| |
¡

t |¡
\}}t |¡
}|ddkr^|d    SgS)
u½
    èŽ·å–当前L1信息
    :return: [(代码,昨日收盘价,最新价,总成交量,总成交额,买五档（价格，成交额），卖五档（价格，成交额）,更新时间)]
    z 43.138.167.68i+Zget_l1_datar)ÚtypeÚsignzutf-8Úcoder
r)    rrrÚjsonÚdumpsrÚsendr!Úloads)rZparams_bytesZ
result_strÚheaderZresult_jsonr
r
rÚget_current_info6s


 



r.Ú__main__gø?)
Ú__doc__rr)r Útimerr.r"ÚprintÚsleepr
r
r
rÚ<module>s



,