org.apache.mina.transport.socket.nio.NioSocketAcceptor.setFilterChainBuilder()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(2.7k)|赞(0)|评价(0)|浏览(99)

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

NioSocketAcceptor.setFilterChainBuilder介绍

暂无

代码示例

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

相关文章