kratos-transport

kratos-transport

把消息队列、任务队列，以及Websocket、HTTP3等网络协议实现为微服务框架 Kratos 的transport.Server。

在使用的时候,可以调用kratos.Server()方法，将之注册成为一个Server。

各种缝合，请叫我：缝合怪。

支持的服务（Server）

消息队列

• RabbitMQ
• Kafka
• RocketMQ
• ActiveMQ
• Apollo
• Pulsar
• NATS
• NSQ
• Redis
• MQTT
• STOMP
• AMQP

RPC

• Thrift
• GraphQL
• FastHttp
• Gin
• Go-Zero
• Hertz
• Iris

任务队列

• Asynq
• Machinery

网络协议

• WebSocket
• HTTP3
• WebTransport
• SSE
• SignalR
• Socket.IO

支持的消息代理（Broker）

• RabbitMQ
• Kafka
• RocketMQ
• ActiveMQ
• Apollo
• Pulsar
• NATS
• NSQ
• Redis
• MQTT
• STOMP
• AMQP

应用示例

• kratos-chatroom 一个简单的Websocket聊天室的示例
• kratos-cqrs 一个CQRS架构模式的示例
• kratos-realtimemap 一个物联网的公共交通实时显示地图的示例
• kratos-bi 一个BI系统的示例

以上示例在Kratos官方示例代码库中也可以找到。