zeromq集成测试

Administrator

2024-02-27 c0a128ffa94cbbab3eb3214abc4c27aa2262ec52

zeromq集成测试

 test/test_pyzmq.py

@@ -35,7 +35,10 @@
        socket_client_dict[i] = socket
    print(f"开始发送消息({i})：")
    datas = []
    for j in range(500):
    max_count = 500
    if i % 3 == 0:
        max_count = 100
    for j in range(max_count):
        datas.append(('002510', 4.07, 148700, '1', '2', 95433140, 2012, 9207862, 9207862, 'A', 1708998873.1507974, 0))

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