如何在springboot中使用消息中间件？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

1.引入依赖

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

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配置类

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

 @Bean
 public Queue mqQueue(){
  return new Queue("mqboot");
 }
}

4.发送类< 大专栏 zyzx(53)-springboot使用消息中间件/h6>

@Component
public class Sender {

 @Autowired
 private AmqpTemplate rabbitTemplate;

 public void send(){
  String content = "send: hello"+new Date();
  System.out.println("Sender:"+content)
  this.rabbitTemplate.convertAndSend("mqboot",content);
 }
}

收类

@Component
@RabbitListener(queues = "mqboot")
public class Receiver {

 @RabbitHandler
 public void process(String data){
  System.out.println("Receiver:"+data);
 }
}

6.测试

启动springBoot

如下显示表明:连接成功:

@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {
 @Autowired
 private TeacherRepository teacherRepository;

 /*@Autowired
 private JavaMailSender javaMailSender;*/

 @Autowired
 private Sender sender;

 @Test
 public void contextLoads() {
  //mq测试
  sender.send();
 }
}

关于如何在springboot中使用消息中间件问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注天达云行业资讯频道了解更多相关知识。