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

程序员文章站 2022-07-09 21:34:33

在上一篇随笔中我们认识并安装了RabbitMQ，接下来我们来看下怎么在Spring Boot 应用中整合RabbitMQ。先给出最终目录结构：搭建步骤如下：切换到amqp应用的控制台，能看到打印：在管理页面中我们能看到Connections和Channels中包含了当前连接的条目：在整个生 ......

在上一篇随笔中我们认识并安装了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();
    }
}