在上一篇随笔中咱们认识并安装了RabbitMQ,接下来咱们来看下怎么在Spring Boot 应用中整合RabbitMQ。html
先给出最终目录结构:java
搭建步骤以下:spring
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.sam</groupId> <artifactId>amqp</artifactId> <version>0.0.1-SNAPSHOT</version> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.1.RELEASE</version> </parent> <properties> <javaVersion>1.8</javaVersion> </properties> <dependencies> <!-- 引入amqp依赖,它能很好的支持RabbitMQ --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <!-- 引入test依赖,此次须要用到JUnit --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> </dependency> </dependencies> </project>
spring.application.name=rabbitmq-hello
#config rabbitmq info
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
/** * 这里没什么特殊的地方,就是普通的spring boot 配置 * */ @SpringBootApplication public class RabbitMQApp { public static void main(String[] args) { SpringApplication.run(RabbitMQApp.class, args); } }
@Component public class Sender { @Autowired AmqpTemplate rabbitmqTemplate; /** * 发送消息 */ public void send() { String content = "Sender says:" + "'hello, I'm sender'"; System.out.println(content); rabbitmqTemplate.convertAndSend("hello", content); } }
/** * 经过@RabbitListener对hello队列进行监听 * */ @Component @RabbitListener(queues="hello") public class Receiver { /** * 经过@RabbitHandler声明的方法,对hello队列中的消息进行处理 */ @RabbitHandler public void receiver(String str) { System.out.println("Receiver says:[" + str + "]"); } }
/** * rabbitmq配置类, * 为了简单,咱们这里只配置了Queue * 至于exchanges、brokers等用的默认配置 * */ @Configuration public class RabbitConfig { @Bean public Queue helloQueue() { return new Queue("hello"); } }
@RunWith(SpringJUnit4ClassRunner.class) @SpringBootTest(classes=RabbitMQApp.class) public class HelloTest { @Autowired private Sender sender; /** * 调用生产者进行消息发送 */ @Test public void hello() throws Exception{ sender.send(); } }
切换到amqp应用的控制台,能看到打印:apache
在管理页面中咱们能看到Connections和Channels中包含了当前链接的条目:并发
在整个生产和消费的过程当中,生产和消费是一个异步操做,这是分布式系统中要使用消息代理的重要缘由。app