设计网站平台风格,百度网盟推广费用是多少,外网如何访问群晖wordpress,制作ppt用什么软件好Publish/Subscribe
**发布(Publish)、订阅(Subscribe)#xff1a;**允许将同一个消息发送给多个消费者 **注意#xff1a;**exchange负责消息路由#xff0c;而不是存储#xff0c;路由失败则消息丢失
常见的**X(exchange–交换机)***类型#xff1a;
Fanout 广播Direc…Publish/Subscribe
**发布(Publish)、订阅(Subscribe)**允许将同一个消息发送给多个消费者 **注意**exchange负责消息路由而不是存储路由失败则消息丢失
常见的**X(exchange–交换机)***类型
Fanout 广播Direct 路由Topoc 话题
发布订阅–FanoutExchange
案例三利用SpringAMQP演示广播交换机的使用
1.在消费者consumer包中创建一个FanoutConfig类声明队列、交换机并将两者绑定
Configuration
public class FanoutConfig {//声明FanoutExchange交换机itcast.fanoutBeanpublic FanoutExchange fanoutExchange(){return new FanoutExchange(itcast.fanout);}//声明fanout.queue1队列Beanpublic Queue fanoutQueue1(){return new Queue(fanout.queue1);}//绑定fanout.queue1队列和交换机Beanpublic Binding bindingQueue1(Queue fanoutQueue1, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}//声明fanout.queue2队列Beanpublic Queue fanoutQueue2(){return new Queue(fanout.queue2);}//绑定fanout.queue2队列和交换机Beanpublic Binding bindingQueue2(Queue fanoutQueue2, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);}
}2.在消费者consumer包中编写两个消费者SpringRabbitListener方法分别监听fanout.queue1和fanout.queue2
Component
public class SpringRabbitListener {RabbitListener(queues fanout.queue1)public void listenFanoutQueue1(String msg) {System.out.println(消费者接收到fanout.queue1的消息【 msg 】);}RabbitListener(queues fanout.queue2)public void listenFanoutQueue2(String msg) {System.out.println(消费者接收到fanout.queue2的消息【 msg 】);}}
3.在publiSher中编写测试方法向itcast.fanout发送消息
RunWith(SpringRunner.class)
SpringBootTest
public class SpringAmqpTest {Autowiredprivate RabbitTemplate rabbitTemplate;Testpublic void testSendFanoutExchange() {// 交换机名称String exchangeName itcast.fanout;// 消息String message hello, every one!;// 发送消息rabbitTemplate.convertAndSend(exchangeName, , message);}
}4.运行结果 发布订阅–DirectExchange
将接收到的消息根据规则路由到指定的Queue因此称为路由模式(routes)
每一个Queue都与Exchange设置一个BindingKey暗号发布者发送消息时指定消息的RoutingKeyExchange将消息路由到BindingKey与消息RoutingKey一致的队列 案例四利用SpringAMQP演示DirectExchange的使用
1.直接用注解
RabbitListener声明Exchange、Queue、RoutingKey
QueueBinding注解用于绑定队列和交换器并指定路由键
Component
public class SpringRabbitListener {RabbitListener(bindings QueueBinding(value Queue(name direct.queue1),exchange Exchange(name itcast.direct, type ExchangeTypes.DIRECT),key {red, blue}))public void listenDirectQueue1(String msg){System.out.println(消费者接收到direct.queue1的消息【 msg 】);}RabbitListener(bindings QueueBinding(value Queue(name direct.queue2),exchange Exchange(name itcast.direct, type ExchangeTypes.DIRECT),key {red, yellow}))public void listenDirectQueue2(String msg){System.out.println(消费者接收到direct.queue2的消息【 msg 】);}}2.测试
RunWith(SpringRunner.class)
SpringBootTest
public class SpringAmqpTest {Autowiredprivate RabbitTemplate rabbitTemplate;Testpublic void testSendDirectExchange() {// 交换机名称String exchangeName itcast.direct;// 消息String message hello, red!;// 发送消息rabbitTemplate.convertAndSend(exchangeName, red, message);}
}3.结果 发布订阅–TopicExchange
TopicExchange与DirectExchange类似区别在于routingKey必须是多个单词的列表并且以**.**分割
Queue与Exchange指定BindingKey时可以使用通配符
# : 代指0个或多个单词* : 代指一个单词 案例五利用SpringAMQP演示TopicExchange的使用
1.直接用注解
RabbitListener声明Exchange、Queue、RoutingKey
QueueBinding注解用于绑定队列和交换器并指定路由键
Component
public class SpringRabbitListener {RabbitListener(bindings QueueBinding(value Queue(name topic.queue1),exchange Exchange(name itcast.topic, type ExchangeTypes.TOPIC),key china.#))public void listenTopicQueue1(String msg){System.out.println(消费者接收到topic.queue1的消息【 msg 】);}RabbitListener(bindings QueueBinding(value Queue(name topic.queue2),exchange Exchange(name itcast.topic, type ExchangeTypes.TOPIC),key #.news))public void listenTopicQueue2(String msg){System.out.println(消费者接收到topic.queue2的消息【 msg 】);}
}2.测试
RunWith(SpringRunner.class)
SpringBootTest
public class SpringAmqpTest {Autowiredprivate RabbitTemplate rabbitTemplate;Testpublic void testSendTopicExchange() {// 交换机名称String exchangeName itcast.topic;// 消息String message 合理小姐是凑巧先生独一无二的女主角;//String message 今天天气不错我的心情好极了!;// 发送消息rabbitTemplate.convertAndSend(exchangeName, china.news, message);//rabbitTemplate.convertAndSend(exchangeName, china.weather, message);}}3.结果
