当前位置：首页 > news >正文

湖北省建设厅信息网站最近新闻头条最新消息

news 2025/7/11 21:08:28

湖北省建设厅信息网站,最近新闻头条最新消息,国内做网站费用,宠物网站开发目录背景前景知识 1.启动一个代理服务器 2.发布者 3.订阅者实际应用 1.模拟智驾收来自交互箱131的按钮json数据 2.模拟交互箱131收来自智驾137的cjson数据背景在调试防爆无轨无人矿车时，出现消息代理不能很好转发，于是在公司通过代理的方式…

背景

前景知识

1.启动一个代理服务器

2.发布者

3.订阅者

实际应用

1.模拟智驾收来自交互箱131的按钮json数据

2.模拟交互箱131收来自智驾137的cjson数据

背景

在调试防爆无轨无人矿车时，出现消息代理不能很好转发，于是在公司通过代理的方式模拟跨机互联收发数据报文，当时记录的目的是若更新固件后若不能收发数据，智驾的代码那块可参考该文章进行修改相应ip和端口

前景知识

ZeroMQ（ZMQ）是一个强大的消息传递库，它提供了许多灵活的消息传递模式，包括发布-订阅、请求-应答、推送-接收等。在 ZeroMQ 中，您可以通过使用不同的套接字类型和模式来构建消息代理转发机制。

下面是一个简单的示例，演示了如何使用 ZeroMQ 来实现一个消息代理转发机制：

1.启动一个代理服务器

代理服务器会接收来自多个发布者的消息，并将这些消息发送给订阅者。

import zmqcontext = zmq.Context()# 代理服务器绑定到tcp://*:5555
frontend = context.socket(zmq.SUB)
frontend.bind("tcp://*:5555")# 代理服务器发送到tcp://*:5556
backend = context.socket(zmq.PUB)
backend.bind("tcp://*:5556")zmq.proxy(frontend, backend)

2.发布者

发布者将消息发送到代理服务器

import zmqcontext = zmq.Context()
socket = context.socket(zmq.PUB)
socket.connect("tcp://localhost:5555")while True:msg = input("Enter message: ")socket.send_string(msg)

3.订阅者

订阅者从代理服务器接收消息。

import zmqcontext = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://localhost:5556")while True:msg = socket.recv_string()print("Received message: ", msg)

在这个示例中，代理服务器充当消息的中转站，让发布者和订阅者之间进行解耦。发布者将消息发送到代理服务器，而订阅者从代理服务器接收消息，实现了消息的转发机制。

大家可以根据具体需求和场景，调整消息传递模式、套接字类型以及网络配置，来构建适合您需求的消息代理转发机制。