问题消息释放
public class MessageTask4Response implements Runnable {
private MessageModule.Message message;
private ChannelHandlerContext ctx;
public MessageTask4Response(MessageModule.Message message, ChannelHandlerContext ctx) {
this.message = message;
this.ctx = ctx;
}
@Override
public void run() {
try {
// user-return
String module = this.message.getModule();
// save-return
String cmd = this.message.getCmd();
// 响应的结果
ResultType resultType = this.message.getResultType();
// 响应的内容
byte[] data = this.message.getBody().toByteArray();
Invoker invoker = InvokerTable.getInvoker(module, cmd);
invoker.invoke(resultType, data);
} finally {
ReferenceCountUtil.release(message);
}
}
}
为什么
MessageTask4Response
需要
finally {
ReferenceCountUtil.release(message);
}
而
MessageTask4Request
却没有
11
收起
正在回答 回答被采纳积分+1
1回答
恭喜解决一个难题,获得1积分~
来为老师/同学的回答评分吧
0 星