直接进入正题，有关mq的知识参考上一篇，其实这个和activemq在性能上差不多，只不过他是依赖amqp协议,同时rabbitmq是用erlang语言写的
1，安装RabbitMq
#这个带有管理界面docker pull rabbitmq:3-management
还有一个是直接docker pull rabbitmq，但是会映射出来4个接口5671 25672 4369 5672，且没有管理界面，不推荐使用，我被坑过!!
#启动容器docker run -itd -p 5672:5672 -p 15672:15672 cb479f313c93
- **rabbitmq界面 **
**默认密码：guest/guest,**进入的页面为：
可以看到队列，通道，交换机之类的东西
2.代码部分
-
- 添加依赖配置application.properties
org.springframework.boot spring-boot-starter-amqp
application.properties
springboot对其有默认配置，这个可以在联想的代码中直接看到，比如username和paaword之类的，我这里如果是默认的localhost的话也不需要配置，由于我这里不是默认的，必须要自定义配置
- 2.新建queue和监听
package com.lijunhao.rabbitmq;import org.springframework.amqp.core.Queue;import org.springframework.amqp.rabbit.annotation.RabbitListener;import org.springframework.beans.factory.annotation.Configurable;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.stereotype.Component;/** * 新建队列 * @author lijunhao * */@Componentpublic class MyQueue { /**只是声明一个叫my-queue的队列 import org.springframework.amqp.core.Queue，包不要引错了 */ @Bean public Queue rabbitQueue(){ return new Queue("my-queue"); } /** * 声明一个监听者，监听my-queue队列的消息,可以多选，队列名用逗号隔开 * @param message */ @RabbitListener(queues = "my-queue") public void receiveMessage(String message){ System.out.println("接收到来自RabbitMq的消息："+message); } } - 3，测试代码
/** * 测试发送RabbitMq消息 * lijunhao * @return */ @RequestMapping(value="/rabbit-test") public String getTestRabbitMQ(){ rabbitTemplate.convertAndSend("my-queue", "hello-rabbitMQ.from 2016-09-02"); return "index"; } - 4，启动并测试
得到的结果为
rabbit界面为：
已经新建了一个名为my-queue队列，同时也监听到了消息。