共享内存/zeromq通信测试

Administrator

2024-04-18 eb106c82e31fd1c68bf7c95156940d07ea04b9d6

共享内存/zeromq通信测试

 test_communication.py

@@ -23,7 +23,7 @@
            try:
                use_time = (time.time() - msg['time']) * 1000
                decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory)
                print(f"获取到逐笔委托数据: 通信耗时：{use_time}ms 解码耗时:{decoded_use_time}s")
                print(f"获取到逐笔委托数据: 数据长度：{len(decoded_data)} 通信耗时：{use_time}ms 解码耗时:{decoded_use_time}s")
            except Exception as e:
                logging.exception(e)
            finally:
@@ -37,7 +37,7 @@
            try:
                use_time = (time.time() - msg['time']) * 1000
                decoded_data, decoded_use_time = L2SharedMemoryDataUtil.get_data(shared_memory)
                print(f"获取到逐笔成交数据: 通信耗时：{use_time}ms 解码耗时:{decoded_use_time}s")
                print(f"获取到逐笔成交数据:  数据长度：{len(decoded_data)} 通信耗时：{use_time}ms 解码耗时:{decoded_use_time}s")
            except Exception as e:
                logging.exception(e)
            finally:
@@ -62,6 +62,7 @@
        socket.connect(delegate_ipc_addr)
        while True:
            try:
                print("发送委托数据")
                datas = [('000990', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100]
                L2SharedMemoryDataUtil.set_data(datas, shared_memory)
                socket.send_json({'data': [], "time": time.time()})
@@ -105,7 +106,7 @@
            deal_ipc_addr=f"ipc://deal_{i}.ipc",
            delegate_data_shared_memory=delegate_data_array,
            deal_data_shared_memory=deal_data_array)
        if constant.is_windows() or True:
        if constant.is_windows():
            param.delegate_ipc_addr = f"tcp://127.0.0.1:{15000 + i}"
            param.deal_ipc_addr = f"tcp://127.0.0.1:{16000 + i}"
        params.append(param)