zeromq集成测试

Administrator

2024-02-27 a55372e700a052cb9f3236f46935e20072563efe

zeromq集成测试

 test/test_pyzmq.py

@@ -30,7 +30,7 @@
        socket = context.socket(zmq.REQ)
        socket.connect(f"ipc://order_{i}.ipc")
        socket_client_dict[i] = socket

    print(f"开始发送消息({i})：")
    socket_client_dict[i].send_string(json.dumps({'msg': i}))
    response = socket_client_dict[i].recv_string()