LesenRPC-基于netty/protobuffer的高性能RPC框架
目录
1简介
2 架构
Business code |
applacation(beanfactory+observer) |
procotols(protobuffer) |
Transport(netty) |
3 使用指南
一 从这里获取源码:http://www.svnchina.com/svn/lensenrpc/
二 服务端 1 制定要导出的接口,并将你的接口打包提供给客户端,如: interface TestServiceItf { void add(int a,int b); } 2 提供一个服务端实现
3 创建RPCService app = new RPCService(1082);
4 导出你的服务app.exportService("test", new TestService());
5 调用RPCService.run()
参见: com.lesen.rpc.example.ServiceTest
package com.lesen.rpc.example; import com.lesen.rpc.common.export.TestService; import com.lesen.rpc.service.RPCService; public class ServiceTest { public static void main(String[] args) throws Exception { RPCService app = new RPCService(1082); app.exportService("test", new TestService()); app.run(); } }
三 客户端
参见:com.lesen.rpc.example.ClientTest
package com.lesen.rpc.example; import com.lesen.rpc.client.RPCClient; import com.lesen.rpc.common.export.Service; public class ClientTest { public static void main(String[] args) { String serverName = "test"; String rpcUri = "rpc://127.0.0.1:1082"; RPCClient client = new RPCClient(rpcUri); client.registDecodeEncode(new PersonDecodeEncode()); client.connectService(); Service service = client.getRemoteService(serverName, Service.class); System.out.println(service.test("12")); client.close(); } }
4 发展方向
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。