sudo docker run -d -p 5672:5672 -p 15672:15672 rabbitmq:3-management

        <!--添加 rabbitmq的依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>

########### rabbitmq 的配置 ******
spring: rabbitmq:host: 192.168.50.202port: 5672
#    username: admin
#    password: secret

package com.wenbronk.enterprise.rabbitmq.send;import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;/*** 消息发送者* 实现接口, 为了开机就自动发送* Created by wenbronk on 2017/6/13.*/
@Component
public class RabbitMQSender implements CommandLineRunner{@Autowiredprivate RabbitTemplate rabbitTemplate;@Overridepublic void run(String... args) throws Exception {rabbitTemplate.convertAndSend("my-queue", "来自rabiitmq的问候");}
}

package com.wenbronk.enterprise.rabbitmq.receive;import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;/*** 消息接收者* Created by wenbronk on 2017/6/13.*/
@Component
public class RabbitMQReceive {/*** 使用rabbitlistener接收消息* @param message*/@RabbitListener(queues = "my-queue")public void receiveMessage(String message) {System.out.println("receive: " + message);}}

package com.wenbronk.enterprise.rabbitmq.config;import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 队列模式的bean* Created by wenbronk on 2017/6/13.*/
@Configuration
public class QueueConfig {/*** 定义使用到的队列* @return*/@Beanpublic Queue myQueue() {return new Queue("my-queue");}
}

  @Beanpublic RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {RabbitTemplate template = new RabbitTemplate(connectionFactory);template.setMessageConverter(new Jackson2JsonMessageConverter());return template;}@Beanpublic SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();factory.setConnectionFactory(connectionFactory);factory.setMessageConverter(new Jackson2JsonMessageConverter());return factory;}

@RabbitListener(queues = "merchant", containerFactory="rabbitListenerContainerFactory")
public void process(@Payload UpdateMerchant request) { UpdateMerchantResponse response = new UpdateMerchantResponse();logger.info(request.getMerchantId() + "->" + response.getReturnCode());}