对等连接异常？

Question

我这个程序采用的是netty，此程序中有客户端和服务端。

程序思路：服务端接受消息后在利用客户端发给别的服务端。

出现问题：时不时会出现这个异常，也不知道是那报的异常，经过查资料此异常是由某一端断开，发生的连接异常 ，我的客户端做了断开重连 但是并没发现重连的log ，难道是上游的客户端断开，那我的服务端也不应该报异常啊。不是很清楚？ 有知道的吗？或者提供解决思路。

客户端重连代码

@Component
public class BdspNettySocketClient {

    private Logger log = LoggerFactory.getLogger(BdspNettySocketClient.class);

    /**
     * 线程组
     */
    private NioEventLoopGroup eventExecutors;


    /**
     * 存放通道  BdspNettySocketClientInitializer中的通道为最新通道
     */
    public static final ConcurrentHashMap<String, Channel> mChannel = new ConcurrentHashMap<>();


    /**
     * 启动netty客户端
     */
    @PostConstruct
    public void start() {
        //初始化信息
        try {
            this.init();
        } catch (Exception e) {
            log.error("启动 netty 客户端出现异常", e);
        }
    }

    /**
     * 当Bean在容器销毁之前，调用被@PreDestroy注解的方法
     */
    @PreDestroy
    public void destroy() {
        this.eventExecutors.shutdownGracefully();
    }

    /**
     * 初始化nettyClient配置
     */

    private void init() {

        //每次都需要重置通道
        if (mChannel.get("channel") != null) {
            mChannel.clear();
        }


        this.eventExecutors = new NioEventLoopGroup(1);

        //配置客户端的各种信息
        Bootstrap bootstrap = new Bootstrap();
        //设置线程组
        bootstrap.group(eventExecutors);

        //设置通道 此通道是异步非堵塞
        bootstrap.channel(NioSocketChannel.class);
        bootstrap.option(ChannelOption.SO_KEEPALIVE, true);
        //初始化通道 其中在里面配置逻辑
        bootstrap.handler(new BdspNettySocketClientInitializer());
        //连接设备信息
        log.info("netty client start!");
 
        /**
         * 连接好的容器
         */
        ChannelFuture channelFuture = bootstrap.connect("", );

        //这事防止客户端掉线 掉线后重连
        channelFuture.addListener(new ConnectionListener());
    }


    public void send(String msg) {
        try {
            mChannel.get("channel").writeAndFlush(Unpooled.copiedBuffer(msg, CharsetUtil.UTF_8));
       /*     System.out.println(mChannel.get("channel"));
            System.out.println(mChannel.get("channel"));
            channelFuture.channel().writeAndFlush(Unpooled.copiedBuffer(msg, CharsetUtil.UTF_8));*/
        } catch (Exception e) {
            log.error(this.getClass().getName().concat(".send has error"), e);

        }
    }

    public void send(Object msg) {
        try {
            mChannel.get("channel").writeAndFlush(msg);
        } catch (Exception e) {
            log.error(this.getClass().getName().concat(".send has error"), e);
        }
    }
}

断开后进入重连

@Component
public class ConnectionListener implements ChannelFutureListener {


    private BdspNettySocketClient bdspNettySocketClient = new BdspNettySocketClient();

    /**
     * 处理第一次连接服务器是否成功的
     * @param channelFuture  the source {@link Future} which called this callback
     * @throws Exception
     */
    @Override
    public void operationComplete(ChannelFuture channelFuture) throws Exception {
        if (!channelFuture.isSuccess()) {
            final EventLoop loop = channelFuture.channel().eventLoop();
            loop.schedule(new Runnable() {
                @Override
                public void run() {
                    System.err.println("服务端链接不上，开始重连操作...");
                    bdspNettySocketClient.start( );
                }
            }, 2L, TimeUnit.SECONDS);
        } else {
            System.err.println("服务端链接成功...");
        }
    }
}

Answer 1

这个应该是你的客户端断开连接了，客户端怎么做的断开重连，贴下代码看看