springCloud-10. RabbitMQ基础使用

目标

A.完成RabbitMQ消息发送

B.完成RabbitMQ消息接收

前面已有RabbitMQ的安装教程，这里就再也不讲安装

1.修改配置

2.建立RabbitMQ消息接收类

package com.test.server.receiverTest;

import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * 描述:
 * MQ测试接收类
 *
 * @outhor hekang
 * @create 2018-08-09 上午10:38
 */
@Component
public class MqReceiver {

    //建立电脑和手机两个分组的列表消息


    /**
     * 电脑类       接收消息
     * @param message
     */
    @RabbitListener(bindings = @QueueBinding(
            exchange = @Exchange("myElectronics"),
            key = "comput",
            value = @Queue("computElectronics")
    ))
    public void processCmput(String message){
        System.out.println(message);
    }


    /**
     * 手机类       接收消息
     * @param message
     */
    @RabbitListener(bindings = @QueueBinding(
            exchange = @Exchange("myElectronics"),
            key = "phone",
            value = @Queue("phoneElectronics")
    ))
    public void processPhone(String message){
        System.out.println(message);
    }

}

 

3.建立RabbitMQ消息发送类

package com.test.server;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.stereotype.Component;
import org.springframework.test.context.junit4.SpringRunner;

/**
 * 描述:MQ测试消息发送类
 *
 * @outhor hekang
 * @create 2018-08-09 上午10:48
 */
@Component
@RunWith(SpringRunner.class)
@SpringBootTest
public class MqSenderTest{
    @Autowired
    private AmqpTemplate amqpTemplate;

    @Test
    public  void sendComput(){
        amqpTemplate.convertAndSend("myElectronics","comput","computMqSender");
    }

}

4.启动项目，刷新http://localhost:15672/   RabbitMQ后台

5.运行单测看看消息是否能正常发送和接收

控制台打印接收成功。