{"repo":"tx7do/kratos-transport","free":true,"listed":false,"github":"https://github.com/tx7do/kratos-transport","clone":"git clone https://github.com/tx7do/kratos-transport.git","description":"kratos transport layer extension, support: rabbitmq,kafka,rocketmq,activemq,apollo,mcp,tcp,websocket...","language":"Go","stars":447,"topics":["activemq","amqp","asynq","gin","golang","http3","iris","kafka","kratos","machinery"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Kratos Transport 为 Kratos 微服务框架打造的统一传输层与消息代理扩展集 一套抽象，30+ 传输协议全覆盖，开箱即用 中文 · English · 日本語 --- 项目亮点 - 30+ 传输协议与消息中间件适配 ：RabbitMQ、Kafka、RocketMQ、Pulsar、NATS、NSQ、MQTT、Redis Stream、Azure Service Bus、GCP Pub/Sub、AWS SQS、WebSocket、HTTP/3、WebTransport、SSE、SignalR、Socket.IO、MCP、KCP、WebRTC…… 一站式覆盖主流消息队列、云消息服务、RPC 框架与实时通信协议 - 双模式接入 ： transport.Server 实现可直接注册到 Kratos 服务生命周期；独立 broker.Broker 接口支持纯消息代理场景，按需选用 - 泛型类型安全 ：基于 Go 1.18+ 泛型提供 TypedHandler[T] 、 Subscribe[T] 、 RegisterSubscriber[S, T] 等类型安全 API，告别 interface{} 运行时恐慌 - 统一消息抽象 ： broker.Message 统一封装 Headers / Body / Metadata / Partition / Offset，屏蔽底层协议差异 - 可观测性就绪 ：内置 OpenTelemetry 链路追踪集成，支持 OTLP gRPC/HTTP、Jaeger、Zipkin 等主流 Exporter，发布 / 订阅全链路 Trace - 中间件链 ：Publish / Subscribe 双向中间件机制，可灵活注入日志、指标、链路追踪、限流等横切关注点 - 高可靠性消息投递 ：RabbitMQ 支持 Publisher Confirms（发布确认）、Publisher Returns（消息退回）、多 Exchange 路由，确保消息不丢失 - 模块化按需引入 ：每个 transport / broker 实现独立 Go Module，只引入你需要的依赖，避免依赖膨胀 --- 架构概览 --- 支持能力一览 消息队列 Transport Server 中间件 说明 文档 ------------------- ------------------------------ ------------------------------------------ RabbitMQ AMQP 0-9-1 协议，广泛用于企业异步消息 README Kafka 高吞吐分布式事件流平台 README RocketMQ 阿里云级分布式消息中间件 README ActiveMQ STOMP 协议接入 ActiveMQ / Apollo README Pulsar Apache Pulsar 云原生消息平台 README NATS 轻量高性能消息系统 README NSQ 实时分布式消息平台 README Redis Redis Stream 消息消费 README MQTT 物联网 MQTT v3.1.1 / v5.0 协议 README Azure Service Bus Azure 云消息队列服务 README GCP Pub/Sub Google Cloud 消息发布/订阅服务 README AWS SQS Amazon Simple Queue Service README RPC / Web 框架扩展 框架 说明 文档","default_branch":null,"files":null,"tree":[],"storefront":"/r/tx7do","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/tx7do/kratos-transport/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}