首页 > 编程语言 > 详细

消息队列客户端开发向导(基于 Spring 的 amqp 实现)

时间:2019-12-30 22:32:20      阅读:77      评论:0      收藏:0      [点我收藏+]

上篇文章  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

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!