From 93aa26b89d046031f7a143e686c151197b420876 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 27 二月 2024 14:13:58 +0800
Subject: [PATCH] zeromq集成测试
---
test/test_pyzmq.py | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/test/test_pyzmq.py b/test/test_pyzmq.py
index a2a8ab4..b5b0750 100644
--- a/test/test_pyzmq.py
+++ b/test/test_pyzmq.py
@@ -5,20 +5,20 @@
import zmq
-def __create_server(context, port):
+def __create_server(context, index):
socket = context.socket(zmq.REP)
- socket.bind(f"ipc://order{port}.ipc")
- print("缁戝畾鎴愬姛", port)
+ socket.bind(f"ipc://order_{index}.ipc")
+ print("缁戝畾鎴愬姛", index)
while True:
msg = socket.recv_json()
- print(f"Got Msg({port}): {msg}")
+ print(f"Got Msg({index}): {msg}")
socket.send_string("SUCCESS")
def create_server():
context = zmq.Context()
for i in range(5):
- threading.Thread(target=lambda: __create_server(context, 10000 + i), daemon=True).start()
+ threading.Thread(target=lambda: __create_server(context, i), daemon=True).start()
socket_client_dict = {}
@@ -27,7 +27,7 @@
def send_data(context, i):
if i not in socket_client_dict:
socket = context.socket(zmq.REQ)
- socket.connect(f"ipc://order{10000 + i}.ipc")
+ socket.connect(f"ipc://order_{i}.ipc")
socket_client_dict[i] = socket
socket_client_dict[i].send_json({'msg': i})
--
Gitblit v1.8.0