SpringBoot整合RabbitMQ及其原理分析

2023-05-23 162

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： SpringBoot整合RabbitMQ及其原理分析

上一篇：RabbitMQ基础知识

1、相关依赖

这里无需指定版本号，让其跟着SpringBoot版本走。本示例使用SpringBoot版本号为2.7.10。

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>

2、生产者、消费者

创建两个SpringBoot应用，模拟消息生产者与消费者【publisher、consumer】。

2-1生产者

编写配置文件，用户名和密码等自行修改这里虚拟机的名称是上一篇文章中新建的。

server.port=8082
#rabbitmq服务器ip
spring.rabbitmq.host=localhost
#rabbitmq的端口
spring.rabbitmq.port=5672
#用户名
spring.rabbitmq.username=用户名
#密码
spring.rabbitmq.password=密码
#配置虚拟机
spring.rabbitmq.virtual-host=demo

声明交换机、队列并绑定：

@ConfigurationpublicclassRabbitMqConfig {
@BeanpublicRabbitTemplaterabbitTemplate(CachingConnectionFactoryconnectionFactory) {
RabbitTemplaterabbitTemplate=newRabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(jackson2JsonMessageConverter());
returnrabbitTemplate;
    }
@BeanpublicMessageConverterjackson2JsonMessageConverter() {
returnnewJackson2JsonMessageConverter();
    }
@BeanpublicDirectExchangegetExchange(){
returnnewDirectExchange("directExchange",false,false);
    }
@BeanpublicQueuegetQueue(){
returnnewQueue("publisher.addUser",true,false,false);
    }
@BeanpublicBindinggetBinding(DirectExchangeexchange,Queuequeue){
returnBindingBuilder.bind(queue).to(exchange).with("publisher.addUser");
    }
}

新建User实体类

@DatapublicclassUser {
privateLongid;
privateStringname;
privateStringdesc;
}

在方法中使用RabbitTemplate来发送消息：

publicinterfacePublisherService {
/*** 添加用户* @param user 用户信息*/voidaddUser(Useruser);
}

@RequiredArgsConstructor@ServicepublicclassPublisherServiceImplimplementsPublisherService{
privatefinalRabbitTemplaterabbitTemplate;
@OverridepublicvoidaddUser(Useruser) {
rabbitTemplate.convertAndSend("directExchange","publisher.addUser",user);
    }
}

以上需要注意的就是交换机的名称、队列名、routingKey。示例中使用的是直连交换机，routingKey需要和队列名保持一致。不懂的可以查看上一篇文章。

controller:

@RequiredArgsConstructor@RestController@RequestMapping("/user")
publicclassUserController {
privatefinalPublisherServicepublisherService;
@PostMapping("/add")
publicvoidadd(){
Useruser=newUser();
user.setId(1000L);
user.setName("黄忠");
user.setDesc("老兵不死，只是逐渐凋零");
publisherService.addUser(user);
    }
}

2-2消费者

消费者的配置和生产者一样，不赘述了，直接看代码：

@Service@Slf4jpublicclassConsumerService {
@RabbitListener(queues="publisher.addUser")
publicvoidaddUser(StringuserStr){
Useruser=JSONObject.parseObject(userStr,User.class);
log.info(user.toString());
    }
}