jeremyhi
jeremyhi
## Add streaming APIs (RpcClient, RpcServer), implement it based on gRPC. This is a subtask that belongs to the first step of #672 In this subtask, we need a streaming...
### 背景： 目前 jraft 日志复制基于普通 RPC 的一请求一响应模型，在 RPC 层之上实现了日志的 pipeline 复制，这给上层带来了复杂的控制逻辑，比如要绑定线程以保证发送和接收顺序，要维护一个 inflights FIFO 队列来保证顺序，我们还为此专门实现了一个 `MpscSingleThreadExecutor` （多生产者单消费者线程池）来提高性能，等等，以上种种，核心原因还是因为受到 `一请求一响应的模型`的约束从而带来的实现复杂度。 ### 目标： 当前，jraft 有一层 rpc 层的抽象层，并且在去年我们也支持了 grpc，所以我们是否可以利用 grpc 的 streaming 来实现一个新的 AppendEntries，如果抛开一请求一相应的模型，可能有如下好处： 1....
- [x] 1. 并行压缩解压缩能力，主要是优化加载 snapshot 的速度，见 #569 - 已合并进 master - [x] 2. 将一个运行中的 learner 动态改成 follower，见 #560 - 已合并进 master - [ ] 3. Snapshot 传输实现断点续传机制，见 #503 - 已提交...
#837 #841
## Introduction SOFAJRaft is a production-level, high-performance Java implementation based on the RAFT consistency algorithm that supports MULTI-RAFT-GROUP for high-load, low-latency scenarios. With SOFAJRaft you can focus on your business...
### Your question Now that we have multiple implementations of rpc layer, we need some common unit tests to cover all of them ### Your scenes ### Your advice ###...
## Introduction SOFAJRaft is a production-level, high-performance Java implementation based on the RAFT consistency algorithm that supports MULTI-RAFT-GROUP for high-load, low-latency scenarios. With SOFAJRaft you can focus on your business...
### Your question `ping` is a blocking call, and this is not needed, we should let the rpc framework (bolt) to check connections ### Your scenes ### Your advice replace...
- [Jupiter源码解析：服务](http://www.code-sea.com/?p=486) - [Jupiter源码解析（二）：客户端远程调用](http://www.code-sea.com/?p=510) - [一起学RPC(零)](https://www.jianshu.com/p/2df868381b9a) - [一起学Netty（十四）之 Netty生产级的心跳和重连机制](https://blog.csdn.net/linuu/article/details/51509847)