From b86a707eb861bf746783f20e197cba40bed0b978 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 27 二月 2024 14:23:37 +0800
Subject: [PATCH] zeromq集成测试
---
test/test_pyzmq.py | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/test/test_pyzmq.py b/test/test_pyzmq.py
index 17d9a12..c6cf4b6 100644
--- a/test/test_pyzmq.py
+++ b/test/test_pyzmq.py
@@ -1,3 +1,4 @@
+import json
import multiprocessing
import threading
import time
@@ -10,7 +11,7 @@
socket.bind(f"ipc://order_{index}.ipc")
print("缁戝畾鎴愬姛", index)
while True:
- msg = socket.recv_json()
+ msg = socket.recv_string()
print(f"Got Msg({index}): {msg}")
socket.send_string("SUCCESS")
@@ -27,11 +28,10 @@
def send_data(context, i):
if i not in socket_client_dict:
socket = context.socket(zmq.REQ)
- result = socket.connect(f"ipc://order_{i}.ipc")
- print("杩炴帴缁撴灉锛�", result)
+ socket.connect(f"ipc://order_{i}.ipc")
socket_client_dict[i] = socket
- socket_client_dict[i].send_json({'msg': i})
+ socket_client_dict[i].send_string(json.dumps({'msg': i}))
response = socket_client_dict[i].recv_string()
--
Gitblit v1.8.0