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

NioSocketAcceptor.getSessionConfig介绍

暂无

代码示例

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

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

代码示例来源：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: igniterealtime/Openfire

socketAcceptor.getSessionConfig().setMaxReadBufferSize( configuration.getMaxBufferSize() );
Log.debug( "Throttling read buffer for connections to max={} bytes", configuration.getMaxBufferSize() );

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

socketAcceptor.getSessionConfig().setMaxReadBufferSize( configuration.getMaxBufferSize() );
Log.debug( "Throttling read buffer for connections to max={} bytes", configuration.getMaxBufferSize() );

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

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters (multiple thread model).
 */
public NioSocketAcceptor() {
  super(new DefaultSocketSessionConfig(), NioProcessor.class);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

/**
 *  Constructor for {@link NioSocketAcceptor} with default configuration but a
 *  specific {@link IoProcessor}, useful for sharing the same processor over multiple
 *  {@link IoService} of the same type.
 * @param processor the processor to use for managing I/O events
 */
public NioSocketAcceptor(IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

/**
 *  Constructor for {@link NioSocketAcceptor} with a given {@link Executor} for handling
 *  connection events and a given {@link IoProcessor} for handling I/O events, useful for
 *  sharing the same processor and executor over multiple {@link IoService} of the same type.
 * @param executor the executor for connection
 * @param processor the processor for I/O operations
 */
public NioSocketAcceptor(Executor executor, IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), executor, processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters, and
 * given number of {@link NioProcessor} for multithreading I/O operations.
 * 
 * @param processorCount the number of processor to create and place in a
 * {@link SimpleIoProcessorPool}
 */
public NioSocketAcceptor(int processorCount) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 *  Constructor for {@link NioSocketAcceptor} with a given {@link Executor} for handling
 *  connection events and a given {@link IoProcessor} for handling I/O events, useful for
 *  sharing the same processor and executor over multiple {@link IoService} of the same type.
 * @param executor the executor for connection
 * @param processor the processor for I/O operations
 */
public NioSocketAcceptor(Executor executor, IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), executor, processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters, and
 * given number of {@link NioProcessor} for multithreading I/O operations, and
 * a custom SelectorProvider for NIO
 *
 * @param processorCount the number of processor to create and place in a
 * @param selectorProvider teh SelectorProvider to use
 * {@link SimpleIoProcessorPool}
 */
public NioSocketAcceptor(int processorCount, SelectorProvider selectorProvider) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount, selectorProvider);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
  this.selectorProvider = selectorProvider;
}

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

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters, and
 * given number of {@link NioProcessor} for multithreading I/O operations.
 * 
 * @param processorCount the number of processor to create and place in a
 * {@link SimpleIoProcessorPool}
 */
public NioSocketAcceptor(int processorCount) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: kaazing/gateway

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters, and 
 * given number of {@link NioProcessor} for multithreading I/O operations.
 * 
 * @param processorCount the number of processor to create and place in a
 * {@link SimpleIoProcessorPool} 
 */
public NioSocketAcceptor(int processorCount) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters (multiple thread model).
 */
public NioSocketAcceptor() {
  super(new DefaultSocketSessionConfig(), NioProcessor.class);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 *  Constructor for {@link NioSocketAcceptor} with default configuration but a
 *  specific {@link IoProcessor}, useful for sharing the same processor over multiple
 *  {@link IoService} of the same type.
 * @param processor the processor to use for managing I/O events
 */
public NioSocketAcceptor(IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: kaazing/gateway

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters (multiple thread model).
 */
public NioSocketAcceptor() {
  super(new DefaultSocketSessionConfig(), NioProcessor.class);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: kaazing/gateway

/**
*  Constructor for {@link NioSocketAcceptor} with default configuration but a
 *  specific {@link IoProcessor}, useful for sharing the same processor over multiple
 *  {@link org.apache.mina.core.service.IoService} of the same type.
 * @param processor the processor to use for managing I/O events
 */
public NioSocketAcceptor(IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: kaazing/gateway

/**
 *  Constructor for {@link NioSocketAcceptor} with a given {@link Executor} for handling 
 *  connection events and a given {@link IoProcessor} for handling I/O events, useful for 
 *  sharing the same processor and executor over multiple {@link org.apache.mina.core.service.IoService} of the same type.
 * @param executor the executor for connection
 * @param processor the processor for I/O operations
 */
public NioSocketAcceptor(Executor executor, IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), executor, processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 * Constructor for {@link NioSocketAcceptor} using default parameters, and
 * given number of {@link NioProcessor} for multithreading I/O operations, and
 * a custom SelectorProvider for NIO
 *
 * @param processorCount the number of processor to create and place in a
 * @param selectorProvider teh SelectorProvider to use
 * {@link SimpleIoProcessorPool}
 */
public NioSocketAcceptor(int processorCount, SelectorProvider selectorProvider) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount, selectorProvider);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
  this.selectorProvider = selectorProvider;
}

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

protected IoAcceptor createAcceptor() {
  NioSocketAcceptor acceptor = new NioSocketAcceptor(ioProcessor);
  acceptor.setCloseOnDeactivation(false);
  acceptor.setReuseAddress(reuseAddress);
  acceptor.setBacklog(backlog);
  configure(acceptor.getSessionConfig());
  return acceptor;
}

代码示例来源：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());
    }
  }
}