Spring Boot 集成RabbitMQ入门Demo

Dear 丶 2022-06-08 11:36 256阅读 0赞

## 一、创建工程 ##

###   1、 在http://start.spring.io/中创建RabbitMQHello工程： ###

A、MAVEN工程

B、2.0.0.BUILD-SNAPSHOT

C 、Group：com.example

D、Artifact：RabbitMQHello

E、Packaging：jar

F、Java Version：1.8

G、勾选WEB、AMQP（Advanced Message Queuing Protocol via spring-rabbit）。

###    2、下载工程、解压，然后导入eclipse中 ###

###    3、修改pom.xml以便于热部署 ###

A、在dependencies中增加spring-boot-devtools

1.  <dependency>  
2.        <groupId>org.springframework.boot</groupId>  
3.        <artifactId>spring-boot-devtools</artifactId>  
4.        <optional>true</optional>  
5.  </dependency>

B、在build的spring-boot-maven-plugin中增加依赖包

1.  <build>  
2.      <plugins>  
3.          <plugin>  
4.              <groupId>org.springframework.boot</groupId>  
5.              <artifactId>spring-boot-maven-plugin</artifactId>  
6.              <dependencies>  
7.                    
8.                  <dependency>  
9.                      <groupId>org.springframework</groupId>  
10.                     <artifactId>springloaded</artifactId>  
11.                     <version>1.2.6.RELEASE</version>  
12.                 </dependency>  
13.             </dependencies>  
14.         </plugin>  
15.     </plugins>  
16. </build>

###  4、增加日志配置文件 ###

在src/main/resources下增加文件logback.xml,内容如下

<?xml version="1.0" encoding="UTF-8"?>    
<configuration>        
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">        
        <encoder>        
            <pattern>%d %p-%file- %m%n</pattern>  
            <charset>GBK</charset>     
        </encoder>        
    </appender>  
  
      
      
      
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">  
    <encoder>  
        <charset>UTF-8</charset>    
        <pattern>%d\{HH:mm:ss\}\[%-5level\]\[%file:%line\] %msg%n</pattern>  
    </encoder>  
      
    </appender>        
    <root level="error"><appender-ref ref="STDOUT" /></root>        
    <logger name="com.boot" level="DEBUG"/>       
</configuration>

配置文件把日志输出到控制台和文件。文件的字符集为UTF-8，控制台的为GBK(我用win10专业版)。

### 5、修改系统配置文件application.properties，编制RabbitMQ的链接参数 ###

1.  spring.application.name=rabbitmq\-hello  
2.  spring.rabbitmq.host=localhost  
3.  spring.rabbitmq.port=5672  
4.  spring.rabbitmq.username=test  
5.  spring.rabbitmq.password=123456

RabbitMQ,我使用win7 安装，现在 很流行 docker托管参看 [在docker的centos7上安裝rabbitmq3.6.5][docker_centos7_rabbitmq3.6.5] [rabbitmq的用户管理][rabbitmq]

## 二、编制RabbitMQ配置、发送、接受的代码 ##

### 1、编写配置文件类 ###

在com.example包中增加类，名称为HelloRabbitConfig，并修改代码为

package com.example;

1.  import org.springframework.amqp.core.Queue;  
2.  import org.springframework.context.annotation.Bean;  
3.  import org.springframework.context.annotation.Configuration;  
4.    
5.  @Configuration  
6.  public class HelloRabbitConfig \{  
7.    
8.      @Bean  
9.      public Queue helloQueue() \{  
10.         return new Queue("hello");  
11.     \}  
12. \}

### 2、编写发送消息类 ###

在com.example包中增加类，名称为HelloSender，并修改代码为

**\[java\]** [ view plain][view plain] [ copy][view plain]

1.  package com.example;  
2.    
3.  import java.util.Date;  
4.    
5.  import org.slf4j.Logger;  
6.  import org.slf4j.LoggerFactory;  
7.  import org.springframework.amqp.core.AmqpTemplate;  
8.  import org.springframework.beans.factory.annotation.Autowired;  
9.  import org.springframework.stereotype.Component;  
10.   
11. @Component  
12. public class HelloSender \{  
13.   
14.     protected static Logger logger=LoggerFactory.getLogger(HelloSender.class);   
15.       
16.     @Autowired  
17.     private AmqpTemplate rabbitTemplate;  
18.   
19.     public String send(String name) \{  
20.         String context = "hello "\+name+" --" + new Date();  
21.         logger.debug("HelloSender: " + context);  
22.         this.rabbitTemplate.convertAndSend("hello", context);  
23.         return context;  
24.     \}  
25. \}

### 3、编写接受消息类 ###

在com.example包中增加类，名称为HelloReceiver，并修改代码为

**\[html\]** [ view plain][view plain] [ copy][view plain]

