zeromq集成测试

Administrator

2024-02-27 b30bb4c12a44317faf962caeea2279b7b19849fb

 test/test_pyzmq.py

@@ -8,6 +8,7 @@
def __create_server(context, port):
    socket = context.socket(zmq.REP)
    socket.bind(f"ipc://order{port}.ipc")
    print("绑定成功", port)
    while True:
        msg = socket.recv_json()
        print(f"Got Msg({port}): {msg}")