/kratos-transport

kratos 消息队列

Primary LanguageGoMIT LicenseMIT

kratos-transport

把Kafka等异步消息队列以及Websocket实现为微服务框架Kratostransport.Server

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

我另外有一个项目kratos-cqrs ,它引用了本项目,使用Kafka来消费数据库的写操作。

要切到其他的队列(协议)也是简单的,只需要切换包即可,所需的代码更改并不多,具体可以看例子和测试。

支持的协议

消息队列

其他类型

RPC

支持的队列