SpringBoot整合RabbitMQ-白红宇

RabbitMQ是开源消息队列系统，用erlang语言开发。如果不了解可以查看官网

这篇文章介绍一个springboot简单整合RabbitMQ。

1.安装rabbitmq，自行百度即可，方法很多。

2.启动rabbitmq，成功如下图：

image

可以访问查看管理页面

image

新建项目，pom文件加入依赖，完整pom如下：


     
         
      
       4.0.0
          
      
       com.dalaoyang
          
      
       springboot_rabbitmq
          
      
       0.0.1-SNAPSHOT
          
      
       jar
          
      
       springboot_rabbitmq
          
      
       springboot_rabbitmq
          
              
       
        org.springframework.boot
               
       
        spring-boot-starter-parent
               
       
        1.5.9.RELEASE
               
        
           
          
              
       
        UTF-8
               
       
        UTF-8
               
       
        1.8
           
          
              
                   
        
         org.springframework.boot
                    
        
         spring-boot-starter-web
                
               
                   
        
         org.springframework.boot
                    
        
         spring-boot-devtools
                    
        
         runtime
                
               
                   
        
         org.springframework.boot
                    
        
         spring-boot-starter-test
                    
        
         test
                
               
                   
        
         org.springframework.boot
                    
        
         spring-boot-starter-amqp
                
           
          
              
                   
                        
         
          org.springframework.boot
                         
         
          spring-boot-maven-plugin

新建一个消息发送者Sender，使用AmqpTemplate将消息发送到消息队列message中去。代码如下：

package com.dalaoyang.sender;import org.apache.log4j.Logger;import org.springframework.amqp.core.AmqpTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Component;import java.util.Date;/** * @author dalaoyang * @Description * @project springboot_learn * @package com.dalaoyang.send * @email yangyang@dalaoyang.cn * @date 2018/4/25 */@Componentpublic class Sender {    Logger logger = Logger.getLogger(Sender.class);    @Autowired    private AmqpTemplate amqpTemplate;    public String send(){        String context = "简单消息发送";        logger.info("简单消息发送时间："+new Date());        amqpTemplate.convertAndSend("message", context);        return "发送成功";    }}

创建消息接收者Receiver，使用注解@RabbitListener(queues = "message")来监听message的消息队列@RabbitHandler来实现具体消费。

package com.dalaoyang.receiver;import org.apache.log4j.Logger;import org.springframework.amqp.rabbit.annotation.RabbitHandler;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.stereotype.Component;import java.util.Date;/** * @author dalaoyang * @Description * @project springboot_learn * @package com.dalaoyang.receiver * @email yangyang@dalaoyang.cn * @date 2018/4/25 */@Component@RabbitListener(queues = "message")public class Receiver {    Logger logger = Logger.getLogger(Receiver.class);    @RabbitHandler    public void process(String Str) {        logger.info("接收消息："+Str);        logger.info("接收消息时间："+new Date());    }}

然后看一下配置信息，因为是简单整合，所以只配置了端口和rabbitmq的信息，如下：

##端口号server.port=8888##rabbitmqspring.rabbitmq.host=localhostspring.rabbitmq.port=5672spring.rabbitmq.username=guestspring.rabbitmq.password=guest

创建一个controller，这里仅用来测试，代码如下：

package com.dalaoyang.controller;import com.dalaoyang.sender.Sender;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;/** * @author dalaoyang * @Description * @project springboot_learn * @package com.dalaoyang.controller * @email yangyang@dalaoyang.cn * @date 2018/4/25 */@RestControllerpublic class TestController {    @Autowired    private Sender sender;    @GetMapping("hello")    public String helloTest(){        sender.send();        return "success";    }}

启动项目，访问然后观看控制台可以看到消息已经发送成功。

image

源码下载：

个人网站：