zeromq集成测试

Administrator

2024-02-27 ba656c32b0155cfeffdf577a2a4f06460dd55bbc

zeromq集成测试

 test/test_pyzmq.py

@@ -27,7 +27,8 @@
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})