Publish/Subscribe 发布与订阅模式

Publish/Subscribe 发布与订阅：

通过交换机来实现，一个生产者可以让不同队列的消费者同时得到消息
生产者：

package Fanout;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import utils.RabbitMqUtils;
import java.io.IOException;
public class Provider {public static void main(String[] args) throws IOException {Connection connection = RabbitMqUtils.getConnection();Channel channel = connection.createChannel();channel.exchangeDeclare("logs","fanout");//创建交换机 1.交换机名称 2.交换机类型channel.basicPublish("logs","",null,"hello exchanges".getBytes());RabbitMqUtils.closeConnectionAndChannel(channel,connection);}
}

多个消费者在不同的队列中：
消费者1：

package Fanout;
import com.rabbitmq.client.*;
import utils.RabbitMqUtils;
import java.io.IOException;
public class Consumer {public static void main(String[] args) throws IOException {Connection connection = RabbitMqUtils.getConnection();Channel channel = connection.createChannel();channel.exchangeDeclare("logs","fanout");//可以再次声名队列，有就调用 没有才创建 相当于绑定String queueName = channel.queueDeclare().getQueue();//声名临时队列 不指定具体队列// channel.exchangeBind("logs",queueName,"fanout");//绑定队列channel.queueBind(queueName,"logs","");//1.队列名 2.交换机名 3.routing keychannel.basicConsume(queueName,true,new DefaultConsumer(channel){@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("消费者1---"+new String(body));}});}
}

消费者2：

package Fanout;
import com.rabbitmq.client.*;
import utils.RabbitMqUtils;
import java.io.IOException;
public class Consumer1 {public static void main(String[] args) throws IOException {Connection connection = RabbitMqUtils.getConnection();Channel channel = connection.createChannel();channel.exchangeDeclare("logs","fanout");//可以再次声名队列，有就调用 没有才创建 相当于绑定String queueName = channel.queueDeclare().getQueue();//声名临时队列// channel.exchangeBind("logs",queueName,"fanout");//绑定队列channel.queueBind(queueName,"logs","");//1.队列名 2.交换机名 3.routing keychannel.basicConsume(queueName,true,new DefaultConsumer(channel){@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("消费者3---"+new String(body));}});}
}

Publish/Subscribe 发布与订阅模式相关推荐

译: 3. RabbitMQ Spring AMQP 之 Publish/Subscribe 发布和订阅
在第一篇教程中,我们展示了如何使用start.spring.io来利用Spring Initializr创建一个具有RabbitMQ starter dependency的项目来创建spring-am ...
RabbitMQ Tutorials 3 - Publish/Subscribe 发布／订阅
发布/订阅分发一个消息给多个消费者(consumers).这种模式被称为"发布/订阅". 为了描述这种模式,我们将会构建一个简单的日志系统.它包括两个程序--第一个程序负责发送日 ...
【RabbitMQ】基础三：发布与订阅模式（Publish/Subscribe）
[RabbitMQ]基础三:发布与订阅模式(Publish/Subscribe) 1. 订阅模式 2. 发布与订阅模式说明 3. 代码示例 3.1 生产者 3.2 消费者 3.3 测试 4. 总结 1 ...
RabbitMQ工作模式Publish/Subscribe发布订阅,test测试代码
RabbitMQ有以下几种工作模式 : 1.Work queues 工作队列 2.Publish/Subscribe 发布订阅 3.Routing 路由 4.Topics 通 ...
php订阅系统,php redis pub/sub(Publish/Subscribe,发布/订阅的信息系统)之基本使用
一.场景介绍最近的一个项目需要用到发布/订阅的信息系统,以做到最新实时消息的通知.经查找后发现了redis pub/sub(发布/订阅的信息系统)可以满足我的开发需求,而且学习成本和使用成本也比较低 ...
知方可补不足~SQL2008中的发布与订阅模式~续
上一回介绍了如何在sql2008中建立一个数据库的发布者,今天来说一下如何建立一个订阅者,其实订阅者也是一个数据库,而这个数据库是和发布者的数据结构相同的库,它们之间通过SQL代理进行数据上的同步. ...
Redis发布与订阅模式
Redis的Pub/Sub实现了发布/订阅消息范式,发布者将消息发布到不同的频道,订阅者订阅感兴趣的频道消息,而不需要关心是谁在发布.这种发布者和订阅者的解耦合方式可以极大的扩展的扩展性网络拓扑. 为 ...
React中发布与订阅模式
一,用处当我们想要父组件传值给子组件时,通常会使用props传值. 子组件传值给父组件时,通常会子组件中的事件触发一个回调函数(也是props),父组件中的对应函数再去修改值. 兄弟组件间传值,我通 ...
redis的发布和订阅模式
**开启:**以MULTI开始一个事务 **入队:**将多个命令入队到事务中,接到这些命令并不会立即执行,而是放到等待执行的事务队列中 **执行:**又EXEC命令触发事务 **redis的发布订阅: ...

Publish/Subscribe 发布与订阅模式

Publish/Subscribe 发布与订阅模式相关推荐

最新文章

热门文章