消息队列高可用 ，`事务 签收 zookeeper+replicated leveldb store`的主从集群 异步发送 同步发送： 1. 明确指定同步发送 2. 未使用事务的前提下，发送持久化消息（会使用同步发送，且会阻塞producer直到broker返回一个确认，表示消息已持久化。会阻塞客户 ...
分类：
其他好文 时间：
2019-08-25 17:51:06
阅读次数：
108
1、RabbitMQ的主要特点 （1）可靠性：RabbitMQ可通过队列持久化，交换机持久化，消息持久化及ACK回应等机制保证可靠性 （2）支持多种语言与协议：RabbitMQ几乎支持所有的编程语言，还支持AMQP，STOMP，MQTT等多种协议 （3）管理界面：RabbitMQ有一个可视化的管理界 ...
分类：
其他好文 时间：
2019-08-03 10:41:39
阅读次数：
80
一、简单的RabbitMQ示例 生产者 消费者 二、RabbitMQ命令行工具 三、rabbitmq持久化 队列持久化 消息持久化 四、消息调度 在消费者中定义 五、广播模式 fanout：所有bind到此exchange的queue都可以接受消息 订阅/发布 生成者 消费者 direct：通过ro ...
分类：
编程语言 时间：
2019-07-07 12:57:25
阅读次数：
119
持久化消息和非持久化消息的发送策略 消息同步发送和异步发送 ActiveMQ支持同步、异步两种发送模式将消息发送到broker上。同步发送过程中，发送者发送一条消息会阻塞直到broker反馈一个确认消息，表示消息已经被broker处理。这个机制提供了消息的安全性保障，但是由于是阻塞的操作，会影响到客 ...
分类：
其他好文 时间：
2019-04-08 01:04:59
阅读次数：
186
深入浅出 JMS(四) - ActiveMQ 消息存储 一、消息的存储方式 ActiveMQ 支持 JMS 规范中的持久化消息与非持久化消息 持久化消息通常用于不管是否消费者在线，它们都会保证消息会被消费者消费。当消息被确认消费后，会从存储中删除 非持久化消息通常用于发送通知以及实时数据，通常要求性 ...
分类：
其他好文 时间：
2019-04-05 19:45:27
阅读次数：
136
消息存储持久化机制 有基于文件的，数据库的，内存的。默认的是基于文件的，在安装目录/data/kahadb。在conf/activemq.xml文件中。 <persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb"/> </pers ...
分类：
其他好文 时间：
2019-04-01 18:54:02
阅读次数：
217
消息应答（ Message acknowledgment） 1、 Message acknowledgment（消息应答） 执行任务可能需要几秒钟。你可能想知道如果其中一个消费者开始一项长期任务并且只是部分完 成而死亡会发生什么。使用我们当前的代码，一旦RabbitMQ向消费者发送消息，它立即将其标 ...
分类：
其他好文 时间：
2019-03-14 16:46:07
阅读次数：
150
消息的可靠性是RabbitMQ的一大特色，那么RabbitMQ是如何保证消息可靠性的呢——消息持久化。 为了保证RabbitMQ在退出或者crash等异常情况下数据没有丢失，需要将queue，exchange和Message都持久化。 queue的持久化queue的持久化是通过durable=tru ...
分类：
其他好文 时间：
2018-12-21 22:46:10
阅读次数：
236
一、消息队列在实际场景中的使用 流程A在处理时没有在当前线程同步的处理完而是直接发送了一条消息A1到队列里,然后消息队列过了一段时间(可能是几毫秒 几秒 几分钟)这个消息开始被处理,消息处理的过程就相当于流程A被处理;当然这只是一个简单的模型下面我们套用实际的场景来看一下,比如下单成功后发送短信提醒 ...
分类：
其他好文 时间：
2018-11-26 22:04:00
阅读次数：
241
