RabbitMQ入門：在Spring Boot 應用中整合RabbitMQ

時間 2019-11-08

標籤 rabbitmq 入門 spring boot 應用整合欄目 RabbitMQ 简体版

原文原文鏈接

在上一篇隨筆中咱們認識並安裝了RabbitMQ，接下來咱們來看下怎麼在Spring Boot 應用中整合RabbitMQ。html

先給出最終目錄結構：java

搭建步驟以下：spring

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