yukari/flandre
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add zmqtest

Browse Source
This commit is contained in:
remilia 2025-01-18 21:05:23 +08:00
parent df30702ac0
commit 3474608ac1
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
test/testcppzmq.py
View File

@ -1,8 +1,17 @@
import zmq import zmq
import time
import sys
if __name__ == '__main__': if __name__ == '__main__':
s = sys.argv[1]
ctx = zmq.Context() ctx = zmq.Context()
sock = ctx.socket(zmq.REQ)
sock.connect('tcp://11.6.1.66:5556')
# time.sleep(1)
sock.send(s.encode())
print(sock.recv())
exit(0)
sock = ctx.socket(zmq.PULL) sock = ctx.socket(zmq.PULL)
sock.bind('tcp://0.0.0.0:5558') sock.bind('tcp://0.0.0.0:5558')
while True: while True:
s = sock.recv() s = sock.recv()
print(s) print(s)