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

NioSocketAcceptor.getFilterChain介绍

暂无

代码示例

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

filter.setEnabledProtocols(getFilteredProtocols(sslParameters));
 filter.setEnabledCipherSuites(getFilteredCipherSuites(sslParameters));
 acceptor.getFilterChain().addFirst("ssl", filter);
});

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

final DefaultIoFilterChainBuilder filterChain = socketAcceptor.getFilterChain();

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

final DefaultIoFilterChainBuilder filterChain = socketAcceptor.getFilterChain();
filterChain.addFirst( ConnectionManagerImpl.EXECUTOR_FILTER_NAME, executorFilter );

代码示例来源：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.apache.flume/flume-ng-core

filter.setEnabledProtocols(getFilteredProtocols(sslParameters));
 filter.setEnabledCipherSuites(getFilteredCipherSuites(sslParameters));
 acceptor.getFilterChain().addFirst("ssl", filter);
});

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

acceptor.getFilterChain().addLast("SSL", sslFilter);
acceptor.getFilterChain().addLast("protocol", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
DefaultIoFilterChainBuilder filterChainBuilder = acceptor.getFilterChain();

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

final DefaultIoFilterChainBuilder filterChain = socketAcceptor.getFilterChain();

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

if (!isRunning) {
  isRunning = true;
  DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
  if (factory == null) {
    factory = new DefaultProtocolCodecFactory();

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

final DefaultIoFilterChainBuilder filterChain = socketAcceptor.getFilterChain();
filterChain.addFirst( ConnectionManagerImpl.EXECUTOR_FILTER_NAME, executorFilter );

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