Question

netty channelactive方法只在连接时调用吗

Answer 1

@Override
public void channelUnregistered(ChannelHandlerContext ctx) throws Exception {
//断开连接删除channel
channels.remove(SolrTcpEnum.QUERY);

final EventLoop loop = ctx.channel().eventLoop();
loop.schedule(new Runnable() {
@Override
public void run() {
log.info("Reconnecting to Solr Server [{}:{}]",SolrClient.HOST,SolrClient.PORT);
try {
SolrClient.createBootstrap(new Bootstrap(), loop);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, RECONNECT_DELAY, TimeUnit.SECONDS);

}

@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
channels.put(SolrTcpEnum.QUERY, ctx);
// if(channels.get(SolrTcpEnum.QUERY)==null){
// channels.put(SolrTcpEnum.QUERY, ctx);
// }else if(channels.get(SolrTcpEnum.PUT)==null){
// channels.put(SolrTcpEnum.PUT, ctx);
// }
}