brpc-java 是 baidu rpc 的 java 版本实现，支持 baidu rpc、nshead、sofa、hulu、http、stargate、dubbo 等协议。

• 支持 baidu rpc 标准协议、sofa 协议、hulu 协议、nshead+protobuf 协议、http+protobuf/json 协议、public pbrpc、stargate、dubbo协议。
• 支持 Spring Boot Starter，也支持 Spring Cloud 的服务注册发现、用 brpc-java 替换 Feign HTTP 调用，提升性能。
• 支持 Server Push 机制，并支持扩展 Server Push 协议。
• 支持多种 naming 服务，比如 Zookeeper、Consul、List、File、DNS 等，可以灵活扩展支持 etcd、eureka、nacos 等。
• 支持多种负载均衡策略，比如 fair、random、round robin、weight 等。
• 支持 interceptor 功能，支持计数器、令牌桶等 server 端限流算法。
• RPC 功能可独立使用，不是必须依赖 Spring 和注册中心功能。
• 基于 SPI 机制可灵活扩展 Protocol、NamingService 和 LoadBalance。

java 6+ && protobuf 2.5.0+

brpc-java当前稳定版：[STABLE_VESION] 是

非 Spring 环境：

<dependency>
    <groupId>com.baidu</groupId>
    <artifactId>brpc-java</artifactId>
    <version>[STABLE_VERSION]</version>
</dependency>

Spring 环境：

<dependency>
    <groupId>com.baidu</groupId>
    <artifactId>brpc-spring</artifactId>
    <version>[STABLE_VERSION]</version>
</dependency>

Spring Boot 环境：

<dependency>
    <groupId>com.baidu</groupId>
    <artifactId>brpc-spring-boot-starter</artifactId>
    <version>[STABLE_VERSION]</version>
</dependency>

Spring Cloud 环境：

<dependency>
    <groupId>com.baidu</groupId>
    <artifactId>spring-cloud-brpc</artifactId>
    <version>[STABLE_VERSION]</version>
</dependency>

Zookeeper 注册中心：

<dependency>
    <groupId>com.baidu</groupId>
    <artifactId>brpc-java-naming-zookeeper</artifactId>
    <version>[STABLE_VERSION]</version>
</dependency>

Consul 注册中心：

<dependency>
    <groupId>com.baidu</groupId>
    <artifactId>brpc-java-naming-consul</artifactId>
    <version>[STABLE_VERSION]</version>
</dependency>

除了引入 protobuf 2.x 环境所需依赖外，还需要增加 protobuf 3.x 依赖：

<dependency>
    <groupId>com.google.protobuf</groupId>
    <artifactId>protobuf-java</artifactId>
    <version>3.11.0</version>
</dependency>

<dependency>
    <groupId>com.google.protobuf</groupId>
    <artifactId>protobuf-java-util</artifactId>
    <version>3.11.0</version>
</dependency>

• Server 端基本用法
• 搭建标准协议/sofa 协议/hulu 协议 server
• 搭建 nshead server
• 搭建 HTTP server
• Server Push 推送用法

• Client 端基本用法

• Spring 集成使用

• 扩展 Protocol、NamingService、LoadBalance

采用 Netty 的 Reactor 网络模型，但跟常规用法有些不同：

• 没有使用 Netty 的 ByteToMessageDecoder 去解析协议，因为 ByteToMessageDecoder 内部会对 buffer 进行拷贝。
• 为了提高并发，尽量少在 IO 线程中执行业务逻辑，所以在 IO 线程中只会去解析协议的 Header 部分，并把 body 的 buffer retain 出来，然后丢给工作线程去处理；工作线程会 decode body，并执行具体业务逻辑。
• 由于粘包/拆包问题，可能一次 socket 读操作会包含多个包，所以支持了批量往工作线程中 submit 任务。

• DynamicCompositeByteBuf

• 调研过 JDK 的 ThreadPoolExecutor、ConcurrentLinkedQueue 以及 Disruptor，最后使用更高性能的 ThreadPool 。
• ThreadPool 内部把生产者队列、消费者队列分开，用两个锁去控制同步，当 consumer queue 为空时，且 producer queue 不为空条件满足时，会交换两个队列。

• FastFutureStore

• Client/Server 机器配置：CPU 12核，内存 132G，千兆网卡。
• 压测代码

添加以下管理员帮忙加群，备注bprc-java