上篇文章 RabbitMQ 入门 https://www.cnblogs.com/lemos/p/12093882.html 通过 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 实现)
来源: http://www.bubuko.com/infodetail-3358310.html