pom：

                 
      
       org.springframework.boot
                  
      
       spring-boot-starter-amqp
              
     

配置：

spring.rabbitmq.host=127.0.0.1spring.rabbitmq.username=guestspring.rabbitmq.password=guest

Main类，启动rabbitmq注释。

@EnableRabbitpublic class DemoApplication {}

监控类Service，必须@EnableRabbit与@RabbitListener一起使用。

才可以有其他写法，也可以指定监控配置等，官网有写法说明：

@Servicepublic class BookService {    @RabbitListener(queues = "cw.news")    public void receive(Book book){        System.out.println("收到消息："+book);    }}

配置类，解决JSON转换乱码问题

@Configurationpublic class AmqpConverter {    @Bean    public MessageConverter messageConverter(){        return new Jackson2JsonMessageConverter();    }}

往队列发送与接收消息：

@Autowired

      RabbitTemplate rabbitTemplate;

public void contextLoads() {        Map
     
       map = new HashMap<>();        map.put("msg","firstnews");        map.put("data", Arrays.asList("hello",123,true));        rabbitTemplate.convertAndSend("exchange-direct","cw.news",map);    }//发送给交换器XXX，路由key为cw.news，数据为map。    public void receive(){        Object obj = rabbitTemplate.receiveAndConvert("cw.news");        System.out.println(obj.getClass());        System.out.println(obj);    }
     

代码操作交换机（exchange）、队列（queues）、绑定（binding）等：

@Autowired    AmqpAdmin amqpAdmin;    public void createExchange(){        amqpAdmin.declareExchange(new DirectExchange("amqp-exchange"));    }

值得一提的是，官网有很完整的样例，还是多语言的。

 

关于Erlang与RabbitMQ的安装：

一、Erlang与RabbitMQ

1. RabbitMQ的官方安装目录是有空格的，需要另起炉灶，不能有带空格的目录。
2. Erlang的命令得在管理员权限的CMD下才有效。
3. RabbitMQ的版本要跟Erlang适配，官网有列表。
4. 安装RabbitMQ的时候，计算机名不能是中文，如果是，改了再重装（删除后记得把C盘下的用户资料也删掉）。
5. RabbitMQ装完后进入sbin目录，输入Rabbit MQ's Management Plugin，接着输入Net stop rabbitmq && net start rabbitmq重启RabbitMQ目录，登录http://localhost:15672，用户名：guest，密码：guest。

这时候guest都是默认的，可以通过cmd命令进行更改（或者直接在页面新增用户）。