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

NioSocketAcceptor.setHandler介绍

暂无

代码示例

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

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
acceptor.setHandler(new MultiportSyslogHandler(maxEventSize, batchSize,
  getChannelProcessor(), sourceCounter, portHeader, clientIPHeader,
  clientHostnameHeader, defaultDecoder, portCharsets, keepFields));

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

socketAcceptor.setHandler( connectionHandler );
socketAcceptor.bind( new InetSocketAddress( configuration.getBindAddress(), configuration.getPort() ) );

代码示例来源：origin: jobxhub/JobX

@Override
  public void run() {
    final MinaServerHandler serverHandler = new MinaServerHandler(handler);
    socketAddress = new InetSocketAddress(port);
    acceptor = new NioSocketAcceptor();
    acceptor.getFilterChain().addLast("threadPool", new ExecutorFilter(Executors.newCachedThreadPool()));
    acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MinaCodecAdapter(Response.class, Request.class)));
    acceptor.setHandler(serverHandler);
    try {
      acceptor.bind(socketAddress);
      if (logger.isInfoEnabled()) {
        logger.info("[JobX] MinaServer start at address:{} success", port);
      }
    } catch (IOException e) {
      logger.error("[JobX] MinaServer start failure: {}", stackTrace(e));
    }
  }
});

代码示例来源：origin: org.eclipse.neoscada.core/org.eclipse.scada.core.server.ngp

public ServerBase ( final Collection<InetSocketAddress> addresses, final ProtocolConfigurationFactory protocolConfigurationFactory ) throws Exception
{
  this.addresses = addresses;
  this.acceptor = new NioSocketAcceptor ();
  this.acceptor.setReuseAddress ( true );
  this.chainBuilder = new FilterChainBuilder ( false );
  this.chainBuilder.setLoggerName ( ServerBase.class.getName () + ".protocol" );
  this.acceptor.setFilterChainBuilder ( this.chainBuilder );
  this.acceptor.setHandler ( new ServerBaseHandler ( this, protocolConfigurationFactory.createConfiguration ( false ) ) );
}

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

acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
acceptor.setHandler(new MultiportSyslogHandler(maxEventSize, batchSize,
  getChannelProcessor(), sourceCounter, portHeader, clientIPHeader,
  clientHostnameHeader, defaultDecoder, portCharsets, keepFields));

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

public void start() throws IOException {
  NioSocketAcceptor acceptor = new NioSocketAcceptor();
  DefaultIoFilterChainBuilder filterChainBuilder = new DefaultIoFilterChainBuilder();
  //filterChainBuilder.addLast("executorFilter", new OrderedThreadPoolExecutor());
  filterChainBuilder.addLast("xmppCodec", new ProtocolCodecFilter(new XMPPProtocolCodecFactory()));
  filterChainBuilder.addLast("loggingFilter", new StanzaLoggingFilter());
  acceptor.setFilterChainBuilder(filterChainBuilder);
  XmppIoHandlerAdapter adapter = new XmppIoHandlerAdapter();
  adapter.setServerRuntimeContext(serverRuntimeContext);
  acceptor.setHandler(adapter);
  acceptor.setReuseAddress(true);
  acceptor.bind(new InetSocketAddress(port));
  this.acceptor = acceptor;
}

代码示例来源：origin: com.synaptix/SynaptixServer

public void start() throws IOException {
  NioSocketAcceptor acceptor = new NioSocketAcceptor();
  DefaultIoFilterChainBuilder filterChainBuilder = new DefaultIoFilterChainBuilder();
  // filterChainBuilder.addLast("executorFilter", new OrderedThreadPoolExecutor());
  // filterChainBuilder.addLast("xmppCodec", new ProtocolCodecFilter(new XMPPProtocolCodecFactory()));
  filterChainBuilder.addLast("xmppCodec", new ProtocolCodecFilter(new SynaptixXMPPProtocolCodecFactory()));
  filterChainBuilder.addLast("loggingFilter", new StanzaLoggingFilter());
  acceptor.setFilterChainBuilder(filterChainBuilder);
  SynaptixXmppIoHandlerAdapter adapter = new SynaptixXmppIoHandlerAdapter();
  adapter.setServerRuntimeContext(serverRuntimeContext);
  acceptor.setHandler(adapter);
  acceptor.setReuseAddress(true);
  acceptor.bind(new InetSocketAddress(port));
  this.acceptor = acceptor;
}

代码示例来源：origin: com.github.mrstampy/esp

/**
 * Initialization of the broadcaster, to send
 * {@link AbstractMultiConnectionEvent}s to remote processes which have
 * registered for subscriptions. Invoke during object creation.
 *
 * @throws IOException Signals that an I/O exception has occurred.
 */
protected void initBroadCaster() throws IOException {
  socketBroadcaster = new NioSocketAcceptor();
  DefaultIoFilterChainBuilder chain = socketBroadcaster.getFilterChain();
  MdcInjectionFilter mdcInjectionFilter = new MdcInjectionFilter();
  chain.addLast("mdc", mdcInjectionFilter);
  if (log.isDebugEnabled()) chain.addLast("logger", new LoggingFilter());
  chain.addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
  socketBroadcaster.setHandler(getHandlerAdapter());
  socketBroadcaster.setReuseAddress(true);
  bindBroadcaster();
}

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

sc.setIdleTime(IdleStatus.WRITER_IDLE, minaServerConfig.getWriterIdleTime());
acceptor.setHandler(ioHandler);

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

socketAcceptor.setHandler( connectionHandler );
socketAcceptor.bind( new InetSocketAddress( configuration.getBindAddress(), configuration.getPort() ) );

代码示例来源：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: com.bbossgroups.rpc/bboss-rpc

acceptor.setHandler(handler);

代码示例来源：origin: io.termd/termd-core

acceptor.setHandler(new IoHandlerAdapter() {
  @Override
  public void messageReceived(IoSession session, Object message) throws Exception {

代码示例来源：origin: termd/termd

acceptor.setHandler(new IoHandlerAdapter() {
  @Override
  public void messageReceived(IoSession session, Object message) throws Exception {

代码示例来源：origin: com.alibaba.middleware/termd-core

acceptor.setHandler(new IoHandlerAdapter() {
  @Override
  public void messageReceived(IoSession session, Object message) throws Exception {