给我一个 zmq 的 PUB SUB 模型
时间: 2024-05-08 21:15:02 浏览: 10
PUB SUB 模型是一种基于 ZeroMQ 的消息传递模型,其中发布者(PUB)将消息广播给所有订阅者(SUB),订阅者只接收他们感兴趣的消息。
以下是一个基本的 PUB SUB 模型示例:
发布者(PUB)代码:
```
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5555")
while True:
message = input("Enter message: ")
socket.send_string(message)
```
订阅者(SUB)代码:
```
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://localhost:5555")
socket.setsockopt_string(zmq.SUBSCRIBE, "")
while True:
message = socket.recv_string()
print("Received message: %s" % message)
```
在上述示例中,PUB 将消息广播到所有订阅者,而 SUB 只接收感兴趣的消息。要订阅所有消息,SUB 使用空字符串作为订阅过滤器。
相关问题
zmq 的pub与sub
在ZeroMQ中,Pub-Sub(发布-订阅)模式是一种常见的消息传递模式。它包括两个角色:发布者和订阅者。发布者将消息发送到一个称为主题的通道上,而订阅者则从该通道上接收特定主题的消息。以下是Pub-Sub模式的一些特点:
- 发布者可以同时向多个订阅者发送消息;
- 订阅者可以选择订阅一到多个主题;
- 订阅者只会接收到所订阅主题的消息;
- 订阅者可以随时订阅或取消订阅某个主题。
在ZeroMQ中,Pub-Sub模式用两种套接字来实现:PUB(发布者)和SUB(订阅者)。PUB套接字用于发布消息,而SUB套接字用于接收消息。当消息发送到PUB套接字时,它会被广播到所有订阅了该主题的SUB套接字。同时,SUB套接字只会接收到它所订阅的主题的消息。
使用ZeroMQ的Pub-Sub模式,可以实现高效的消息传递和事件通知机制。例如,可以在分布式系统中使用Pub-Sub模式来实现节点之间的消息传递,或者在实时应用程序中使用它来发送事件通知。
在vue.js中,使用zmq的PUB-SUB模式 编写一个服务端代码
首先,需要先安装 `zeromq` 库和 `zeromq.js` 库:
```sh
npm install zeromq zeromq.js
```
然后,可以使用以下代码编写服务端:
```js
const zmq = require('zeromq')
// 创建一个 zmq 的 socket 对象
const sock = new zmq.Publisher()
// 绑定到指定端口
sock.bindSync('tcp://*:3000')
// 定义一个计数器
let count = 0
// 每秒向客户端发布一条消息
setInterval(() => {
const msg = `Hello ${count++}`
console.log(`Sending: ${msg}`)
sock.send(['my_topic', msg])
}, 1000)
```
上面的代码中,我们创建了一个 `Publisher` 类型的 socket 对象,并绑定到了 `3000` 端口。然后,我们定义了一个计数器,每秒向客户端发布一条消息,消息的主题为 `my_topic`。
可以看出,使用 `zeromq` 库非常简单,我们只需要创建一个 socket 对象,然后调用它的 `send()` 方法即可向客户端发布消息。
相关推荐
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)