From 4fd8f66e1c96abbefdfef73b63084ff60872bb70 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 27 二月 2024 14:35:38 +0800
Subject: [PATCH] zeromq集成测试
---
test/test_pyzmq.py | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/test/test_pyzmq.py b/test/test_pyzmq.py
index f57eac8..8f6d381 100644
--- a/test/test_pyzmq.py
+++ b/test/test_pyzmq.py
@@ -11,8 +11,9 @@
socket.bind(f"ipc://order_{index}.ipc")
print("缁戝畾鎴愬姛", index)
while True:
- msg = socket.recv_string()
- print(f"Got Msg({index}-{time.time()}): {msg}")
+ msg = socket.recv_json()
+ use_time = (time.time() - msg['time'])*1000
+ print(f"Got Msg({index}-{time.time()}): 鑰楁椂锛歿use_time}")
socket.send_string("SUCCESS")
@@ -33,7 +34,7 @@
socket.connect(f"ipc://order_{i}.ipc")
socket_client_dict[i] = socket
print(f"寮�濮嬪彂閫佹秷鎭�({i})锛�")
- socket_client_dict[i].send_string(json.dumps({'msg': i, "time": time.time()}))
+ socket_client_dict[i].send_json({'msg': i, "time": time.time()})
response = socket_client_dict[i].recv_string()
--
Gitblit v1.8.0