module
Version:
v0.0.0-...-2d343b4
Opens a new window with list of versions in this module.
Published: Jun 9, 2022
License: MIT
Opens a new window with license information.
README
¶
kratos-transport
把Kafka等异步消息队列以及Websocket实现为微服务框架Kratos 的transport.Server.
在使用的时候,可以调用kratos.Server()
方法,将之注册成为一个Server.
我另外有一个项目kratos-cqrs ,它引用了本项目,使用Kafka来消费数据库的写操作.其实要切到其他的队列也是简单的,比如已经支持的RabbitMQ,Redis.所需要进行的代码更改并不多,具体可以看例子和测试.
支持的队列或者协议
Directories
¶
|
|
|
|
|
|
|
|
|
|
rabbitmq
Package rabbitmq provides a RabbitMQ common
|
Package rabbitmq provides a RabbitMQ common |
|
|
|
|
|
|
|
|
json
Package json provides a json codec
|
Package json provides a json codec |
|
|
|
|
transport
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Click to show internal directories.
Click to hide internal directories.