| | |
|---|
| | | def create_server(): |
|---|
| | | context = zmq.Context() |
|---|
| | | for i in range(5): |
|---|
| | | threading.Thread(target=lambda: __create_server(context, i), daemon=True).start() |
|---|
| | | threading.Thread(target=lambda: __create_server(context, i), daemon=True).start() |
|---|
| | | |
|---|
| | | |
|---|
| | | socket_client_dict = {} |
|---|
| | |
|---|
| | | def send_data(context, i): |
|---|
| | | if i not in socket_client_dict: |
|---|
| | | socket = context.socket(zmq.REQ) |
|---|
| | | socket.connect(f"ipc://order_{i}.ipc") |
|---|
| | | result = socket.connect(f"ipc://order_{i}.ipc") |
|---|
| | | print("连接结果：", result) |
|---|
| | | socket_client_dict[i] = socket |
|---|
| | | |
|---|
| | | socket_client_dict[i].send_json({'msg': i}) |
|---|
