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

NioSocketAcceptor.bind介绍

暂无

代码示例

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

acceptor.bind(addr);
} catch (IOException ex) {
 logger.error("Could not bind to address: " + String.valueOf(addr), ex);

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

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

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

public Set<InetSocketAddress> start () throws IOException
{
  logger.info ( "Starting server for: {}", this.addresses );
  this.acceptor.bind ( this.addresses );
  return NetworkHelper.getLocalAddresses ( this.acceptor );
}

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

@Override
public void bindBroadcaster() throws IOException {
  if (!canBroadcast()) {
    log.warn("AbstractMultiConnectionSocket is not broadcasting events, cannot bind broadcaster");
    return;
  }
  if (socketBroadcaster.isActive()) {
    log.warn("AbstractMultiConnectionSocket is already bound");
    return;
  }
  socketBroadcaster.bind(new InetSocketAddress(AbstractSocketConnector.BROADCASTER_PORT));
  notifyConnectionEventListeners(State.BOUND);
}

代码示例来源：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

acceptor.bind(addr);
} catch (IOException ex) {
 logger.error("Could not bind to address: " + String.valueOf(addr), ex);

代码示例来源：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: jzyong/game-server

acceptor.bind(new InetSocketAddress(minaServerConfig.getPort()));
  log.warn("已开始监听TCP端口：{}", minaServerConfig.getPort());
} catch (IOException e) {

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

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.bind(new InetSocketAddress(PORT));

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

acceptor.bind(new InetSocketAddress(0));
echoPort = acceptor.getLocalAddress().getPort();
this.acceptor = acceptor;

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

acceptor.bind(new InetSocketAddress(0));
echoPort = acceptor.getLocalAddress().getPort();
this.acceptor = acceptor;

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

acceptor.bind(new InetSocketAddress(0));
echoPort = acceptor.getLocalAddress().getPort();
this.acceptor = acceptor;