SpringBoot 配置rabbitmq

一、添加pom文件依赖

 <!--rabbit mq-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

二、在.yml配置文件中对mq进行配置，如下所示

mq:
  rabbit:
    host: 192.168.10.70(换成自己的ip)
    port: 5672
    virtualHost: /
    username: 用户名
    password: 密码

三、相对用的配置类，具体的应用配置信息

package com.zthl.mall.mini.mq.config;

import com.rabbitmq.client.ConnectionFactory;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;

/**
 * Created by qiuzhijie.
 * Date: 2019-01-07
 * 备注: mq config information
 */
@Configuration
public class RabbitMQConfig {

    @Value("${mq.rabbit.host}")
    private String HOST;
    @Value("${mq.rabbit.port}")
    private Integer PORT;
    @Value("${mq.rabbit.virtualHost}")
    private String VIRTUALHOST;
    @Value("${mq.rabbit.username}")
    private String USERNAME;
    @Value("${mq.rabbit.password}")
    private String PASSWORD;

    @Bean
    public CachingConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(this.HOST,this.PORT);

        connectionFactory.setUsername(this.USERNAME);
        connectionFactory.setPassword(this.PASSWORD);
        connectionFactory.setVirtualHost(this.VIRTUALHOST);

        return connectionFactory;
    }
    @Bean
    public Queue queue() {
        return new Queue("mall.paied.order",true);
    }

}

四、springboot默认给实现了AmqpTemplate，所以这里直接注入使用来发消息，这里简单使用测试一下，根据场景使用不同的模式，这里只做与一下最简单的demo

package com.zthl.mall.mini.mq.controller;


import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;


/**
 * Created by qiuzhijie.
 * Date: 2019-01-07
 * 备注:
 */
@Component
public class MqSender {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send()throws Exception{

        rabbitTemplate.convertAndSend("mall.paied.order","hello，rabbit-");
        System.out.println("Sender:"+"rabbit-");
    }
}

五、测试发送消息

package com.zthl.mall.mini.mq.test;

import com.zthl.mall.mini.CloudHallMallMiniApplication;
import com.zthl.mall.mini.mq.controller.MqSender;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * Created by qiuzhijie.
 * Date: 2019-01-07
 * 备注:
 */
@RestController
@RequestMapping(value = "/api/mq")
public class TestRabbitMQ {

    @Autowired
    private MqSender mqSender;

    @RequestMapping("/send")
    public void testRabbit() throws Exception {
        mqSender.send();
    }


}

六、是否发送成功可以在网页查看Messages，成功的情况下，Ready与Total对应的数量变化