1. 新建一個SpringBoot項目
2. pom.xml中引入如下依賴內(nèi)容

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>

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

        <!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-databind -->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.9.7</version>
        </dependency>


        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

3. 在application.properties中配置關(guān)于RabbitMQ的連接和用戶信息，用戶可以回到上面的安裝內(nèi)容，在管理頁面中創(chuàng)建用戶。

spring.application.name=rabbitmq-hello

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=spring
spring.rabbitmq.password=123456

4. 創(chuàng)建消息生產(chǎn)者Sender。

通過注入AmqpTemplate接口的實例來實現(xiàn)消息的發(fā)送，AmqpTemplate接口定義了一套針對AMQP協(xié)議的基礎(chǔ)操作。在Spring Boot中會根據(jù)配置來注入其具體實現(xiàn)。在該生產(chǎn)者，我們會產(chǎn)生一個字符串，并發(fā)送到名為hello的隊列中。

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;

@Component
public class Sender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void send() {
        for (int i = 0; i <20 ; i++) {
            this.rabbitTemplate.convertAndSend ("hello", new Persion("zhangsn"+i,new Date()));
        }
    }
}

5. 創(chuàng)建消息消費者Receiver。

通過@RabbitListener注解定義該類對hello隊列的監(jiān)聽，并用@RabbitHandler注解來指定對消息的處理方法。所以，該消費者實現(xiàn)了對hello隊列的消費，消費操作為輸出消息的字符串內(nèi)容。

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class Receiver2 {

    @RabbitHandler
    @RabbitListener(queues = "hello",containerFactory="rabbitListenerContainerFactory")
    public void process(Persion msg){
        System.out.println("Receiver2: "+msg.toString());
    }
}

6. 創(chuàng)建RabbitMQ的配置類RabbitConfig

用來配置隊列、交換器、路由等高級信息。這里我們以入門為主，先以最小化的配置來定義，以完成一個基本的生產(chǎn)和消費過程。

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitAdmin;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {

    @Bean
    public Queue helloQueue() {
        return new Queue("hello");
    }

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate template = new RabbitTemplate(connectionFactory);
        template.setMessageConverter(new Jackson2JsonMessageConverter());
        return template;
    }

    @Bean
    public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        factory.setMessageConverter(new Jackson2JsonMessageConverter());
        return factory;
    }

    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){
        RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
        return rabbitAdmin;
    }
}

7. 添加測試控制器

@RestController
public class TestController {
    @Autowired
    private  Sender sender;

    @RequestMapping("/add")
    public String addGuess(){
        sender.send();
        return "ok";
    }
}

8. 創(chuàng)建應(yīng)用主類

@SpringBootApplication
@EnableRabbit
public class RabbitmqApplication {

    public static void main(String[] args) {
        SpringApplication.run(RabbitmqApplication.class, args);
    }
}

9. 運行項目，測試消息隊列

1.png

注意

定義多個消費者關(guān)注同一個隊列，消息會被隨即進行分配，一個消息被消費后，不會被另一個消費者再次消費

源碼托管地址
git@git.dev.tencent.com:douguohai/studyproject.git

中的rabbitmq1