1000字范文,内容丰富有趣,学习的好帮手!
1000字范文 > java mina 长连接_apache mina 长连接

java mina 长连接_apache mina 长连接

时间:2019-10-16 12:03:15

相关推荐

java mina 长连接_apache mina 长连接

apache mina 是较为流行的基于NIO的TCP/IP网络框架,她拥有高性能,以及高的实用性。

可以用于网页游戏服务器,手机游戏服务器。也可作为推送服务器使用。

版本:2.0.x

SocketAcceptor acceptor = new NioSocketAcceptor(); //这个构造函数有个参数,是processCount指的是core process数,一般是电脑的 CPU核数 + 1。

LoggingFilter log = new LoggingFilter();

log.setMessageSentLogLevel(LogLevel.DEBUG);

acceptor.getFilterChain().addLast("logger", log);

acceptor.getSessionConfig().setWriteTimeout(10000);

acceptor.getSessionConfig().setWriterIdleTime(100000);

TextLineCodecFactory lineFactory = new TextLineCodecFactory(

Charset.forName("UTF-8"));

lineFactory.setDecoderMaxLineLength(Integer.MAX_VALUE);

lineFactory.setEncoderMaxLineLength(Integer.MAX_VALUE);

acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(lineFactory));

acceptor.getFilterChain().addLast("exceutor", new ExecutorFilter());acceptor.setHandler(new MyDataHandler()); //自定义数据处理 handler

acceptor.getFilterChain().addLast("exceutor", new ExecutorFilter());

默认的如果不设置 exceutor,就使用NioSocketAcceptor() 默认的processCount作为主线程数。

ExecutorFilter 默认为 DEFAULT_MAX_POOL_SIZE = 16;

如果在

MyDataHandler做了阻塞的话,最多16个线程 就无法再接受新的线程。

接收更多的线程:

new ExecutorFilter(Executors.newCachedThreadPool()); //线程数。长连接阻塞必须定义一个thread pool否则无法处理更多的连接数。

public class MyDataHandler extends IoHandlerAdapter {

public void messageReceived(IoSession session, Object message) throws Exception {

String act = message.toString();

long _id = session.getId();

session.setAttribute(_id, System.currentTimeMillis());

process(session, message);

}

private void process(IoSession session, Object msg) {

String cmd = getTcpCmd(msg);

if("1001".equals(cmd)){

while (!hasClosed) { //阻塞当前线程,作为主动推送

if (session.isClosing() || !session.isConnected()) {

break; //异常关闭,客户端主动关闭

}

if (hasData()) {

String data1 = "";

try {

data1 = readLatestData();

} catch (Exception e) {

e.printStackTrace();

}

session.write(data1 + "\n"); //发送数据给客户端,长连接

LOG.info("Send Client OK :" + session);

}

}

}

}

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。