| | |
|---|
| | | |
|---|
| | | from utils import socket_util |
|---|
| | | |
|---|
| | | # SERVER_HOST = '43.138.167.68' |
|---|
| | | SERVER_HOST = '192.168.3.122' |
|---|
| | | SERVER_HOST = '43.138.167.68' |
|---|
| | | # SERVER_HOST = '192.168.3.122' |
|---|
| | | SERVER_PORT = 10008 |
|---|
| | | |
|---|
| | | |
|---|
| | | def request(data_json): |
|---|
| | | if type(data_json) == set: |
|---|
| | | data_json = list(data_json) |
|---|
| | | data_bytes = socket_util.load_header(json.dumps(data_json).encode('utf-8')) |
|---|
| | | sk = socket_util.create_socket(SERVER_HOST, SERVER_PORT) |
|---|
| | | try: |
|---|
| | |
|---|
| | | fdata = {"type": "kp_msg", "data": {"ctype": "kp_msg", "data": {"msg": msg}}} |
|---|
| | | return fdata |
|---|
| | | |
|---|
| | | |
|---|
| | | # ------------------------------L2订阅列表------------------------------------ |
|---|
| | | def load_l2_subscript_codes(datas): |
|---|
| | | fdata = {"type": "l2_subscript_codes", "data": {"ctype": "l2_subscript_codes", "data": datas}} |
|---|
| | | return fdata |
|---|
| | | return fdata |
|---|
