RocketMQ

背景 最近在研究RocketMQ消息不丢失的一些细节，所以关注到了5.x的一个新参数allAckInSyncStateSet 消息一个不丢的代价很大，我们需要再消息丢失和性能之间找…

这里是weihubeats,觉得文章不错可以关注公众号小奏技术 RocketMQ version 5.1.0 脑图总览 实际存储文件 消息实际存储文件 commitLog 消息实际…

1. 问题&分析 1.1. 案例 深夜，小艾接到了一通突如其来的电话，是物流系统的负责人曹工焦急的声音。他火急火燎地反馈了一个严重的问题——大批用户投诉物流信息异常，订单状…

简介 为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理…

业务场景 RocketMQ 消费异常，但是重试间隔时间太长（HTTP协议重试策略），需要快速定位到系统异常问题，所以需要手动在控制台发送消息并且发送。 异常消息日志 RocketM…

  借用习大大的一句话：安全是发展的保障，发展是安全的目的。 这句话不仅仅适用于实体经济，也适用于互联网。   事情是这样的，最近在做开源软件供应链安全相关的项目，之前没了解这方面…

1. RocketMQ集群 1.1 各角色介绍 Producer：消息的发送者。 Consumer：消息的接收者。 Broker：暂存和传输消息。 NameServer：管理Bro…

1. 背景         随着物联网行业的发展、智能设备数量越来越多，设备活跃量也大量增加，常常存…

1. 引言 在设备联动中，有些场景需要保持设备继续工作一段时间再关机。比如在厨房场景下，存在燃气灶和烟机的联动场景，以燃气灶为条件，烟机为结果。当打开燃气灶后，烟机自动打开；当关掉…

1. 引言 随着后端服务的发展，业务难度增加；单体的后端服务逐渐满足不了快速迭代，敏捷开发的节奏，在这样的背景下，分布式系统架构思想逐渐发展，并流行起来；在微服务思想下，将原有复杂…

1. 引言 当设备连接到云端的时候，设备就可以上传自己的状态，根据具体的义务场景设备上报的消息可以分成多类，比如： 设备状态上报：包括设备的在线信息、电量、温度、湿度等； 告警信息…

Rocketmq版本 version: 5.1.0 背景 继续上次的高可用topic二开已经有了一段时间，现在我们需要对我们的限流数据进行监控，所以现在我们来研究研究RocketM…

前言 本文讲述 RocketMQ 从源码编译到配置启动以及测试的完整过程。 准备工作 • 安装 64bit JDK 1.8+ • 参考 安装 Mave…

前言 Dashboard是一个Java web 项目，Maven工程。通过源码编译成jar包后启动即可通过浏览器访问。通过html界面可以查看RockeMQ集群状态、创建/删除To…

前言 从整体浅析Kafka集群结构、和Zookeeper之间的关系、长轮询机制、消息生产和消费以及顺序消费等。 名词解释 • Broker（Kafka服务） •&nbsp…

导读：本篇文章讲解 Docker安装RocketMQ，希望对大家有帮助，欢迎收藏，转发！站点地址：www.bmabk.com