rpc based on netty
Server端只要实现AbstractServerHandler类的processor方法。该方法用来对消息的具体处理。
byte[] ret = transport.getValue(); //处理之后的返回结果
//System.out.println("8080端口接受到的数据:"+new String(ret));
ServerSender sender = new ServerSender(channel, transport);
sender.send(ret);
//System.out.println("向8081端口发送数据完成");
Client端只要提供了三个方法与服务端通讯:(1)阻塞式的消息处理;(2)非阻塞式的消息处理;(3)只发送消息,没有消息返回的情况。
nonBlockingGet(byte[] request);
blockingGet(byte[] request, long timeout);
sendNoBack(byte[] request);
详细使用参考test的代码。
程序主体参考:http://fengfeng925.iteye.com/blog/1551762
二进制协议参考:http://www.blogjava.net/hankchen/archive/2012/02/04/369378.html