共享内存/zeromq通信测试

Administrator

2024-04-18 b9aa0e239c46945afabfbe572751b9aa48dd939c

共享内存/zeromq通信测试

 test_communication.py

@@ -62,22 +62,23 @@
        socket.connect(delegate_ipc_addr)
        while True:
            try:
                print("发送委托数据")
                datas = [('000990', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100]

                datas = ('000990', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100
                L2SharedMemoryDataUtil.set_data(datas, shared_memory)
                socket.send_json({'data': [], "time": time.time()})
                response = socket.recv_string()
                print("收到委托反馈")
            except Exception as e:
                logging.exception(e)
            finally:
                time.sleep(10)
                time.sleep(5)

    def send_deal_data(self, deal_ipc_addr, shared_memory):
        socket = self.context.socket(zmq.REQ)
        socket.connect(deal_ipc_addr)
        while True:
            try:
                datas = [('888888', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100]
                datas = ('888888', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1') * 100
                L2SharedMemoryDataUtil.set_data(datas, shared_memory)
                socket.send_json({'data': [], "time": time.time()})
                response = socket.recv_string()