Message Pipe分布式消息顺序消费管道-其他

时间:2024-07-02 01:22:49
【文件属性】:

文件名称:Message Pipe分布式消息顺序消费管道-其他

文件大小:119KB

文件格式:ZIP

更新时间:2024-07-02 01:22:49

Message Pipe 分布式系统消息顺序 redis消息管道

Message Pipe是基于Redis实现的顺序消息管道,由于内部引入了Redisson分布式锁所以它是线程安全的,多线程情况下也会按照写入管道的顺序执行消费。 Message Pipe采用Client、Server概念进行设计,内部通过grpc-netty来建立消息通道相互通信的长连接,消息的分发由Server负责,而每一个管道内的消息在分发时会通过LoadBalance(负载均衡)的方式来获取在线的Client信息并向Client顺序发送消息。 特性: 自动注册 心跳检查 消息分发 顺序消费 读写分离 线程安全 负载均衡 自动剔除


【文件预览】:
message-pipe
----.github()
--------workflows()
----LICENSE(11KB)
----README.md(2KB)
----message-pipe-client()
--------src()
--------pom.xml(2KB)
----message-pipe-spring-context()
--------src()
--------pom.xml(2KB)
----pom.xml(6KB)
----.gitignore(329B)
----message-pipe-server()
--------src()
--------pom.xml(2KB)
----message-pipe-core()
--------src()
--------pom.xml(3KB)
说明.htm

网友评论