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

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

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

NioSocketAcceptor.<init>介绍

[英]Constructor for NioSocketAcceptor using default parameters (multiple thread model).
[中]使用默认参数（多线程模型）的NioSocketAcceptor构造函数。

代码示例

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

acceptor = new NioSocketAcceptor(ioThreads);
} else {
  acceptor = new NioSocketAcceptor(executor, pool);

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

acceptor = new NioSocketAcceptor(numProcessors);
} else {
 acceptor = new NioSocketAcceptor();

代码示例来源：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: ltsopensource/light-task-scheduler

@Override
protected void serverStart() throws RemotingException {
  acceptor = new NioSocketAcceptor(); //TCP Acceptor
  // acceptor.getFilterChain().addFirst("logging", new MinaLoggingFilter());
  acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MinaCodecFactory(getCodec())));
  acceptor.getFilterChain().addLast("mdc", new MdcInjectionFilter());
  acceptor.setHandler(new MinaHandler(this));
  IoSessionConfig cfg = acceptor.getSessionConfig();
  cfg.setReaderIdleTime(remotingServerConfig.getReaderIdleTimeSeconds());
  cfg.setWriterIdleTime(remotingServerConfig.getWriterIdleTimeSeconds());
  cfg.setBothIdleTime(remotingServerConfig.getServerChannelMaxIdleTimeSeconds());
  bindAddress = new InetSocketAddress(remotingServerConfig.getListenPort());
  try {
    acceptor.bind(bindAddress);
  } catch (IOException e) {
    throw new RemotingException("Start Mina server error", e);
  }
}

代码示例来源：origin: ltsopensource/light-task-scheduler

@Override
protected void serverStart() throws RemotingException {
  acceptor = new NioSocketAcceptor(); //TCP Acceptor
  // acceptor.getFilterChain().addFirst("logging", new MinaLoggingFilter());
  acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MinaCodecFactory(getCodec())));
  acceptor.getFilterChain().addLast("mdc", new MdcInjectionFilter());
  acceptor.setHandler(new MinaHandler(this));
  IoSessionConfig cfg = acceptor.getSessionConfig();
  cfg.setReaderIdleTime(remotingServerConfig.getReaderIdleTimeSeconds());
  cfg.setWriterIdleTime(remotingServerConfig.getWriterIdleTimeSeconds());
  cfg.setBothIdleTime(remotingServerConfig.getServerChannelMaxIdleTimeSeconds());
  bindAddress = new InetSocketAddress(remotingServerConfig.getListenPort());
  try {
    acceptor.bind(bindAddress);
  } catch (IOException e) {
    throw new RemotingException("Start Mina server error", e);
  }
}

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

/**
 * @param minaServerConfig 配置
 * @param ioHandler 消息处理器
 */
public TcpServer(MinaServerConfig minaServerConfig, IoHandler ioHandler) {
  this.minaServerConfig = minaServerConfig;
  this.ioHandler = ioHandler;
  acceptor = new NioSocketAcceptor();
}

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

public HttpServer(MinaServerConfig minaServerConfig, HttpServerIoHandler ioHandler) {
  this.minaServerConfig = minaServerConfig;
  this.ioHandler = ioHandler;
  acceptor = new NioSocketAcceptor();
}

代码示例来源：origin: stackoverflow.com

IoAcceptor acceptor = new NioSocketAcceptor();
     acceptor.getFilterChain().addLast("logger", new LoggingFilter());
     acceptor.getFilterChain().addLast(
         "codec",
         new ProtocolCodecFilter(new TextLineCodecFactory(Charset
             .forName("ISO-8859-1"))));
 @Override
   public void messageReceived(IoSession session, Object message)
       throws Exception {
 byte[] b = new byte[100];
 b =  message.toString().getBytes(Charset.forName("ISO-8859-1"));// Read Binary Message
 }

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

public static IoAcceptor createIoAcceptor(int transportType) {
  if (transportType == SOCKET) {
    NioSocketAcceptor ret = new NioSocketAcceptor();
    ret.setReuseAddress(true);
    return ret;
  } else if (transportType == VM_PIPE) {
    return new VmPipeAcceptor();
  } else {
    throw new RuntimeError("Unsupported transport type: " + transportType);
  }
}

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

