From b9aa0e239c46945afabfbe572751b9aa48dd939c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 18 四月 2024 16:44:29 +0800
Subject: [PATCH] 共享内存/zeromq通信测试
---
test_communication.py | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/test_communication.py b/test_communication.py
index 532e2d2..3b109d8 100644
--- a/test_communication.py
+++ b/test_communication.py
@@ -62,22 +62,23 @@
socket.connect(delegate_ipc_addr)
while True:
try:
- print("鍙戦�佸鎵樻暟鎹�")
- datas = [('000990', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100]
+
+ 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()})
response = socket.recv_string()
+ print("鏀跺埌濮旀墭鍙嶉")
except Exception as e:
logging.exception(e)
finally:
- time.sleep(10)
+ time.sleep(5)
def send_deal_data(self, deal_ipc_addr, shared_memory):
socket = self.context.socket(zmq.REQ)
socket.connect(deal_ipc_addr)
while True:
try:
- datas = [('888888', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100]
+ datas = ('888888', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100
L2SharedMemoryDataUtil.set_data(datas, shared_memory)
socket.send_json({'data': [], "time": time.time()})
response = socket.recv_string()
--
Gitblit v1.8.0