共享内存/zeromq通信测试

Administrator

2024-04-18 5b73c4ec1f21e6dfe669887e0f6a3b208f42bf31

共享内存/zeromq通信测试

 test_communication.py

@@ -66,8 +66,8 @@
                L2SharedMemoryDataUtil.set_data(datas, shared_memory)
                socket.send_json({'data': [], "time": time.time()})
                response = socket.recv_string()
            except:
                pass
            except Exception as e:
                logging.exception(e)
            finally:
                time.sleep(10)

@@ -80,8 +80,8 @@
                L2SharedMemoryDataUtil.set_data(datas, shared_memory)
                socket.send_json({'data': [], "time": time.time()})
                response = socket.recv_string()
            except:
                pass
            except Exception as e:
                logging.exception(e)
            finally:
                time.sleep(10)

@@ -105,7 +105,7 @@
            deal_ipc_addr=f"ipc://deal_{i}.ipc",
            delegate_data_shared_memory=delegate_data_array,
            deal_data_shared_memory=deal_data_array)
        if constant.is_windows():
        if constant.is_windows() or True:
            param.delegate_ipc_addr = f"tcp://127.0.0.1:{15000 + i}"
            param.deal_ipc_addr = f"tcp://127.0.0.1:{16000 + i}"
        params.append(param)