From eb106c82e31fd1c68bf7c95156940d07ea04b9d6 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 18 四月 2024 16:41:18 +0800
Subject: [PATCH] 共享内存/zeromq通信测试
---
test_communication.py | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/test_communication.py b/test_communication.py
index 891a202..532e2d2 100644
--- a/test_communication.py
+++ b/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)
--
Gitblit v1.8.0