概述 本文介绍JMS中可能发生消息故障的3个隐患阶段，以及确保消息安全的3种保障机制。 故障分析 在介绍可靠传送的确保机制之前，先分析消息在传送的过程中可能在哪个阶段出现问题。 1.两个跃点 跃点的含义在于消息的持有者发生变化，如发送使消息 ...

​ 所谓的消费方消息确认就是签收模式ack,Rabbitmq默认开启的是自动签收模式，也就是消费者监听到消息到达，就会自动发送ack给队列，告诉队列这条消息可以删除了，这种自动签收的模式存在消息丢失的可能，出现异常的话这条消息就丢了，要保证消息不会丢失，还是建议开启手动签收的模式。 一、三种签收 ...

源码分析的spark版本是1.6。 首先，先看一下 org.apache.spark.streaming.dstream.InputDStream 的 类说明： 翻译如下： ...

1.引入rocketmq的依赖 2.启动Rocketmq-dashboard管理台 具体参见：https://www.cnblogs.com/luckyplj/p/16007605.html 3. 向RocketMq发送消息 3.1 配置RocketMq发送消息的相关 ...

一、需求 前两篇文章，我们分别介绍了消息发送方的确认和消息接收方的消息确认，由此可知，消息的发送方只关注消息有木有到达队列，消息的接收方只关注在什么时候告诉队列这个条消息可以删除了，那么如果有那样的需求，发送方想获取消息的消费情况，例如想修改消息表中消息的状态，也就是得想一个办法，如何在消息到达 ...

1. 基本了解 1.1 简述说明 特性（Attribute）本质上是一个类，此类需要直接或间接继承 Attribute 类，特性为目标元素（比如类、方法、结构、枚举、组件等）提供关联附加信息，并在运行期以反射的方式来获取附加信息 说明：特性类的实例里没有验证逻辑，只有验证用到的规范 ...

，这个方式很好，我也将采取同样的方式。在接下来的一系列关于AMQ的文章中，顺序几乎是我学习的顺序，但也根据合理 ...

原文地址： Async Sends 背景 ActiveMQ支持同步、异步两种发送的模式将消息发送到broker，模式的选择对发送延时有巨大的影响。producer能达到怎样的产出率 [1]，主要受发送延时的影响，使用异步发送，可以显著的提高发送的性能 ...