Netty - Series 1这是一个后续打算进行长期更新的系列，每篇只包含相关的几个知识点，并不保证完全的准确性。那么作为第一篇，以我比较推崇的Netty框架作为开山作，并希望可以给大家带来一些比较少见但是又比较实用的东西。后续也没有什么特别长远的计划，大概率还是围绕着Netty、Rocket
这篇文章，我们聊聊消息队列中非常重要的最佳实践之一：消费幂等。1 基础概念消费幂等是指：当出现 RocketMQ 消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响。例如，在支付场景下，消费者消费扣款消息，对一笔订单执行扣款操
这篇文章，我们聊一聊 RocketMQ 的消息轨迹设计思路。查询消息轨迹可作为生产环境中排查问题强有力的数据支持 ，也是研发同学解决线上问题的重要武器之一。1 基础概念消息轨迹是指一条消息从生产者发送到 Broker , 再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整
很多业务场景里，我们都需要发送短信，比如登陆验证码、告警、营销通知、节日祝福等等。这篇文章，我们聊聊 Java 应用中如何优雅的发送短信。1 客户端/服务端两种模式Java 应用中发送短信通常需要使用短信服务提供商提供的短信 API 。我们经常使用的短信渠道有：阿里云、腾讯云、华为云、亿美
本文主要是测试Ckafka的性能如何，作为一款商用的消息中间件，从消息的接收和处理，以及监控维度查看消息中间件的使用方便程度，比起自己搭建一个kafka的框架来说有什么省心的地方和优点缺点。
Hope is a good thing, maybe the best of things, and no good thing ever dies.希望是件美丽的东西，也许是最好的东西，而美好的东西是永远不会消逝的。大家好，我是勇哥 。1024 , 程序员节，圆了我一个小小的梦。花
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障
这篇文章，笔者想聊聊 RocketMQ 最佳实践之一：保证订阅关系一致。订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。1 订阅关系演示首先我们展示正确
文章目录前言架构设计名词说明生产10000数据总共耗时消费10000数据总共耗时最后单条消息消耗需要异步接收异步消费测试代码5000数据测试异步接收异步消费1万数据测试异步接收异步消费3万数据测试异
中间件
这次操作差点把自己送走
这次操作差点把自己送走起因自从RabbitMQ的版本从3.9.8升级到3.11.15之后就一直没有消停过，这不监控又在呼唤了。集群中的一个节点磁盘的增速超过了阈值，查看服务器进七天的磁盘使用量一直在缓慢的增长，不是一个好的预兆，如果一直增长下去就会触发集群的磁盘空间阻塞，这是最致命的，一旦由于磁
canal 是阿里知名的开源项目，主要用途是基于 MySQL 数据库增量日志解析，提供增量数据订阅和消费。这篇文章，我们手把手向同学们展示使用 canal 将 MySQL 增量数据同步到 ES 。1 集群模式图中 server 对应一个 canal 运行实例 ，对应一个 JVM 。ser
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障
背景前段时间我们想实现 Pulsar 消息的追踪流程，追踪实现的效果图如下：实现其实比较简单，其中最重要的就是如何存储消息。消息的读取我们是通过 Pulsar 自带的 BrokerInterceptor 实现的，对这个感兴趣的朋友后面会单独做一个分享。根据这里的显示内容我们大概需要存储
@[toc]概要ActiveMQ Artemis是一个开源的消息中间件，它实现了JMS规范，支持多种协议和传输方式。它提供了一个高性能、可扩展、可靠的消息传递系统，适用于各种场景，包括云计算、大数据、企业集成等。可靠性高：ActiveMQ Artemis使用持久化存储来保证消息的可靠
Elasticsearch 是一个分布式的、面向生产规模工作负载优化的搜索引擎。Kibana 可以将 Elasticsearch 中的数据转化为直观的图表、图形和仪表盘。这篇文章，您将学习本地安装 Elasticsearch 和 Kibana，以及使用开发工具/ Java SDK 创建索引和搜
事务消息是 RocketMQ 的高级特性之一，相信很多同学都对于其实现机制很好奇。这篇文章，笔者会从应用场景、功能原理、实战例子、实现细节四个模块慢慢为你揭开事务消息的神秘面纱。1 应用场景以电商交易场景为例，用户支付订单这一核心操作的同时会涉及到下游物流发货、积分变更、购物车状态清空等多
中间件
RabbitMQ采坑记
RabbitMQ介绍RabbitMQ是一个高可用和数据安全的消息管理系统。在业务中多应用实现业务间交互的异步解耦，通过MQ中间件实现业务的削峰填谷，保障业务避免高峰期流量激增冲击。简单说就是类似Kafka、RokectMQ消息中间件的存在，但相较其他消息中间件RabbitMQ提供了友好的后台管理和
提到主从复制，我们可能立马会联想到 MySQL 的主从复制。
MySQL 主从复制是 MySQL 高可用机制之一，数据可以从数据库服务器主节点复制到一个或多个从节点。
这篇文章，我们聊聊 RocketMQ 的主从复制，希望你读完之后，能够理解主从复制的精髓。
中间件
TCP/IP网络模型
联系我们
