##RPC远程调用框架 rpc远程调用通用框架，提供一个端口多个服务同时高并发部署方案，同时提供安全，接口访问频率基础过滤器支持。
client: rpc-client.jar -h10.120.47.41 -p44444 -t300000 -th200 -c25000 -s1000
server: rpc-server.jar -h0.0.0.0 -p44444 -th200 -t600000
average benchmark RpcServerTest.java clientsSize:29325 time:300002 calls:151307 tps:504
###服务端
添加远程服务
添加一个远程服务
String host = "127.0.0.1";
int port = 4332;
AbstractRpcServer server = new SimpleRpcServer();
server.setHost(host);
server.setPort(port);
//TODO注册远程服务
//TODO注册过滤器
//注册完远程服务和过滤器之后再启动服务
server.startService();注册远程服务
简单注册多个远程服务，接口自定义
//实例化一个实现接口HelloRpcService的对象
HelloRpcService helloRpcServiceImpl = new HelloRpcServiceImpl();
//注册为远程服务
server.register(HelloRpcService.class, helloRpcServiceImpl);
//注册为远程服务添加版本支持,级别为service级别
//server.register(HelloRpcService.class, helloRpcServiceImpl,"v1.1");添加过滤器
添加ip端口 log和安全检查过滤器,过滤器实现RpcFilter接口即可
server.addRpcFilter(new MyTestRpcFilter());
server.addRpcFilter(new RpcLoginCheckFilter());###客户端
注册远程服务
初始化并启动
String host = "127.0.0.1";
int port = 4332;
client = new SimpleRpcClient();
client.setHost(host);
client.setPort(port);
//启动服务
client.startService();添加远程接口，得到实现代理对象
添加远程调用bean
LoginRpcService loginService = client.register(LoginRpcService.class);
HelloRpcService helloRpcService = client.register(HelloRpcService.class);
//选择版本，说明：版本是远程服务service版本，若服务端未找到，不会执行，会产生remote Exception
//HelloRpcService helloRpcService = client.register(HelloRpcService.class,"v1.1");调用远程服务
业务逻辑
helloRpcService.sayHello("this is HelloRpcService",564);
loginService.login("linda", "123456");
String hello = helloRpcService.getHello();##泛型支持
客户端无需知道服务端提供的rpc服务class，和参数object，只需知道名称，版本，对象包含参数 除jdk基本类型，包装对象，集合外的对象用Map表示
客户端调用
GenericService service = client.register(GenericService.class);
String[] getBeanTypes = new String[]{"com.linda.framework.rpc.TestBean","int"};
HashMap<String,Object> map = new HashMap<String,Object>();
map.put("limit", 111);
map.put("offset", 322);
map.put("order", "trtr");
map.put("message", "this is a test");
Object[] getBeanArgs = new Object[]{map,543543};
//调用泛型，无需服务端class，只需知道service名称，版本，方法，参数类型和参数
Object hh = service.invoke("com.linda.framework.rpc.HelloRpcService",
RpcUtils.DEFAULT_VERSION,"getBean", getBeanTypes, getBeanArgs);
System.out.println(hh);
String[] argTypes = new String[]{"java.lang.String","int"};
Object[] args = new Object[]{"hello,this is linda",543543};
Object invoke = service.invoke("com.linda.framework.rpc.HelloRpcService",
RpcUtils.DEFAULT_VERSION, "sayHello", argTypes, args);##RPC上下文附件支持
提供rpc上下文支持，可以将任意对象放入client上下文中，当client发起方调用rpc服务时，服务提供方可以从上下文中获取client端上传来的上下文附件。 运用场景：定义一个服务时没有必要接收风控参数作为rpc的入参，但是可以把这些风控参数放在rpc的上下文中，可以从filter中获取或在service实现中获取。
#服务调用方client加入附件
RpcContext.getContext().setAttachment("myhaha", "myattachment value");
//rpc call
helloService.sayHello("hahaha", 100);
//clear rpc context
RpcContext.getContext().clear();
//服务提供方获取附件
@Override
public void sayHello(String message,int tt) {
//获取值
Object attachment = RpcContext.getContext().getAttachment("myattachment");
System.out.println("my attachment:"+attachment);
System.out.println("sayHello:"+message+" intValue:"+tt);
//清理
RpcContext.getContext().clear();
}
//另一种清理方式
server.addRpcFilter(new RpcContextClearFilter());
public class RpcContextClearFilter implements RpcFilter{
@Override
public void doFilter(RpcObject rpc, RemoteCall call, RpcSender sender,
RpcFilterChain chain) {
try{
chain.nextFilter(rpc, call, sender);
}finally{
System.out.println("clean rpc context");
RpcContext.getContext().clear();
}
}
}