public static IoAcceptor createIoAcceptor(int transportType) {
  if (transportType == SOCKET) {
    NioSocketAcceptor ret = new NioSocketAcceptor();
    ret.setReuseAddress(true);
    return ret;
  } else if (transportType == VM_PIPE) {
    return new VmPipeAcceptor();
  } else {
    throw new RuntimeError("Unsupported transport type: " + transportType);
  }
}

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

public static IoAcceptor createIoAcceptor(int transportType) {
  if (transportType == SOCKET) {
    NioSocketAcceptor ret = new NioSocketAcceptor();
    ret.setReuseAddress(true);
    return ret;
  } else if (transportType == VM_PIPE) {
    return new VmPipeAcceptor();
  } else {
    throw new RuntimeError("Unsupported transport type: " + transportType);
  }
}

代码示例来源：origin: kingston-csj/jforgame

public void start(int port) throws Exception {
  this.port = port;
  acceptor = new NioSocketAcceptor();
  acceptor.getFilterChain().addLast("codec", new HttpServerCodec());
  acceptor.setHandler(new HttpServerHandle());
  acceptor.bind(new InetSocketAddress(port));
  logger.error("---------> http server start at port:{}", port);
}

代码示例来源：origin: kingston-csj/jforgame

public void start() throws Exception {
  acceptor = new NioSocketAcceptor();
  acceptor.getFilterChain().addLast("codec", new HttpServerCodec());
  acceptor.setHandler(new HttpServerHandle());
  acceptor.bind(new InetSocketAddress(port));
}

代码示例来源：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.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: 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: Keybo1013/mina

public static void main(String[] args) throws IOException {
    IoAcceptor acceptor = new NioSocketAcceptor();
//        acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, IDELTIMEOUT);

    acceptor.getFilterChain().addLast("logger", new LoggingFilter());
    acceptor.getFilterChain().addLast("myfliter", new MyFilter());
    acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new CommandCodecFactory("UTF-8")));

    KeepAliveMessageFactoryImpl kamfi = new KeepAliveMessageFactoryImpl();
    KeepAliveFilter kaf = new KeepAliveFilter(kamfi, IdleStatus.BOTH_IDLE);
    /** 是否回发 */
    kaf.setForwardEvent(true);
    acceptor.getFilterChain().addLast("heart", kaf);

    acceptor.setHandler(new CalculatorHandler());
    acceptor.bind(new InetSocketAddress(PORT));

    log.debug("socket通信服务端已启动，端口是" + PORT);
  }

代码示例来源：origin: org.jbpm/jbpm-human-task-mina

public void start() throws IOException {
  
  acceptor = new NioSocketAcceptor();
  acceptor.getFilterChain().addLast( "logger",
                    new LoggingFilter() );
  acceptor.getFilterChain().addLast( "codec",
                    new ProtocolCodecFilter( new ObjectSerializationCodecFactory() ) );
  acceptor.setHandler( handler );
  acceptor.getSessionConfig().setReadBufferSize( 2048 );
  acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
  ((SocketSessionConfig) acceptor.getSessionConfig()).setSoLinger(0);
  acceptor.bind( new InetSocketAddress( localInterface, port ) );
  running = true;
}

代码示例来源：origin: OpenNMS/opennms

/**
 * <p>startServer</p>
 *
 * @throws java.lang.Exception if any.
 */
public void startServer() throws Exception {
  
  m_acceptor = new NioSocketAcceptor();
  m_acceptor.getFilterChain().addLast("logger", new LoggingFilter());
  m_acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(StandardCharsets.UTF_8)));
  
  m_acceptor.setHandler(getServerHandler());
  m_acceptor.getSessionConfig().setReadBufferSize(getBufferSize());
  m_acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, getIdleTime());
  ((NioSocketAcceptor) m_acceptor).setReuseAddress(true);
  m_acceptor.bind(new InetSocketAddress(getPort()));
  
}

内容来源于网络，如有侵权，请联系作者删除！

NioSocketAcceptor

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com