按时间顺序浏览所有文章,探索知识的时间线
关键依赖 <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway-server-webf
引言 Spring Cloud Gateway 是 Spring 官方研发的微服务网关组件,专为微服务架构打造,提供简洁、高效、统一的 API 路由管理能力。依靠过滤器链拓展各类通用能力,包含接口鉴权、运行指标监控、流量管控、服务熔断限流、请求重写、跨域处理等,是微服务架构中标准的流量入口组件 现存
引言 事务消息是 RocketMQ 解决分布式事务最终一致性的核心特性,通过半消息、事务状态回查机制,保证本地事务执行与消息发送的原子性 关键概念 半消息(Half Message) 生产者发送的临时不可消费消息,Broker 已接收但未提交,仅用于标记消息预发送成功。 事务状态回查 若网络波动/生
引言 顺序消息用于保证消息生产与消费的严格时序。是 RocketMQ 核心高级特性 顺序消息 顺序消息指生产者发送顺序 = 消费者消费顺序,RocketMQ 通过 hashKey 将消息路由到同一个消息队列,实现严格顺序;消费者需配置顺序消费模式。 核心特性 相同 hashKey 的消息会进入同一队
引言 单向消息(OneWay Message)是 RocketMQ 轻量化的消息发送模式,生产者仅发送消息,不等待 Broker 响应、无回调通知、不关注消息是否送达。该模式无网络等待开销,吞吐量极高,适用于对可靠性要求低、追求极致性能的场景,例如日志采集、用户行为埋点、非核心数据上报等。 准备工作
引言 在分布式系统中,异步消息是高性能、低延迟的核心通信方式。生产者发送消息后无需阻塞等待 Broker 响应,通过线程池异步执行发送任务,消息发送结果通过 SendCallback 回调通知。该模式不阻塞主线程,完美适配对响应时间敏感、高并发的业务场景。 准备工作 消息实体 复用前文定义的实体对象
引言 同步消息是 RocketMQ 中高可靠性的消息发送方式,发送时会阻塞当前线程,等待 Broker 服务器返回发送结果后再继续执行,极大降低消息丢失概率,适用于订单、支付等核心业务场景 准备工作 消息实体 创建序列化实体对象,用于测试复杂对象发送 package com.lusifer.sca.
引言 在 Spring Boot 应用中,通过 Apache RocketMQ 官方提供的 spring-boot-starter 组件,可极简集成 RocketMQ 服务,实现消息的异步发送与监听接收 依赖配置 删除之前的 rocketmq-client-java 依赖,替换如下依赖 <depen
引言 RocketMQ Dashboard 是 RocketMQ 的官方可视化管控平台,提供客户端与应用程序的事件追踪、性能指标统计,支持以图形化界面替代命令行操作,完成 Topic 配置、Broker 管理、消息查询等核心运维工作 功能概述
引言 本节介绍如何使用 Docker Compose 快速部署单节点单副本 RocketMQ 服务,并完成简单的消息收发测试 https://rocketmq.apache.org/zh/