message-queues

用途：为游戏服务器实现异步消息与可扩展架构，覆盖 Kafka、RabbitMQ、Redis Pub/Sub、NATS 以及 Akka/Orleans 等 Actor 模型方案。主要能力：给出队列系统在吞吐量、延迟、有序性和适用场景上的对比；提供 Kafka 生产者与消费者示例（含 acks、retries、linger.ms、batch.size，手动 commit、按 playerId 分区）；RabbitMQ 带重试连接、持久化发布与手动 ack/nack 的 Go 示例；Redis Pub/Sub 的游戏状态与聊天广播、订阅回调及连接池用法；NATS JetStream 流创建、带确认发布与持久消费者；Orleans Grain（虚拟 Actor）玩家状态与 silo 配置示例。还提供用例映射（跨服聊天用 RabbitMQ、分析管道用 Kafka、实时状态用 Redis Pub/Sub、分布式状态用 Orleans/Akka、比赛结果用 Kafka、通知用 NATS）、常见失败模式（消费滞后、消息丢失、重复处理、broker 不可用）与调试命令（kafka-consumer-groups.sh、rabbitmqctl list_queues、redis-cli PUBSUB CHANNELS、nats stream info），以及基于 testcontainers 的发布单元测试模板。使用方式：按上述示例代码与命令配置和调试各类消息系统。限制：资料未提供许可证、安装方式、收费与价格、性能基准，也未说明具体版本要求，这些信息暂未提供。