服務(wù)器異常問題怎么解決

發(fā)布時(shí)間：2021-12-18 17:31:45 來源：億速云閱讀：234 作者：iii 欄目：大數(shù)據(jù)

本篇內(nèi)容介紹了“服務(wù)器異常問題怎么解決”的有關(guān)知識(shí)，在實(shí)際案例的操作過程中，不少人都會(huì)遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

服務(wù)背景：

流數(shù)據(jù)接收--> 解析過濾-->調(diào)用socket服務(wù) 寫入mina服務(wù)。

服務(wù)器異常日志：

java.io.IOException: Too many open files Failed to open a selectorFailed 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); // 設(shè)置接收緩沖區(qū)的大小    connector.getSessionConfig().setSendBufferSize(10240);// 設(shè)置輸出緩沖區(qū)的大小    ConnectFuture cf = connector.connect(        new InetSocketAddress(socketConfig.getSocketServerIp(),            socketConfig.getSocketServerPort()));    // 等待連接創(chuàng)建完成    cf.awaitUninterruptibly();    session = cf.getSession();  }

問題產(chǎn)生原因：
當(dāng)mina服務(wù)端長(zhǎng)時(shí)間連接不上，并發(fā)連接特別多的時(shí)候都會(huì)導(dǎo)致上述問題。
解決方案：當(dāng)連接不成功的時(shí)候進(jìn)行施放句柄。

修改之后：

 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); // 設(shè)置接收緩沖區(qū)的大小    connector.getSessionConfig().setSendBufferSize(10240);// 設(shè)置輸出緩沖區(qū)的大小    ConnectFuture cf = connector.connect(        new InetSocketAddress(socketConfig.getSocketServerIp(),            socketConfig.getSocketServerPort()));    // 等待連接創(chuàng)建完成    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();      }    }  }

“服務(wù)器異常問題怎么解決”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！

向AI問一下細(xì)節(jié)

服務(wù)器異常問題怎么解決

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