上篇文章 RabbitMQ 入门 通过 4个基本实例展示了 RabbitMQ 的基本用法。下面,继续介绍相关的 API
1.声明交互器
几个常见交换器都是实现的 Exchange,该接口有几个重要属性
//交换器名称 String name; //交换器类型 String type; //是否可持久化(将交换器存盘) boolean durable; //自动删除(绑定后再解绑会自动删除) boolean autoDelete; //开启延迟队列(需要 broker 插件) boolean delayed; //内置交换器,只用于交换器到交换器的绑定 boolean internal;
2.声明队列
队列的实现类为 Queue,相关属性如下
//队列名称 String name; //持久化 boolean durable; //排它队列 boolean exclusive; //自动删除(消费者全部解绑后) boolean autoDelete;
注:排它性队列
1.只对首次声明它的连接(Connection)可见
2.会在其连接断开的时候自动删除。
3.队列(交换器)绑定
交换器之间绑定
BindingBuilder.bind(topicExchange1).to(topicExchange2).with("routingKey");
队列与交换器绑定
BindingBuilder.bind(topicQueue1).to(topicExchange).with("*.important.*")
4.发送消息
convertAndSend(String exchange, String routingKey, final Object object)
5.消费消息
推模式
233
消息队列客户端开发向导(基于 Spring 的 amqp 实现)
原文:https://www.cnblogs.com/lemos/p/12121752.html