从本地事务到分布式事务的演变 什么是事务？回答这个问题之前，我们先来看一个经典的场景：支付宝等交易平台的转账。假设小明需要用支付宝给小红转账 100000 元，此时，小明帐号会少 100000 元，而小红帐号会多 100000 元。如果在转账过程中系统崩溃了，小明帐号少 100000 元，而小红帐号金额
大家好，我是三友~~ 上周花了一点时间从头到尾、从无到有地搭建了一套RocketMQ的环境，觉得还挺easy的，所以就写篇文章分享给大家。 整篇文章可以大致分为三个部分，第一部分属于一些核心概念和工作流程的讲解；第二部分就是纯手动搭建了一套环境；第三部分是基于环境进行测试和集成到SpringB
RabbitMQ作为一款主流的消息队列工具早已广受欢迎。相比于其它的MQ工具，RabbitMQ支持的语言更多、功能更完善。 本文提供一种市面上最/极简单的使用RabbitMQ的方式（支持.NET/.NET Framework/.NET Core），只需要会调用以下三个方法，你就几乎可以掌握整个RabbitMQ的使用： （1） Send
Win32 - 窗口 目录Win32 - 窗口前言流程图创建项目VSMinGWWin32API字符串Unicode 和 ANSI 函数TCHARWinMain：Win32 Application入口点函数Console下创建窗口窗口类注册窗口类创建窗口窗口消息窗口过程默认消息处理绘制窗口关闭窗口完整代码Visit me on 前言 对于广大的玩家而言，Wi
一、消息发送重试机制说明 Producer 对发送失败的消息进行重新发送的机制，称为消息发送重试机制，也称为消息重投机制。 对于消息重投，需要注意以下几点： 生产者在发送消息时，若采用同步或异步发送方式，发送失败会重试，但 oneway 消息发送方式发送失败是没有重试机制的 只有普通消息具有
一、延时消息 当消息写入到 Broker 后，在指定的时长后才可被消费处理的消息，称为延时消息。 采用 RocketMQ 的延时消息可以实现定时任务的功能，而无需使用定时器。典型的应用场景是，电商交易中超时未支付关闭订单的场景，12306 平台订票超时未支付取消订票的场景。 在电商平台中，订单创
概念 MQ：消息队列（消息中间件），开源的基于AMQP协议的消息中间件，异步 解耦 削峰 核心作用：1.异步 2.解耦 3.消息通信 RabbitMQ 消息的类型：1.点对点 2.Worker 3.发布/定义（交换器） 四种交换器： ■1.fanout直接转发 ■2.direct路由关键字匹配，精确 ■3.topic路由关键字匹配，支持模糊（*和#） ■4
Kafka消息交付可靠性保障 Kafka 消息交付可靠性保障以及精确处理一次语义的实现。 Kafka 对 Producer 和 Consumer 提供的消息交付可靠性保障： 最多一次（at most once）：消息可能会丢失，但绝不会被重复发送。 至少一次（at least once）：消息不会丢失，但有可能被重复发送。 精确一次（exactly o
kafka 位移主题 __consumer_offsets 位移主题 诞生背景 老版本的Kafka会把位移信息保存在Zookeeper中，当Consumer重启后，自动从Zk中读取位移信息。这种设计使Kafka Broker不需要保存位移数据，可减少Broker端需要持有的状态空间，有利于实现高伸缩性。 Zookeeper不适用于高频的写操作，这
1.Hello world 简单模式 一个生产者对应一个消费者。 2.Work Queues 工作队列 一个生产者，对应多个消费者，消费者之间是竞争去同一队列取消息，并不会取到相同一条消息，类似于Redis中的队列，只能被取走一次。 应用场景：对于任务过重或任务较多的情况，使用工作队列可以提高任务处理的速
作者：罗静 在刚刚过去的 RocketMQ Summit 2022 全球开发者峰会上，我们对外正式开源了我们的新产品 RocketMQ-Eventbridge 事件驱动引擎。 RocketMQ 给人最大的印象一直是一个消息引擎。那什么是事件驱动引擎？为什么我们这次要推出事件驱动引擎这个产品？他有哪些应用场景，以及对应的技
工作模型 producer：生产者 Connection：TCP长连接，AMQP 0-9-1 连接通常是长期存在的。AMQP 0-9-1 是一个应用层协议，它使用 TCP 进行可靠传输。连接使用身份验证，并且可以使用 TLS 进行保护。当应用程序不再需要连接到服务器时，它应该优雅地关闭其 AMQP 0-9-1 连接，而不是突然关闭底层 TC
一、什么是延时消息 当消息写入到Broker后，不能立刻被消费者消费，需要等待指定的时长后才可被消费处理的消息，称为延时消息。 二、延时消息等级 RocketMQ延时消息的延迟时长不支持随意时长的延迟，是通过特定的延迟等级来指定的。默认支持18个等级的延迟消息，延时等级定义在RocketMQ服务
kafka 基本概念 消息：Record。Kafka 是消息引擎嘛，这里的消息就是指 Kafka 处理的主要对象。 主题：Topic。主题是承载消息的逻辑容器，在实际使用中多用来区分具体的业务。 分区：Partition。一个有序不变的消息序列。每个主题下可以有多个分区。 消息位移：Offset。表示分区中每条消息的
为什么使用kafka 多个生产者 Kafka可以无缝地支持多个生产者，不管客户端在使用单个主题还是多个主题。所以它很适合用来从多个前端系统收集数据，并以统一的格式对外提供数据。 多个消费者 支持多个生产者外，Kafka也支持多个消费者从一个单独的消息流上读取数据，而且消费者之间互不影响
kafka 生产者 整个生产者客户端由两个线程协调运行，这两个线程分别为主线程和Sender线程（发送线程）。 主线程中由KafkaProducer创建消息，然后通过可能的拦截器、序列化器和分区器的作用之后缓存到消息累加器（RecordAccumulator，也称为消息收集器）中。 Sender 线程负责从RecordAccumu
为什么使用消息队列？消息队列有哪些优缺点？Kafka、activeMQ，rabbitMQ、rocketMQ都什么区别以及适合哪些场景？ 如何保证消息队列的高可用啊？ 如何保证消息不被重复消费啊（如何保证消息消费时的幂等性）？ 如何保证消息的可靠性传输（如何处理消息丢失的问题）？ 如何保证消息的顺序性？ 如何解决消息
添加一个中间件，取名为内存set，消费者每次消费到了MQ的一条消息的时候，想内存set中插入消费记录，如果消费者消费的消息存在于内存set中，则这条消息被过滤 基于数据库的唯一键，保证重复数据不会被插入多条
Kafka 消息队列扫盲 消息队列顾名思义就是存放消息的队列，队列我就不解释了，别告诉我你连队列都不知道是啥吧？ 所以问题并不是消息队列是什么，而是 消息队列为什么会出现？消息队列能用来干什么？用它来干这些事会带来什么好处？消息队列会带来副作用吗？ 消息队列为什么会出现？ 消息队列算是作
【问题1】 华为推送是否有条数限制？ 【解决方案】 推送次数限制：每天向某个设备上某个应用发送消息数量不超过3000条，超过3000条进行限流（限流24小时后恢复）。 推送速率限制：华为推送对推送速度的分配，主要依据应用在华为终端上的月活和应用类型进行计算分配。 应用QPS=应用MAU 㗠应用
一、offset 管理 这里的 offset 指的是 Consumer 的消费进度 offset。 消费进度 offset 是用来记录每个 Queue 的不同消费组的消费进度的。根据消费进度记录器的不同，可以分为两种模式：本地模式和远程模式。 二、offset 本地管理模式 当消费模式为广播消费时，offset 使用本地模式存
消息中间件 常用消息中间件对比 RocketMQ相比其他两种有一个不可替代的优势：支持事务消息 作用 异步解耦（提高效率） 削峰填谷（缓解压力） 分布式缓存同步 消息分发 写磁盘方式 RocketMQ的消息是存储到磁盘上的，这样既能保证断电后恢复，又可以让存储的消息量超出内存的限制。Rocke
说明（期间写代码使用的VS2015，写博时用的VS2017，有些许差异，见谅） 1.字符问题照着书上抄代码都发现了问题，书上使用的是VC++，本人使用的VS2015，存在着一些字符格式问题。VS2015默认的是Unicode字符集，VC使用多字符字符集，当然你也可以去VS里面改设置，这是后话，暂且不表。在其中，遇到了（wchar_t）类
一、消息的存储 RocketMQ 中的消息存储在本地文件系统中，这些相关文件默认在当前用户主目录下的 store 目录中。 abort：该文件在 Broker 启动后会自动创建，正常关闭 Broker，该文件会自动消失。若在没有启动 Broker 的情况下，发现这个文件是存在的，则说明之前 Broker 的关闭是非正常关
