RabbitMQ代码实例
用docker拉取镜像
# 加速镜像 来拉取 rabbitmq 的镜像
docker pull registry.docker-cn.com/library/rabbitmq:3-management
# 启动 rabbitmq
docker run -d -p 5672:5672 -p 15672:15672 --name myrabbitmq (我的mq镜像ID)
ip地址 + 端口号(15672) 进入 RabbitMQ Management
然后傻瓜式操作的添加Exchange 和 Queue 以及 biand 二者关系
项目测试开始前准备
按照我之前的 MQ 中的图进行傻瓜式操作的添加Exchange 和 Queue 以及 biand 二者关系，
当然是要在ip地址 + 端口号(15672) 进入 RabbitMQ Management里面
不懂得话自己摸索摸索哈__(原谅我的懒)
创建 mqtest项目
application.properties
spring.rabbitmq.host=你的虚拟机ip地址
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
#spring.rabbitmq.virtual-host=/ 默认也是/ 所以没有必要加上
# 还可以配置好多，可以以后用的时候试试
# eg： spring.rabbitmq.cache.channel.checkout-timeout=xxxxxxx
# spring.rabbitmq............
启动类：MptestApplication
/**
* 自动配置
* 1、RabbitAutoConfiguration
* 2、有自动配置了连接了工厂CachingConnectionFactory；
* 3、RabbitProperties 封装了 RabbitMQ 的配置
* 4、RabbitTemplate : 给RabbitMQ发送和接收消息
* 5、AmqpAdmin : RabbitMQ系统管理功能组件
* AmqpAdmin : 创建和删除 Queue, Exchange, Binding
* 6、@EnableRabbit + @RabbitListener 监听消息队列的内容
*
*/
@EnableRabbit //开启基于注解的 RabbitMQ 模式
@SpringBootApplication
public class MptestApplication {
public static void main(String[] args) {
SpringApplication.run(MptestApplication.class, args);
}
}
实体类：Book
public class Book {
private String bookName;
private Long price;
public Book() {
}
public Book(String bookName, Long price) {
this.bookName = bookName;
this.price = price;
}
@Override
public String toString() {
return "Book{" +
"bookName='" + bookName + '\'' +
", price=" + price +
'}';
}
public String getBookName() {
return bookName;
}
public void setBookName(String bookName) {
this.bookName = bookName;
}
public Long getPrice() {
return price;
}
public void setPrice(Long price) {
this.price = price;
}
}
然后就可以直接测试了
测试类：MptestApplicationTests
@RunWith(SpringRunner.class)
@SpringBootTest
public class MptestApplicationTests {
@Autowired
RabbitTemplate rabbitTemplate;
@Autowired
AmqpAdmin amqpAdmin;
//在RabbitMQ中加入Exchange
@Test
public void createExchange() {
amqpAdmin.declareExchange(new DirectExchange("amqpadmin.exchange"));
System.out.println("创建完成");
}
//在RabbitMQ中加入Queue
@Test
public void craeteQueue() {
amqpAdmin.declareQueue(new Queue("amqpadmin.queue", true));
System.out.println("创建完成");
}
//RabbitMQ中进行Exchange与Queue的bind，以及确定routKey
@Test
public void createBind() {
amqpAdmin.declareBinding(new Binding("amqpadmin.queue", Binding.DestinationType.QUEUE , "amqpadmin.exchange", "amqp.haha", null));//这里还可以加一个map集合的参数，不用直接为null
}
/**
* 单播模式下(点对点)
*/
@Test
public void contextLoads() {
//Message需要自己构造一个；定义消息体和消息头
//rabbitTemplate.send(exchange, routeKey, message);;
//object默认当成消息体，只需要传入要发送的对象，自动序列化发送给rabbitmq
//rabbitTemplate.convertAndSend(exchange, routeKey, object);
Map<String, Object>map = new HashMap<>();
map.put("msg", "this is a first message");
map.put("data", Arrays.asList("helloworld", 123, true));
//对象被默认序列化以后发送出去
rabbitTemplate.convertAndSend("exchange.direct", "atguigu.news",map );
}
//接收数据，如何将数据自动转成json 发送出去
@Test
public void receive() {
Object o = rabbitTemplate.receiveAndConvert("atguigu.news");
System.out.println(o.getClass());
System.out.println(o);
}
//对book的测试
@Test
public void bookTest() {
rabbitTemplate.convertAndSend("exchange.direct", "atguigu.news", new Book("西游记",123L));
}
/**
* fanout广播
*/
@Test
public void sendMsg() {
rabbitTemplate.convertAndSend("exchange.fanout", "", new Book("三国演义", 124l));
}
/**
* Topic广播
*/
@Test
public void sendMsgByTopic() {
rabbitTemplate.convertAndSend("exchange.topic","hello.news", new Book("红楼梦", 125L) );
}
}
要对消息队列实行监听的话，可以开启@EnableRabbit //开启基于注解的 RabbitMQ 模式
然后建一个service类来进行实现业务功能
service类：BookService
@Service
public class BookService {
//用@RabbitListener 这是对queue中的某一项进行订阅功能
@RabbitListener(queues = "atguigu.news")
public void receive(Book book) {
System.out.println("收到的消息 : "+ book);
}
//也可以拿Message消息 body head等
@RabbitListener(queues = "atguigu")
public void receive02(Message message) {
System.out.println(message.getBody());
System.out.println(message.getMessageProperties());
}
}
其实就是发布/订阅
在Test中进行发布，然后监听的类监听到了此消息队列中有发布的消息，然后立刻给监听到进行取出然后处理。
实现发布/订阅有利于代码的解耦，和分离
config类：MyAMQPConfig
@Configuration
public class MyAMQPConfig {
//此配置是用来将发布/订阅的数据转换为 json 后再进行传输
@Bean
public MessageConverter messageConverter() {
return new Jackson2JsonMessageConverter();
}
}
这个只是用来改变了MessageConverter的方式 源码中默认是javaJDK，所以在RabbitMQ Management 中显示不是json，而是java序列化后得
学习 尚硅谷的springboot视频MQ时 的学习笔记
OK 目前MQ就到这里了。要是不懂的话，可以花10分钟先去看看我之前的MQ基础概念
