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

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

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

SocketSessionConfig.setTcpNoDelay介绍

暂无

代码示例

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

/** {@inheritDoc} */
@Override
public void sessionOpened(IoSession session) throws Exception {
  SocketSessionConfig ssc = (SocketSessionConfig) session.getConfig();
  ssc.setTcpNoDelay(true);
  super.sessionOpened(session);
}

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

sessionConf.setTcpNoDelay(tcpNoDelay);
sessionConf.setSendBufferSize(sendBufferSize);

代码示例来源:origin: igniterealtime/Openfire

private static NioSocketAcceptor buildSocketAcceptor()
{
  // Create SocketAcceptor with correct number of processors
  final int processorCount = JiveGlobals.getIntProperty( "xmpp.processor.count", Runtime.getRuntime().availableProcessors() );
  final NioSocketAcceptor socketAcceptor = new NioSocketAcceptor( processorCount );
  // Set that it will be possible to bind a socket if there is a connection in the timeout state.
  socketAcceptor.setReuseAddress( true );
  // Set the listen backlog (queue) length. Default is 50.
  socketAcceptor.setBacklog( JiveGlobals.getIntProperty( "xmpp.socket.backlog", 50 ) );
  // Set default (low level) settings for new socket connections
  final SocketSessionConfig socketSessionConfig = socketAcceptor.getSessionConfig();
  //socketSessionConfig.setKeepAlive();
  final int receiveBuffer = JiveGlobals.getIntProperty( "xmpp.socket.buffer.receive", -1 );
  if ( receiveBuffer > 0 )
  {
    socketSessionConfig.setReceiveBufferSize( receiveBuffer );
  }
  final int sendBuffer = JiveGlobals.getIntProperty( "xmpp.socket.buffer.send", -1 );
  if ( sendBuffer > 0 )
  {
    socketSessionConfig.setSendBufferSize( sendBuffer );
  }
  final int linger = JiveGlobals.getIntProperty( "xmpp.socket.linger", -1 );
  if ( linger > 0 )
  {
    socketSessionConfig.setSoLinger( linger );
  }
  socketSessionConfig.setTcpNoDelay( JiveGlobals.getBooleanProperty( "xmpp.socket.tcp-nodelay", socketSessionConfig.isTcpNoDelay() ) );
  return socketAcceptor;
}

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

sessionConf.setTcpNoDelay(true);
sessionConf.setSendBufferSize(sendBufferSize);
sessionConf.setReadBufferSize(receiveBufferSize);

代码示例来源:origin: org.apache.directory.server/apacheds-protocol-ldap

acceptor.getSessionConfig().setTcpNoDelay( true );

代码示例来源:origin: quickfix-j/quickfixj

socketSessionConfig.setTcpNoDelay(tcpNoDelay);

代码示例来源:origin: org.igniterealtime.openfire/xmppserver

private static NioSocketAcceptor buildSocketAcceptor()
{
  // Create SocketAcceptor with correct number of processors
  final int processorCount = JiveGlobals.getIntProperty( "xmpp.processor.count", Runtime.getRuntime().availableProcessors() );
  final NioSocketAcceptor socketAcceptor = new NioSocketAcceptor( processorCount );
  // Set that it will be possible to bind a socket if there is a connection in the timeout state.
  socketAcceptor.setReuseAddress( true );
  // Set the listen backlog (queue) length. Default is 50.
  socketAcceptor.setBacklog( JiveGlobals.getIntProperty( "xmpp.socket.backlog", 50 ) );
  // Set default (low level) settings for new socket connections
  final SocketSessionConfig socketSessionConfig = socketAcceptor.getSessionConfig();
  //socketSessionConfig.setKeepAlive();
  final int receiveBuffer = JiveGlobals.getIntProperty( "xmpp.socket.buffer.receive", -1 );
  if ( receiveBuffer > 0 )
  {
    socketSessionConfig.setReceiveBufferSize( receiveBuffer );
  }
  final int sendBuffer = JiveGlobals.getIntProperty( "xmpp.socket.buffer.send", -1 );
  if ( sendBuffer > 0 )
  {
    socketSessionConfig.setSendBufferSize( sendBuffer );
  }
  final int linger = JiveGlobals.getIntProperty( "xmpp.socket.linger", -1 );
  if ( linger > 0 )
  {
    socketSessionConfig.setSoLinger( linger );
  }
  socketSessionConfig.setTcpNoDelay( JiveGlobals.getBooleanProperty( "xmpp.socket.tcp-nodelay", socketSessionConfig.isTcpNoDelay() ) );
  return socketAcceptor;
}

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.quickfix

socketSessionConfig.setTcpNoDelay(tcpNoDelay);

代码示例来源:origin: org.quickfixj/quickfixj-all

socketSessionConfig.setTcpNoDelay(tcpNoDelay);

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

sc.setReceiveBufferSize(minaServerConfig.getReceiveBufferSize());
sc.setSendBufferSize(minaServerConfig.getSendBufferSize());
sc.setTcpNoDelay(minaServerConfig.isTcpNoDelay());
sc.setSoLinger(minaServerConfig.getSoLinger());
sc.setIdleTime(IdleStatus.READER_IDLE, minaServerConfig.getReaderIdleTime());

代码示例来源: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.apache.directory.server/apacheds-protocol-dns

( ( NioSocketAcceptor ) acceptor ).getSessionConfig().setTcpNoDelay( true );

代码示例来源:origin: org.apache.directory.server/apacheds-protocol-ntp

( ( SocketAcceptor ) acceptor ).getSessionConfig().setTcpNoDelay( true );

代码示例来源:origin: org.apache.sshd/sshd-mina

if (boolVal != null) {
  try {
    config.setTcpNoDelay(boolVal);
  } catch (RuntimeIoException t) {
    handleConfigurationError(config, FactoryManager.TCP_NODELAY, boolVal, t);

相关文章