ZeroMQ(java)之Publish/Subscribe模式

前面的文章介绍了比较简单的Request/Subscribe模式，这篇文章介绍更为经典的Publish/Subscribe通信模式用来ZeroMQ的实现，其通信方式如下图：

客户端（subscriber）向服务器（publisher）订阅消息，然后服务器可以将消息推送到所有订阅了消息的客户端，这里也可以理解为广播吧。。。。

好了，闲话不多说了，直接上用ZeroMQ实现这种通信模式的代码吧：

（1）服务端（publisher）：

[java] view plaincopy

package pubsub;
import org.zeromq.ZMQ;
public class Publisher {
public static void main(String args[]) {
ZMQ.Context context = ZMQ.context(1); //创创建包含一个I/O线程的context
ZMQ.Socket publisher = context.socket(ZMQ.PUB); //创建一个publisher类型的socket，他可以向所有订阅的subscriber广播数据
publisher.bind(”tcp://*:5555”); //将当前publisher绑定到5555端口上，可以接受subscriber的订阅
while (!Thread.currentThread ().isInterrupted ()) {
String message = ”fjs hello”; //最开始可以理解为pub的channel，subscribe需要订阅fjs这个channel才能接收到消息
publisher.send(message.getBytes());
}
publisher.close();
context.term();
}
}

代码很简单吧，这里publisher来充当服务端，所有的subscriber都需要建立于publisher的连接。，，。，

（2）客户端（subscriber）代码：

[java] view plaincopy

package pubsub;
import org.zeromq.ZMQ;
public class Subscriber {
public static void main(String args[]) {
for (int j = 0; j < 100; j++) {
new Thread(new Runnable(){
public void run() {
// TODO Auto-generated method stub
ZMQ.Context context = ZMQ.context(1); //创建1个I/O线程的上下文
ZMQ.Socket subscriber = context.socket(ZMQ.SUB); //创建一个sub类型，也就是subscriber类型的socket
subscriber.connect(”tcp://127.0.0.1:5555”); //与在5555端口监听的publisher建立连接
subscriber.subscribe(”fjs”.getBytes()); //订阅fjs这个channel
for (int i = 0; i < 100; i++) {
byte[] message = subscriber.recv(); //接收publisher发送过来的消息
System.out.println(”receive : ” + new String(message));
}
subscriber.close();
context.term();
}
}).start();
}
}
}

这里需要注意订阅的channel问题，如果这里错了的话，subscriber是不会受到publisher发送过来的数据的

好了，到这里publish/subscribe的实现就算ok了

ZeroMQ(java)之Publish/Subscribe模式相关推荐

RabbitMQ 入门系列（11）— RabbitMQ 常用的工作模式（simple模式、work模式、publish/subscribe模式、routing模式、topic模式）
1. simple 模式 simple 模式是最简单最常用的模式 2. work 模式 work 模式有多个消费者消息产生者将消息放入队列.生产者系统不需知道哪一个任务执行系统在空闲,直接将任务扔到 ...
Publish/SubScribe（发布/订阅）模式
前言上一篇文章中,我们讲了如何利用Observer(观察者)模式实现多选框的全选, 本篇文章将带来Publish/SubScribe模式,并且利用该模式实现一个简易的消息通知功能,文章的最后还与Ob ...
Java（发布/订阅模式）
1.概述观察者模式又称为发布/订阅(Publish/Subscribe)模式观察者设计模式涉及到两种角色:主题(Subject)和观察者(Observer) (1)Subject模块 Subjec ...
javascript设计模式——Publish/Subscribe
推荐阅读http://dev.housetrip.com/2014/09/15/decoupling-javascript-apps-using-pub-sub-pattern/ 我们先引出问题的所在 ...
实现OPC UA publish/subscribe单次发送
最近一直在写OPC UA publish/subscribe 模式的程序,发现程序设置好之后,数据就源源不断地发出来了.但是令人困惑的是变量值明明没有改变,数据会连续不断地重复发送,根本停不下来 .网 ...
ZeroMQ之Publish/Subscribe (Java)
前面的文章介绍了比较简单的Request/Subscribe模式, 这篇文章介绍更为经典的Publish/Subscribe通信模式用来ZeroMQ的实现,其通信方式如下图: 客户端(subscrib ...
RabbitMQ工作模式Publish/Subscribe发布订阅,test测试代码
RabbitMQ有以下几种工作模式 : 1.Work queues 工作队列 2.Publish/Subscribe 发布订阅 3.Routing 路由 4.Topics 通 ...
【RabbitMQ】基础三：发布与订阅模式（Publish/Subscribe）
[RabbitMQ]基础三:发布与订阅模式(Publish/Subscribe) 1. 订阅模式 2. 发布与订阅模式说明 3. 代码示例 3.1 生产者 3.2 消费者 3.3 测试 4. 总结 1 ...
RabbitMQ发布/订阅模式（Publish/Subscribe）
工作队列模式是直接在生产者与消费者里声明好一个队列,这种情况下消息只会对应同类型的消费者. 举个用户注册的列子:用户在注册完后一般都会发送消息通知用户注册成功(失败).如果在一个系统中,用户注册信息有 ...

ZeroMQ(java)之Publish/Subscribe模式

ZeroMQ(java)之Publish/Subscribe模式相关推荐

最新文章

热门文章