基于netty+zookeeper实现的springboot rpc框架
Features:
- 服务自动注册与发现
- 服务节点优雅下线
- 客户端负载均衡
- 支持protobuf序列化协议
- 请求超时重试
- 基于javassist实现动态代理
- 支持同步,异步,回调三种调用方式
<dependency>
<groupId>com.zhouj</groupId>
<artifactId>spring-boot-rpc-starter</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
public interface RemoteService{
String remote();
}rpc:
port: 8200 #服务端口配置
clientPackage: com.zhouj.rpc.consumer #客户端包扫描路径
zookeeper:
address: 127.0.0.1:2181 #zookeeper地址@RestController
public class ConsumerController {
@RpcClient
private RemoteService remoteService;
/**
* 同步调用
* @return
*/
@RequestMapping("/remote")
public String test() {
return remoteService.remote();
}
/**
* 异步调用
* @return
*/
@RequestMapping("/async")
public String async() {
ResponseFuture responseFuture = AsyncClient.async(RemoteService.class, "remote", null);
Response response = responseFuture.get();
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append(response.getResult());
return stringBuilder.toString();
}
/**
* 回调
* @return
*/
@RequestMapping("/call")
public void call() {
AsyncClient.call(RemoteService.class, "remote", null, response -> {
logger.info("回调结果:{}", response.getResult());
});
}
}rpc:
port: 8300 #服务端端口
serverPackage: com.zhouj.rpc.server #服务包路径扫描
zookeeper:
address: 127.0.0.1:2181 #zookeeper地址@RpcService
public class RemoteServiceImpl implements RemoteService {
public String remote(){
return "远程服务";
}
}