minbox-message-pipe 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
minbox-message-pipe 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
授权协议: Apache
开发语言: Java
操作系统: 跨平台
收录时间: 2020-08-24
提 交 者: 恒宇少年

基于 Redis实现的分布式消息顺序消费管道。

什么是Message Pipe?

MessagePipe是基于 Redis实现的顺序消息管道,由于内部引入了 Redisson分布式锁,所以它是线程安全的,多线程情况下也会按照写入管道的顺序执行消费。

MessagePipe采用 ClientServer概念进行设计,内部通过 grpc-netty来建立消息通道相互通信的长连接,消息的分发由 Server负责,而每一个管道内的消息在分发时会通过 LoadBalance(负载均衡)的方式来获取在线的 Client信息并向 Client顺序发送消息。

特性

  • 自动注册
  • 心跳检查
  • 消息分发
  • 顺序消费
  • 读写分离
  • 线程安全
  • 负载均衡
  • 自动剔除
展开阅读全文

代码

的 Gitee 指数为
超过 的项目

minbox-message-pipe 的相关博客

pipe

[toc] 管道(pipe) 管道是一种最基本的IPC机制, 作用于有血缘关系的进程之间通信, 完成数据传递. 本质:   伪文件, 实质为内核...

pipe

pipe我们用中文叫做管道。

Unzip from Pipe

伟大的猜想可能只是一个不起眼的注脚,然而灵感的积累却来自生活的点滴

pipe 管道

管道是一种最基本的 IPC 机制,由pipe 函数创建: #include <unistd.h> int pipe(int filedes[2]); 调用pipe 函数时在内核中开...

管道读写规则和Pipe Capacity、PIPE_BUF

一、当没有数据可读时 O_NONBLOCK disable:read调用阻塞,即进程暂停执行,一直等到有数据来到为止。 O_NONBLOCK enable:r...

Broken pipe

**例如我在浏览器发起一个请求,在请求到达服务器端后,服务器正在处理时候浏览器关闭了,服务器无法向浏览器正常发送数据,b...

12, Pipe

http://tutorials.jenkov.com/java-nio/pipe.html A Java NIO Pipe is a one-way data connection between two threads. A Pi...

broken pipe

客户端socket发送消息,此时服务端关闭了socket,就会报socketException:broken pipe错误...

pipe的操作

const char *fifo_name = "/tmp/my_fifo"; int pipe_fd = -1; int data_fd = -1; int res = 0; ...

【Vulnhub】pipe

nmap 扫描端口 扫描目录出来个 scriptz 访问得到一个 js 一个 bak 访问下载 是一个 Log 类,后面析构函数实现了把 data 写到 ...

minbox-message-pipe 的相关问答

还没有任何问答,马上提问

评论 (0)

加载中
更多评论
0 评论
10 收藏
分享
返回顶部
顶部