1.  package com.example;  
2.    
3.  import org.slf4j.Logger;  
4.  import org.slf4j.LoggerFactory;  
5.  import org.springframework.amqp.rabbit.annotation.RabbitHandler;  
6.  import org.springframework.amqp.rabbit.annotation.RabbitListener;  
7.  import org.springframework.stereotype.Component;  
8.    
9.  @Component  
10. @RabbitListener(queues = "hello")  
11. public class HelloReceiver \{  
12.     protected static Logger logger = LoggerFactory.getLogger(HelloReceiver.class);  
13.   
14.     @RabbitHandler  
15.     public void process(String hello) \{  
16.         logger.debug("HelloReceiver : " + hello);  
17.     \}  
18. \}

### 4、编写RestController，调用发送消息 ###

在com.example包中增加类，名称为HelloController，并修改代码为

1.  package com.example;  
2.    
3.  import org.slf4j.Logger;  
4.  import org.slf4j.LoggerFactory;  
5.  import org.springframework.beans.factory.annotation.Autowired;  
6.  import org.springframework.web.bind.annotation.PathVariable;  
7.  import org.springframework.web.bind.annotation.RequestMapping;  
8.  import org.springframework.web.bind.annotation.RestController;  
9.    
10. @RestController   
11. public class HelloController \{  
12.     protected static Logger logger=LoggerFactory.getLogger(HelloController.class);   
13.       
14.     @Autowired  
15.         private HelloSender helloSender;  
16.       
17.     @RequestMapping("/send/\{name\}")  
18.     public String helloworld(@PathVariable String name) \{  
19.         return helloSender.send(name);  
20.     \}  
21. \}

### 5、运行测试 ###

A、启动docker中容器rabbitmq5672。docker start rabbitmq5672   (如果已启动，则忽略)

B、启动工程。在工程所在的文件夹打开命令行，且在命令行中执行 mvn spring-boot:run

C、在浏览器中输入 http://localhost：8080/send/上帝

![20170403202150600][]

浏览器中显示

![20170403202253148][]

控制台中显示，成功发送、接收消息

## 三、小结 ##

### 1、rabbitmq连接 ###

1.1 springboot,在启动时，根据系统配置文件的参数建立一个rabbitmq连接。参看控制台日志：

(MBeanExporter.java:431)- Registering beans for JMX exposure on startup

(MBeanExporter.java:916)- Bean with name 'rabbitConnectionFactory' has been autodetected for JMX exposure

(MBeanExporter.java:678)- Located managed bean 'rabbitConnectionFactory': registering with JMX server as MBean \[org.springframework.amqp.rabbit.connection:name=rabbitConnectionFactory,type=CachingConnectionFactory\]

(DefaultLifecycleProcessor.java:343)- Starting beans in phase -2147482648

(DefaultLifecycleProcessor.java:343)- Starting beans in phase 2147483647

(AbstractConnectionFactory.java:347)- Created new connection: SimpleConnection@7075a8f1 \[delegate=amqp://test@127.0.0.1:5672/, localPort= 62881\]

1.2、在springboot启动之后，查看rabbitmq(http://localhost:15672/)的connections，也可以查看到。当然，你也可以停止springboot去看链接(停止之后，当然就没有链接了).  
1.3、把logbak.xml的root的等级修改为debug，你会发现监听在不断的链接reabitmq；它就是一个心跳。通过这个心跳，rabbitmq也知道存在哪些监听器在监听那个队列。

### 2、配置文件 ###

在配置文件中，仅仅配置了一个名为hello的队列。以后发送、接收都与这个队列相关。

### 3、发送消息 ###

3.1、发送消息使用模板机制，用springboot自动注入的rabbitTemplate，它已经封装好链接、管道、转换等。

3.2、消息转换和发送

void convertAndSend(String routingKey, Object message) throws AmqpException;

它的注释是：Convert a Java object to an Amqp \{@link Message\} and send it to a default exchange with a specific routing key.

转换一个Java对象为Amqp消息，然后再用缺省的交换机指定路由键发送消息。

4、接受消息

4.1、监听消息

在类上声明@RabbitListener(queues = "hello")，表示监听hello队列

4.2、消息处理句柄

在接收处理消息的方法上声明@RabbitHandler

Annotation that marks a method to be the target of a Rabbit message  listener within a class that is annotated with \{@link RabbitListener\}.

5、印象

整个工程比较简单，没有什么特殊的配置，仅仅三个类文件即可实现消息的发送和接受

[docker_centos7_rabbitmq3.6.5]: http://blog.csdn.net/lxhjh/article/details/68952392
[rabbitmq]: http://blog.csdn.net/lxhjh/article/details/68954878
[view plain]: http://blog.csdn.net/lxhjh/article/details/68969552#
[20170403202150600]: /images/20220608/10b7b0bb2d664aebabaacbea97dc3694.png
[20170403202253148]: /images/20220608/c719af87d3964ffe829d06883556e311.png