org.apache.mina.transport.socket.SocketSessionConfig.setIdleTime()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(84)

本文整理了Java中org.apache.mina.transport.socket.SocketSessionConfig.setIdleTime()方法的一些代码示例,展示了SocketSessionConfig.setIdleTime()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。SocketSessionConfig.setIdleTime()方法的具体详情如下:
包路径:org.apache.mina.transport.socket.SocketSessionConfig
类名称:SocketSessionConfig
方法名:setIdleTime

SocketSessionConfig.setIdleTime介绍

暂无

代码示例

代码示例来源:origin: Red5/red5-server

sessionConf.setIdleTime(IdleStatus.BOTH_IDLE, idleTime);
sessionConf.setKeepAlive(keepAlive);

代码示例来源:origin: apache/flume

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);

代码示例来源:origin: miltonio/milton2

@Override
  public void sessionCreated(IoSession session) throws Exception {
    log.info("Session created...");
    ((SocketSessionConfig) session.getConfig()).setReceiveBufferSize(2048);
    ((SocketSessionConfig) session.getConfig()).setIdleTime(IdleStatus.BOTH_IDLE, 10);
    PopSession sess = new PopSession(session, resourceFactory);
    session.setAttribute("stateMachine", sess);
  }
}

代码示例来源:origin: youtongluan/sumk

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, AppInfo.getInt("soa.session.idle", 60 * 5));
if (SocketSessionConfig.class.isInstance(acceptor.getSessionConfig())) {
  SocketSessionConfig conf = (SocketSessionConfig) acceptor.getSessionConfig();

代码示例来源:origin: Red5/red5-websocket

sessionConf.setIdleTime(IdleStatus.BOTH_IDLE, idleTimeout);

代码示例来源:origin: org.codehaus.fabric3/fabric3-ftp-server

/**
 * Starts the FTP server.
 *
 * @throws IOException If unable to start the FTP server.
 */
@Init
public void start() throws IOException {
  InetSocketAddress socketAddress;
  if (listenAddress == null) {
    socketAddress = new InetSocketAddress(InetAddress.getLocalHost(), commandPort);
  } else {
    socketAddress = new InetSocketAddress(listenAddress, commandPort);
  }
  acceptor = new NioSocketAcceptor();
  SocketSessionConfig config = acceptor.getSessionConfig();
  config.setIdleTime(IdleStatus.BOTH_IDLE, idleTimeout);
  acceptor.getFilterChain().addLast("threadPool", new ExecutorFilter(executorService));
  acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(codecFactory));
  acceptor.setHandler(ftpHandler);
  acceptor.bind(socketAddress);
  monitor.startFtpListener(commandPort);
}

代码示例来源:origin: org.apache.flume/flume-ng-core

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);

代码示例来源:origin: jzyong/game-server

@Override
  public void run() {
    DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
    chain.addLast("codec", new HttpServerCodecImpl());
    // // 线程队列池
    OrderedThreadPoolExecutor threadpool = new OrderedThreadPoolExecutor(minaServerConfig.getOrderedThreadPoolExecutorSize());
    chain.addLast("threadPool", new ExecutorFilter(threadpool));
    acceptor.setReuseAddress(minaServerConfig.isReuseAddress()); // 允许地址重用
    SocketSessionConfig sc = acceptor.getSessionConfig();
    sc.setReuseAddress(minaServerConfig.isReuseAddress());
    sc.setReceiveBufferSize(minaServerConfig.getMaxReadSize());
    sc.setSendBufferSize(minaServerConfig.getSendBufferSize());
    sc.setTcpNoDelay(minaServerConfig.isTcpNoDelay());
    sc.setSoLinger(minaServerConfig.getSoLinger());
    sc.setIdleTime(IdleStatus.READER_IDLE, minaServerConfig.getReaderIdleTime());
    sc.setIdleTime(IdleStatus.WRITER_IDLE, minaServerConfig.getWriterIdleTime());
    acceptor.setHandler(ioHandler);
    try {
      acceptor.bind(new InetSocketAddress(minaServerConfig.getHttpPort()));
      LOG.warn("已开始监听HTTP端口:{}", minaServerConfig.getHttpPort());
    } catch (IOException e) {
      SysUtil.exit(getClass(), e, "监听HTTP端口:{}已被占用", minaServerConfig.getHttpPort());
    }
  }
}

代码示例来源:origin: org.drools/drools-grid-core

public synchronized void start() throws IOException {
  acceptor.getFilterChain().addLast( "logger",
                    new LoggingFilter() );
  acceptor.getFilterChain().addLast( "codec",
                    new ProtocolCodecFilter( new ObjectSerializationCodecFactory() ) );
  acceptor.getSessionConfig().setReadBufferSize( 2048 );
  acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE,
                       10 );
  acceptor.bind( address );
}

代码示例来源:origin: jzyong/game-server

sc.setTcpNoDelay(minaServerConfig.isTcpNoDelay());
sc.setSoLinger(minaServerConfig.getSoLinger());
sc.setIdleTime(IdleStatus.READER_IDLE, minaServerConfig.getReaderIdleTime());
sc.setIdleTime(IdleStatus.WRITER_IDLE, minaServerConfig.getWriterIdleTime());

代码示例来源:origin: r17171709/android_demo

private PushManager() {
  connector=new NioSocketConnector();
  connector.setConnectTimeoutMillis(Params.CONNECT_TIMEOUT);
  //为接收器设置管理服务
  connector.setHandler(new ClientSessionHandler());
  //设置过滤器(使用Mina提供的文本换行符编解码器)
  connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(),LineDelimiter.WINDOWS.getValue())));
  //读写通道5秒内无操作进入空闲状态
  connector.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, Params.REQUEST_TIMEOUT);
  //设置读取数据的缓冲区大小
  connector.getSessionConfig().setReadBufferSize(2048);
  //设置心跳
  KeepAliveMessageFactory heartBeatFactory = new ClientKeepAliveMessageFactoryImp();
  KeepAliveRequestTimeoutHandler heartBeatHandler = new ClientKeepAliveMessageTimeoutFactoryImp();
  KeepAliveFilter heartBeat = new KeepAliveFilter(heartBeatFactory, IdleStatus.BOTH_IDLE, heartBeatHandler);
  //是否回发
  heartBeat.setForwardEvent(true);
  //心跳发送频率
  heartBeat.setRequestInterval(Params.REQUEST_INTERVAL);
  connector.getSessionConfig().setKeepAlive(true);
  connector.getFilterChain().addLast("keepalive", heartBeat);
}

代码示例来源:origin: org.apache.ftpserver/ftpserver-core

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,
    getIdleTimeout());

代码示例来源:origin: miltonio/milton2

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,
    getIdleTimeout());

相关文章