kratos-transport

module
v0.0.0-...-2d343b4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 9, 2022 License: MIT

README

kratos-transport

把Kafka等异步消息队列以及Websocket实现为微服务框架Kratos 的transport.Server.
在使用的时候,可以调用kratos.Server()方法,将之注册成为一个Server.

我另外有一个项目kratos-cqrs ,它引用了本项目,使用Kafka来消费数据库的写操作.其实要切到其他的队列也是简单的,比如已经支持的RabbitMQ,Redis.所需要进行的代码更改并不多,具体可以看例子和测试.

支持的队列或者协议

Directories

Path Synopsis
nsq
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL