VIP20

本课程属于：004-ROS2机器人开发 机器人系统 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

自定义消息与服务接口实战

📚 共计 30 章节

消息驱动架构概述

什么是消息驱动架构、为什么需要消息队列、同步与异步通信对比、常见消息中间件介绍（RabbitMQ、Kafka、RocketMQ）

架构消息队列

自定义消息协议设计

协议设计原则、消息头与消息体结构、序列化与反序列化（JSON/Protobuf）、消息类型与路由键设计

协议序列化

RabbitMQ 基础与实战

RabbitMQ 核心概念（Exchange、Queue、Binding）、安装与配置、Java/Python 客户端连接、Hello World 消息发送与接收

RabbitMQ 交换机模式

Direct Exchange、Topic Exchange、Fanout Exchange、Headers Exchange 的原理与代码实现

交换机路由

RabbitMQ 高级特性

消息确认机制（ACK/NACK）、死信队列（DLX）、延迟队列、消息持久化与可靠性保证

可靠性死信

Kafka 基础与实战

Kafka 核心概念（Topic、Partition、Consumer Group）、安装与配置、Java/Python 生产者与消费者 API

Kafka 分区与副本机制

分区策略、副本同步（ISR）、Leader 选举、数据可靠性保证（acks 配置）

Kafka 高级特性

消息幂等性与事务、Exactly-Once 语义、Kafka Streams 入门、Kafka Connect 数据集成

RocketMQ 基础与实战

RocketMQ 核心概念（NameServer、Broker、Producer、Consumer）、安装与配置、Java 客户端发送与消费消息

RocketMQ 高级特性

顺序消息、事务消息、延时消息、批量消息、消息过滤机制

消息序列化与反序列化

JSON 序列化实战、Protobuf 定义与编译、Avro 与 Thrift 对比、自定义序列化器实现

服务接口设计基础

RESTful API 设计规范、gRPC 入门、接口版本管理、错误码与异常处理设计

Protocol Buffers 定义服务、一元 RPC、服务端流式 RPC、客户端流式 RPC、双向流式 RPC

gRPC 高级特性

拦截器（Interceptor）、认证与安全（TLS/SSL）、负载均衡、健康检查

拦截器安全

消息驱动微服务实战

Spring Cloud Stream 入门、Binder 概念（RabbitMQ/Kafka）、消息绑定与通道定义

Spring微服务

Spring Cloud Stream 高级

消息分组与分区、消息重试与死信处理、自定义消息转换器、测试消息驱动应用

事件驱动架构（EDA）

事件溯源（Event Sourcing）概念、CQRS 模式、事件总线实现、与消息队列的集成

消息事务与一致性

分布式事务基础（CAP、BASE）、本地消息表、TCC 模式、Saga 模式、消息最终一致性方案

消息幂等性与去重

幂等性设计原则、唯一键去重、状态机去重、Redis 与数据库实现去重

消息监控与运维

消息堆积监控、延迟监控、Prometheus + Grafana 监控 RabbitMQ/Kafka、告警规则配置

监控Prometheus

消息安全与权限控制

TLS/SSL 加密传输、SASL 认证、ACL 权限控制、消息加密与解密

高性能消息处理

批量发送与消费、异步非阻塞处理、连接池与线程池优化、零拷贝技术

性能零拷贝

消息中间件选型对比

RabbitMQ vs Kafka vs RocketMQ vs Pulsar、吞吐量、延迟、可靠性、社区生态对比

自定义消息网关

基于 Netty 实现消息网关、协议解析与路由、连接管理、心跳与断线重连

消息协议扩展

MQTT 协议入门、AMQP 协议详解、STOMP 协议、WebSocket 与消息推送

云原生消息服务

阿里云 RocketMQ、AWS SQS/SNS、Google Pub/Sub、Azure Service Bus 使用与对比

消息驱动测试策略

单元测试（Mock 消息）、集成测试（Embedded Broker）、契约测试、性能测试（JMeter/Locust）

消息驱动项目实战（上）

需求分析、架构设计、消息协议定义、生产者服务实现

消息驱动项目实战（下）

消费者服务实现、异常处理与重试、监控与日志、部署与运维

课程总结与未来展望

消息驱动架构最佳实践、常见坑与避坑指南、Serverless 与消息驱动、AI 与消息驱动融合趋势