慕无忌1101988
RpcServer类下需要添加无参构造函数:
RpcServer() {
(RpcServerConfig());
}
慕妹4366021
你可以查看server是否运行,client和server端口号是否一致
慕莱坞5193489
expect {, actual error, pos 0 是不是单括号右边多打了逗号没注意
慕丝7481661
你看下有没有先启动服务端,再启动client
慕斯卡6586063
老师的代码没有问题,有相同错误的自己纠正。查看
private Response invokeRemote(Request request) {
Response resp = null;
TransportClient client = null;
try {
client = selector.select();
byte[] outBytes = encoder.encode(request);
InputStream receive = client.write(new ByteArrayInputStream(outBytes));
byte[] inBytes = IOUtils.readFully(receive, receive.available());
resp = decoder.decode(inBytes, Response.class);
} catch (IOException e) {
log.warn(e.getMessage(), e);
resp = new Response();
resp.setCode(1);
resp.setMessage("RpcClient got error:"
+ e.getClass()
+ ":" + e.getMessage());
} finally {
if(client != null){
selector.release(client);
}
}
return resp;
}这部分代码是否有误。祝大家秋招顺利~
慕盖茨412934
和那个RpcClient的空构造方法一样的~