RabbitMq中不存在topic这个概念&＃xff0c;不同的消费者想要消费不同的消息只有通过Exchange(交换器)来实现
Exchange类型介绍注&＃xff1a;1. 在针对同一个queue或者exchage时&＃xff0c;queueDeclare消费者和生产者所有的配置都必须要保存一致&＃xff0c;否则会抛出530的异常。
2.Exchange只用于Producer&＃xff0c;RoutingKey用来绑定Exchange和Queue&＃xff0c;这个一般在Producer这端做的。
*3. 假如Producer把消息发到没有绑定Queue的Exchange消息会丢失&＃xff01;
direct类型
该类型的是默认的exchage&＃xff0c;直接指定消息需要发送的那个队列
Exchage创建
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
发送消息
channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
接受消息
chanel.queueDeclare(QUEUE_NAME, false, false, false, null);
Topic类型
该类型的exchange可以通过模糊匹配&＃xff0c;使一个消费者可以消费多个queue的消息
Exchage创建
//EXCHANGE_NAME创建过后不能修改 第三个参数表示持久化
channel.exchangeDeclare(EXCHANGE_NAME, "topic",true);
//将队列,转换器,路由规则绑定(下面表示的是吧不同的两个队列绑定到同一个转换器上,但是配置不同的routeKey)
channel.queueBind(QUEUE_NAME, EXCHANGE_NAME, "*.second.*");
channel.queueBind(QUEUE_NAME&＃43;".v2", EXCHANGE_NAME, "first.second.*");
发送消息
//第二个参数表示routeKey 格式为String.String.String...(根据路由规则匹配,下面这个消息会同时发送到QUEUE_NAME和QUEUE_NAME.v2这两个队列中)
channel.basicPublish(EXCHANGE_NAME, "first.second.three", null,message.getBytes());
接受消息
channel.exchangeDeclare(EXCHANGE_NAME, "topic");
String queue &＃61; channel.queueDeclare().getQueue();
//第三个参数表示routeKey&＃xff0c;这里不同于生产者&＃xff0c;是可以使用* 或者 # 进行模糊匹配,即满足该表达式的queue都可以消费&＃xff0c;比如之前设置的first.second.three在这里可以设置成first.*.*或者first.#或者 *.second.*来进行消费
channel.queueBind(queue, EXCHANGE_NAME, "first.*.*");
// 声明要关注的队列
channel.queueDeclare(queue, true, false, false, null);
Fanout类型
不处理路由键。你只需要简单的将队列绑定到交换机上。一个发送到该类型交换机的消息都会被广播到与该交换机绑定的所有队列
创建Exchange
channel.exchangeDeclare(EXCHANGE_NAME, "fanout")
发送消息
channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes());
接受消息
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
String queueName &＃61; channel.queueDeclare().getQueue();
channel.queueBind(queueName, EXCHANGE_NAME, "");
京公网安备 11010802041100号