zeromq集成测试

Administrator

2024-02-27 cf1022bf85694958fcab3f6d8be5bda19a872d33

zeromq集成测试

 test/test_pyzmq.py

@@ -12,7 +12,7 @@
    print("绑定成功", index)
    while True:
        msg = socket.recv_string()
        print(f"Got Msg({index}): {msg}")
        print(f"Got Msg({index}-{time.time()}): {msg}")
        socket.send_string("SUCCESS")


@@ -33,7 +33,7 @@
        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}))
    socket_client_dict[i].send_string(json.dumps({'msg': i, "time": time.time()}))
    response = socket_client_dict[i].recv_string()