Springboot整合RabbitMq-用心看完这一篇就够了(最新)

SpringBoot-整合MQ---目录

第一步创建一个springboot的项目
- 1---HelloWorld模型
- 2---Work模型
- 3---Fanout模式
- 4---direct路由模式
- 5---主题模式topics

第一步创建一个springboot的项目

创建springboot项目选好所需要的骨架

1—HelloWorld模型

springboot-整合mq-第一种模型 Hello World 简单模式
一个生产者丶默认交换机丶一个队列丶一个消费者。

第一步配置好自己的yml

server:port: 8001spring:rabbitmq:username: guest password: guest virtual-host: /  port: 5672host: 192.168.192.168

创建生产者

第一个：HelloWorld模型
1、一个生产者
2、默认交换机
3、一个队列
4、一个消费者

@SpringBootTest
// 1--生产者
class SpringBootBuliangrenApplicationTests {@Autowired//RabbitTemplate是模板对象,用来简化mq操作private RabbitTemplate rabbitTemplate;
// 2--不用写就是默认交换机
// 3--队列名称是：hello
// 发送的消息是HelloWorld@Testvoid contextLoads() {       // 3--队列名字是：hellorabbitTemplate.convertAndSend("hello", "HelloWorld");}
}

创建消费者

@Component//@RabbitListener 这个注解代表消费者的 一个监听//消费者监听hello队列
@RabbitListener(queuesToDeclare = @Queue(value = "hello"))
public class HelloCustomer {//消费者 - 消费 - 提供者 的消息@RabbitHandlerpublic void receival(String message){System.out.println("消费接收到了消息----->"+message);}
}

运行

此时hello队列也创建出了

2—Work模型

springboot-整合mq-第二种模型:work-工作模式
一个生产者丶默认交换机丶一个队列丶多个消费者。

第一步配置好自己的yml

server:port: 8001spring:rabbitmq:username: guest password: guest virtual-host: /  port: 5672host: 192.168.192.168

创建生产者

第二个：Work模型
1、一个生产者
2、默认交换机
3、一个队列
4、多个消费者

@SpringBootTest //1 一个生产者
class SpringBootBuliangren2ApplicationTests {// 2--不用写就是默认交换机@Autowired    //RabbitTemplate是模板对象,用来简化mq操作private RabbitTemplate rabbitTemplatel;
// 3--队列名称是：workTest
//发送的消息是hello,work模型 我们发送多条消息 应为有多个消费者@Testvoid contextLoads() {//消费者发送10 条消息for (int i = 0;i<10;i++){rabbitTemplatel.convertAndSend("workTest","hello,work模型");}}
}

创建消费者

@Component
public class HelloCustomer {//1号消费者   ---监听workTest队列@RabbitListener(queuesToDeclare = @Queue("workTest"))public void receive01(String message){//消费者 - 消费 - 提供者 的消息System.out.println("消费者1号 - 接收到了消息----->"+message);}//2号消费者   ---监听workTest队列@RabbitListener(queuesToDeclare = @Queue("workTest"))public void receive02(String message){//消费者 - 消费 - 提供者 的消息System.out.println("消费者2号 - 接收到了消息----->"+message);}//3号消费者   ---监听workTest队列@RabbitListener(queuesToDeclare = @Queue("workTest"))public void receive03(String message){//消费者 - 消费 - 提供者 的消息System.out.println("消费者3号 - 接收到了消息----->"+message);}
}

运行

此时workTest队列也创建出了

3—Fanout模式

springboot-整合mq-第三种模型:Fanout-广播模型-订阅模式
多个消费者，每一个消费这都有自己的队列，每个队列都绑定到交换机
生产者发送消息到交换机-交换机发送到哪个队列

第一步配置好自己的yml

server:port: 8003spring:rabbitmq:virtual-host: /host: 192.168.192.168port: 5672username: guestpassword: guest

创建生产者

第三个：Fanout模式
1、一个生产者
2、一个交换机
3、多个队列
4、多个消费者

@SpringBootTest//1 一个生产者
class SpringBootBuliangren3ApplicationTests {@Autowired//RabbitTemplate是模板对象,用来简化mq操作private RabbitTemplate rabbitTemplate;@Testvoid contextLoads() {//参数： 交换机名称, 路由, 生产者发送的消息//我们使用for循环 ---发送多条消息 ---应为有多个消费者for (int i = 0; i < 10; i++) {rabbitTemplate.convertAndSend("fanoutlogs", "", "Fanout模型发送的消息");}}
}

