1 )生产者还是将消息发送给交换机,消息携带具体的路由key(routingKey)
2 )交换机类型direct,将接受到消息中的routingKey与之绑定队列的routingKey比对
3 )消费者监听一个队列,获取消息,执行消费逻辑.
5 topic主题模式
1 )生产端发送消息,消息携带具体的路由key
2 )交换机的类型topic
3 )队列绑定交换机不在使用具体的路由key而是一个范围值
与路由模式的区别:路由模式中的queue绑定携带的具体的key值,路由细化划分,topic主题模式queue携带的key是一个范围的匹配,某一类消息的获取
四 . rabbitmq的安装及虚拟机和用户名的创建
...........................
五 . springboot整合rabbitmq
整合思路:1 )配置信息 2 )配置类 (明确初始化对象,初始化一个工厂,就从工厂获取连接;生产端逻辑实现简单;) 3 )二次封装
springboot
自动配置:扫描同名,下级包
根据依赖的文件自动配置需要的内容(一旦依赖了jdbc,不配置datasource就报错)
springboot就会根据依赖的amqp自动创建连接消息队列的内部connection,封装一个对外调用的对象rabbitTemplate模板对象;做生产逻辑
利用底层连接,实现异步非阻塞监听,只需要在方法上使用注解,就可以将监听内容传递给方法的参数;
1 添加依赖
<starter-amqp>简化依赖
groupId在maven库是一个具有结构的文件夹
artifactId是一整个文件夹
version是一个文件夹
org\springframework\boot\spring-boot-starter-amqp
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
2 配置文件(application.properties)
spring.rabbitmq.host=10.9.100.26
spring.rabbitmq.port=5672
spring.rabbitmq.username=easymall
spring.rabbitmq.password=123456
spring.rabbitmq.virtualHost=http://www.likecs.com/easymall
3 配置文件中声明对象
内部完成各种连接channel等的封装
声明需要的队列和交换机
配置类中完成这种声明,并且交换机,队列的对象由框架维护,何时调用由业务逻辑决定;
1 package com.jt.config; 2 import org.springframework.amqp.core.Binding; 3 import org.springframework.amqp.core.BindingBuilder; 4 import org.springframework.amqp.core.DirectExchange; 5 import org.springframework.amqp.core.Queue; 6 import org.springframework.context.annotation.Bean; 7 import org.springframework.context.annotation.Configuration; 8 @Configuration 9 public class RabbitmqConfig { 10 //路由模式做案例 11 //准备2个queue,1个路由交换机 12 //声明2个队列 13 @Bean 14 public Queue queue01(){ 15 //org.springframework.amqp.core. 16 return new Queue("springboot-q1", false); 17 } 18 @Bean 19 public Queue queue02(){ 20 //org.springframework.amqp.core. 21 return new Queue("springboot-q2", false); 22 } 23 @Bean//声明交换机 24 public DirectExchange ex(){ 25 return new DirectExchange("springboot-ex"); 26 } 27 //声明绑定关系 28 @Bean 29 public Binding bind01(){ 30 return BindingBuilder. 31 bind(queue01()).to(ex()).with("item.add"); 32 } 33 @Bean 34 public Binding bind02(){ 35 return BindingBuilder. 36 bind(queue02()).to(ex()).with("item.update");}}