netty用pb来实现多接口rpc

| 2014年12月17日

package org.zhwen.netty.hello;

enum ReqestType {
LOGIN = 0;
SERVICE = 1;
}

message Request {
required ReqestType type = 1;
optional Login login = 100;
optional Service service = 101;
}

message Login {
required string user = 1;
required string pswd = 2;
}

message Service {
optional string content = 1;
}

message Response {
required ReqestType type = 1;
required int64 seqid = 2;
required int32 ret = 3;
optional string result = 4;
}

pipeline.addLast("protobufDecoder", new ProtobufDecoder(Hello.Request.getDefaultInstance()));

protected void channelRead0(ChannelHandlerContext ctx, Request req) throws Exception {
Response.Builder response = Response.newBuilder();

response.setSeqid(++count);
response.setType(req.getType());

if (ReqestType.LOGIN == req.getType()) {
response.setResult(req.getLogin().getPswd());
response.setRet(0);
｝

pipeline.addLast("protobufDecoder", new ProtobufDecoder(Hello.Response.getDefaultInstance()));