如何在springboot中使用消息中间件

tangjin

作者

如何在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配置类

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();
}
}