zeromq集成测试

Administrator

2024-02-27 b0b769e558eb8299f8b5ae6312e0656ac2fe7155

 test/test_pyzmq.py

@@ -34,11 +34,11 @@
        socket.connect(f"ipc://order_{i}.ipc")
        socket_client_dict[i] = socket
    print(f"开始发送消息({i})：")
    msg = "test"
    for i in range(1000):
        msg += "test123123"
    datas = []
    for i in range(200):
        datas.append(('002510', 4.07, 148700, '1', '2', 95433140, 2012, 9207862, 9207862, 'A', 1708998873.1507974, 0))

    socket_client_dict[i].send_json({'msg': msg, "time": time.time()})
    socket_client_dict[i].send_json({'data': datas, "time": time.time()})
    response = socket_client_dict[i].recv_string()