zeromq集成测试

Administrator

2024-02-27 824b434b3e1555ac50ff58d412171a052a953d8a

 test/test_pyzmq.py

@@ -2,7 +2,7 @@
import multiprocessing
import threading
import time

from huaxin_client import l2_data_manager
import zmq


@@ -45,7 +45,7 @@
    response = socket_client_dict[i].recv_string()


if __name__ == "__main__":
if __name__ == "__main__1":

    serverProcess = multiprocessing.Process(
        target=create_server)
@@ -59,3 +59,9 @@
            threading.Thread(target=lambda: send_data(context, i), daemon=True).start()
        time.sleep(5)
    input()


if __name__ == "__main__":
    l2_data_manager.test()

    pass