在讲这一篇之前,你首先要知道什么是RabbitMq,做什么用,怎么安装,细节请查看
8.1RabbitMq安装及使用
8.2 RabbitMQ与Spring整合
8.3 RabbitMQ消息消费
1.maven配置
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
通过增加spring-boot-starter-amqp
来引用RabbitTemplate实现队列的调用
2.application.yml
spring:
rabbitmq:
host: localhost
port: 5672
username: test1
password: 123
virtualHost: /
配置各个参数
3.测试把消息放入队列TestRabbitmq.java
@RunWith(SpringRunner.class)
@SpringBootTest
public class TestRabbitmq {
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
public void testSend() {
rabbitTemplate.convertAndSend("test_mq", "SpringBoot发送消息");
}
}
可以看到调用rabbitTemplate.convertAndSend就可以发送消息了,非常简单。
网友评论