SpringBoot整合RabbitMQ

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

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

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

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

可以访问http://localhost:15672/查看管理页面

新建项目，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;


@Component
public 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;


@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

##rabbitmq
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.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;


@RestController
public class TestController {

    @Autowired
    private Sender sender;

    @GetMapping("hello")
    public String helloTest(){
        sender.send();
        return "success";
    }

}

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

源码下载 ：大老杨码云