From ba656c32b0155cfeffdf577a2a4f06460dd55bbc Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 27 二月 2024 14:19:23 +0800
Subject: [PATCH] zeromq集成测试
---
test/test_pyzmq.py | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/test/test_pyzmq.py b/test/test_pyzmq.py
index b5b0750..17d9a12 100644
--- a/test/test_pyzmq.py
+++ b/test/test_pyzmq.py
@@ -18,7 +18,7 @@
def create_server():
context = zmq.Context()
for i in range(5):
- threading.Thread(target=lambda: __create_server(context, i), daemon=True).start()
+ threading.Thread(target=lambda: __create_server(context, i), daemon=True).start()
socket_client_dict = {}
@@ -27,7 +27,8 @@
def send_data(context, i):
if i not in socket_client_dict:
socket = context.socket(zmq.REQ)
- socket.connect(f"ipc://order_{i}.ipc")
+ result = socket.connect(f"ipc://order_{i}.ipc")
+ print("杩炴帴缁撴灉锛�", result)
socket_client_dict[i] = socket
socket_client_dict[i].send_json({'msg': i})
--
Gitblit v1.8.0