创建消费者

@Component//创建消费者
public class FanoutCustomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue("FanoutTest"),//创建的队列名称exchange = @Exchange(value = "fanoutlogs",//绑定的交换机type = "fanout"))})//fanout类型public void receice01(String message) {System.out.println("消费者1号 - 接收到了消息----->" + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue("FanoutTest"),//创建的队列名称exchange = @Exchange(value = "fanoutlogs",//绑定的交换机type = "fanout"))})//fanout类型public void receice02(String message) {System.out.println("消费者2号 - 接收到了消息----->" + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue("FanoutTest"),//创建的队列名称exchange = @Exchange(value = "fanoutlogs",//绑定的交换机type = "fanout"))})//fanout类型public void receice03(String message) {System.out.println("消费者3号 - 接收到了消息----->" + message);}
}

运行

此时FanoutTest队列也创建出了

此时fanoutlogs交换机也创建出了

4—direct路由模式

springboot-整合mq-第四种模型:-路由模型-direct
根据指定路由的key转向不同的队列

第一步配置好自己的yml

server:port: 8004
spring:rabbitmq:port: 5672host: 192.168.192.168virtual-host: /username: guestpassword: guest

创建生产者

第四个：direct路由模式
1、一个生产者
2、一个交换机
3、多个队列
4、多个消费者
根据不同的key 接收不同的消息

创建生产者

@SpringBootTest
class SpringBootBuliangren4ApplicationTests {@Autowired            //RabbitTemplate是模板对象,用来简化mq操作private RabbitTemplate rabbitTemplate;//路由模式@Testvoid contextLoads() {       参数一:是交换机参数二:队列参数三:消息rabbitTemplate.convertAndSend("directlogs", "info", "发送info的key的路由信息");rabbitTemplate.convertAndSend("directlogs", "warn", "发送warn的key的路由信息");}
}

创建消费者

@Component
public class RouteCusstomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue("directTest01"),//创建队列名字exchange = @Exchange(value = "directlogs"),//绑定的交换机key = {"info"           //指定的key})})public void recrvel01(String message) {System.out.println("消费者1号: 接收的消息是---->" + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue("directTest02"),//创建队列的名字exchange = @Exchange(value = "directlogs"),//绑定的交换机key = {"error"           //指定的key})})public void recrvel02(String message) {System.out.println("消费者2号: 接收的消息是---->" + message);}@RabbitListener(bindings = {@QueueBinding(value = @Queue("directTest03"),//创建队列的名字exchange = @Exchange(value = "directlogs"),//绑定的交换机key = {"warn"           //指定的key})})public void recrvel03(String message) {System.out.println("消费者3号: 接收的消息是---->" + message);}
}

运行

此时directTest队列也创建出了

此时交换机也创建出了

5—主题模式topics

springboot-整合mq-第五种模型:主题模型-Topics
第五个：动态路由模式Topics
#号可以代替零个或多个单词.
*号可以代替一个完整的单词

第一步配置好自己的yml

server:port: 8005spring:rabbitmq:host: 192.168.192.168port: 5672username: guestpassword: guestvirtual-host: /

创建生产者

@SpringBootTest
class SpringBootBuliangren5ApplicationTests {@Autowired  //rabbitmqtemplate 是简化mq开发private RabbitTemplate rabbitTemplate;@Testvoid contextLoads() {   //参数1:交换机  参数2:key  参数3:生产者的消息rabbitTemplate.convertAndSend("topicsTest","a.user.save","user.save-----消息");}
}

创建消费者

@Component//消费者
public class TopicCusstomer {@RabbitListener(bindings = {@QueueBinding(value = @Queue("topiceTest01"),//创建的队列exchange = @Exchange(type = "topic",name = "topicsTest"),//topic类型绑定的交换机topicsTestkey = {"#.user.#"})})public void recevicel01(String messge){System.out.println("消费者1号: 接收的消息是---->"+messge);}@RabbitListener(bindings = {@QueueBinding(value = @Queue("topiceTest02"),//创建的队列exchange = @Exchange(type = "topic",name = "topicsTest"),//topic类型绑定的交换机topicsTestkey = {"*.user","user.*"})})public void recevicel02(String messge){System.out.println("消费者2号: 接收的消息是---->"+messge);}
}

运行

学习是一步一步来的不要跳过