共享内存/zeromq通信测试

Administrator

2024-04-18 a13cb5262f0eea22aa51147b087b26e91930a9c4

共享内存/zeromq通信测试

 test_communication.py

@@ -1,3 +1,4 @@
import logging
import multiprocessing
import threading
import time
@@ -23,8 +24,8 @@
                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")
            except:
                pass
            except Exception as e:
                logging.exception(e)
            finally:
                socket.send_string("SUCCESS")

@@ -37,8 +38,8 @@
                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")
            except:
                pass
            except Exception as e:
                logging.exception(e)
            finally:
                socket.send_string("SUCCESS")

@@ -105,8 +106,8 @@
            delegate_data_shared_memory=delegate_data_array,
            deal_data_shared_memory=deal_data_array)
        if constant.is_windows():
            param.delegate_ipc_addr = f"tcp://*:{10000 + i}"
            param.deal_ipc_addr = f"tcp://*:{11000 + i}"
            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)
    strategy = L2Strategy(params)
    dataCollector = L2DataCollector(params)