| | |
|---|
| | | import zmq |
|---|
| | | |
|---|
| | | |
|---|
| | | def __create_server(context, port): |
|---|
| | | def __create_server(context, index): |
|---|
| | | socket = context.socket(zmq.REP) |
|---|
| | | socket.bind(f"ipc://order{port}.ipc") |
|---|
| | | print("绑定成功", port) |
|---|
| | | socket.bind(f"ipc://order_{index}.ipc") |
|---|
| | | print("绑定成功", index) |
|---|
| | | while True: |
|---|
| | | msg = socket.recv_json() |
|---|
| | | print(f"Got Msg({port}): {msg}") |
|---|
| | | print(f"Got Msg({index}): {msg}") |
|---|
| | | socket.send_string("SUCCESS") |
|---|
| | | |
|---|
| | | |
|---|
| | | def create_server(): |
|---|
| | | context = zmq.Context() |
|---|
| | | for i in range(5): |
|---|
| | | threading.Thread(target=lambda: __create_server(context, 10000 + 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{10000 + i}.ipc") |
|---|
| | | socket.connect(f"ipc://order_{i}.ipc") |
|---|
| | | socket_client_dict[i] = socket |
|---|
| | | |
|---|
| | | socket_client_dict[i].send_json({'msg': i}) |
|---|
