如何在springboot中使用消息中间件？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
1.引入依赖
org.springframework.boot
spring-boot-starter-amqp
2.application.properties
#rabbitmq配置
spring.application.name=springboot-mq
spring.rabbitmq.host=192.168.17.129
spring.rabbitmq.port=5672
spring.rabbitmq.username=mytest
spring.rabbitmq.password=mytest
3.rabbitmap配置类
importorg.springframework.amqp.core.Queue;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
@Configuration
publicclassRabbitMQConfig{
@Bean
publicQueuemqQueue(){
returnnewQueue("mqboot");
}
}4.发送类< 大专栏 zyzx(53)-springboot使用消息中间件/h6>
@Component
publicclassSender{
@Autowired
privateAmqpTemplaterabbitTemplate;
publicvoidsend(){
Stringcontent="send:hello"+newDate();
System.out.println("Sender:"+content)
this.rabbitTemplate.convertAndSend("mqboot",content);
}
}收类
@Component
@RabbitListener(queues="mqboot")
publicclassReceiver{
@RabbitHandler
publicvoidprocess(Stringdata){
System.out.println("Receiver:"+data);
}
}6.测试
启动springBoot
如下显示表明:连接成功:
@RunWith(SpringRunner.class)
@SpringBootTest
publicclassApplicationTests{
@Autowired
privateTeacherRepositoryteacherRepository;
/*@Autowired
privateJavaMailSenderjavaMailSender;*/
@Autowired
privateSendersender;
@Test
publicvoidcontextLoads(){
//mq测试
sender.send();
}
}关于如何在springboot中使用消息中间件问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注恰卡编程网行业资讯频道了解更多相关知识。
