mina socket 通信 Too many open files Failed to open a selector

纯洁的明依 2020-12-05

1414

服务背景：

流数据接收--> 解析过滤-->调用socket服务写入mina服务。

服务器异常日志：

java.io.IOException: Too many open files Failed to open a selector
Failed to create a new instance of org.apache.mina.transport.socket.nio.NioProcessor:null

定位到问题代码：

 public void init() {
    NioSocketConnector connector = new NioSocketConnector();
    connector.getFilterChain().addLast("codec",
        new ProtocolCodecFilter(new TextLineCodecFactory(Charset.defaultCharset())));
    connector.setConnectTimeoutMillis(10000);
    connector.setHandler(new SocketClientHandler());
    connector.getSessionConfig().setReceiveBufferSize(10240); // 设置接收缓冲区的大小
    connector.getSessionConfig().setSendBufferSize(10240);// 设置输出缓冲区的大小
    ConnectFuture cf = connector.connect(
        new InetSocketAddress(socketConfig.getSocketServerIp(),
            socketConfig.getSocketServerPort()));
    // 等待连接创建完成
    cf.awaitUninterruptibly();
    session = cf.getSession();
  }

问题产生原因：
当mina服务端长时间连接不上，并发连接特别多的时候都会导致上述问题。
解决方案：当连接不成功的时候进行施放句柄。

修改之后：

 public void init() {
    NioSocketConnector connector = new NioSocketConnector();
    connector.getFilterChain().addLast("codec",
        new ProtocolCodecFilter(new TextLineCodecFactory(Charset.defaultCharset())));
    connector.setConnectTimeoutMillis(10000);
    connector.setHandler(new SocketClientHandler());
    connector.getSessionConfig().setReceiveBufferSize(10240); // 设置接收缓冲区的大小
    connector.getSessionConfig().setSendBufferSize(10240);// 设置输出缓冲区的大小
    ConnectFuture cf = connector.connect(
        new InetSocketAddress(socketConfig.getSocketServerIp(),
            socketConfig.getSocketServerPort()));
    // 等待连接创建完成
    cf.awaitUninterruptibly();
    if (cf.isDone()) {
      if (!cf.isConnected()) {
        log.error("fail connect {} {}", socketConfig.getSocketServerIp(),
            socketConfig.getSocketServerPort());
        connector.dispose();
        throw new RuntimeException("Not connect to Mina Server");
      } else {
        session = cf.getSession();
      }
    }
  }

持续分享个人的成长经历，希望为你的职场发展带来些新思路，欢迎扫码关注我！

你若喜欢，为小编点个在看哦

文章转载自纯洁的明依，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。

mina socket 通信 Too many open files Failed to open a selector

评论