把Kafka等异步消息队列以及Websocket实现为微服务框架Kratos 的transport.Server。
在使用的时候,可以调用kratos.Server()方法，将之注册成为一个Server。
我另外有一个项目kratos-cqrs ，它引用了本项目，使用Kafka来消费数据库的写操作。
要切到其他的队列（协议）也是简单的，只需要切换包即可，所需的代码更改并不多，具体可以看例子和测试。
把Kafka等异步消息队列以及Websocket实现为微服务框架Kratos 的transport.Server。
在使用的时候,可以调用kratos.Server()方法，将之注册成为一个Server。
我另外有一个项目kratos-cqrs ，它引用了本项目，使用Kafka来消费数据库的写操作。
要切到其他的队列（协议）也是简单的，只需要切换包即可，所需的代码更改并不多，具体可以看例子和测试。