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.運行單測看看消息是否能正常發送和接收

控制檯打印接收成功。