RabbitMQ入门：在Spring Boot 应用中整合RabbitMQ

在上一篇随笔中我们认识并安装了RabbitMQ，接下来我们来看下怎么在Spring Boot 应用中整合RabbitMQ。

先给出最终目录结构：

搭建步骤如下：

新建maven工程amqp

修改pom文件，引入spring-boot-starter-amqp和spring-boot-starter-test

<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>

新建application.properties配置文件，主要就是配置下连接RabbitMQ的信息：

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启动类

/**

 * 这里没什么特殊的地方，就是普通的spring boot 配置

 *

 */

@SpringBootApplication

public class RabbitMQApp {

    public static void main(String[] args) {

        SpringApplication.run(RabbitMQApp.class, args);

    }

}

创建生产者类，通过AmqpTemplate实现消息的发送，AmqpTemplate接口定义了一套针对AMQP协议的基础操作。在Spring Boot中会根据配置来注入具体的实现。这里我们会产生一个字符串，并发送到名为hello的队列中。

@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队列的监听，并用@RabbitHandler注解来指定对消息处理的方法。我们这里实现了对hello队列的消费。

/**

 * 通过@RabbitListener对hello队列进行监听

 *

 */

@Component

@RabbitListener(queues="hello")

public class Receiver {

    /**

     * 通过@RabbitHandler声明的方法，对hello队列中的消息进行处理

     */

    @RabbitHandler

    public void receiver(String str) {

        System.out.println("Receiver says:[" + str + "]");

    }

}

编写RabbitMQ的配置类，配置类可以配置队列、交换器、路由等高级信息。我们这里为了简单，只配置队列，其他的采用默认配置。

/**

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

    }

}

运行启动类，启动后控制台会有下面的提示内容：
执行测试类，在测试类的控制台会打印我们打的log内容

　　 RabbitMQ入门：在Spring Boot 应用中整合RabbitMQ

　　切换到amqp应用的控制台，能看到打印：

　　 RabbitMQ入门：在Spring Boot 应用中整合RabbitMQ

　　在管理页面中我们能看到Connections和Channels中包含了当前连接的条目： RabbitMQ入门：在Spring Boot 应用中整合RabbitMQ

在整个生产和消费的过程中，生产和消费是一个异步操作，这是分布式系统中要使用消息代理的重要原因。

秒客网

RabbitMQ入门：在Spring Boot 应用中整合RabbitMQ

相关文章