spring boot 集成rabbitmq（9步搞定）

前言：最近公司有使用到spring boot rabbitmq，使用了总归是要记录一下，主要是加强巩固。

首先我们创建一个spring boot项目
第一步：pom.xml引入amqp
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>第二步：在application.properties修改默认的配置

spring.rabbitmq.host=#.#.#.#
spring.rabbitmq.port=5672
spring.rabbitmq.username=xubing
spring.rabbitmq.password=123456

第三步：springboot程序入口package com.xubing;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class SpringbootrabbitmqApplication {

public static void main(String[] args) {
SpringApplication.run(SpringbootrabbitmqApplication.class, args);
}
}

第四步：新建一个配置文件，用于创建声明队列，并将队列绑定到交换器(未来简单起见我们使用direct交换器，省略了绑定队列到交换器的操作)
package com.xubing.configuration;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
* Created by xubing on 2018/3/10.
*/
@Configuration
public class RabbitmqConfiguration {

/**
* 实例化队列
* @return
*/
@Bean
public Queue Queue(){
return new Queue("helloworld");
}

}

第五步：创建一个消费者
package com.xubing;

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

/**
* Created by xubing on 2018/3/10.
*/
@Component
public class Producer {

@Autowired
public AmqpTemplate amqpTemplate;

public void sendMessage(String queueName,String message ){
amqpTemplate.convertAndSend(queueName,message);
}

}第六步：编写单元测试：
package com.xubing;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class ProducerTests {

@Autowired
Producer producer;

@Test
public void testSend(){
String queueName="helloworld";
String message="你好呀";
producer.sendMessage(queueName,message);
}

}第七步：执行之前从rabbitmq mananger查看队列信息



第8步：开始执行单元测试
单元测试结果



第9步：执行成功ok,我们在去rabbitmq manager查看一下



最后附上github源码地址：点击打开链接

<
8629
script>
$(".MathJax").remove();