把Kafka等异步消息队列以及Websocket实现为微服务框架Kratos 的transport.Server.
在使用的时候,可以调用kratos.Server()方法,将之注册成为一个Server.
我另外有一个项目kratos-cqrs ,它引用了本项目,使用Kafka来消费数据库的写操作.其实要切到其他的队列也是简单的,比如已经支持的RabbitMQ,Redis.所需要进行的代码更改并不多,具体可以看例子和测试.
forked from tx7do/kratos-transport
-
Notifications
You must be signed in to change notification settings - Fork 0
License
go-sohunjug/kratos-transport
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published
Languages
- Go 100.0%