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

NioSocketConnector.<init>介绍

[英]Constructor for NioSocketConnector with default configuration (multiple thread model).
[中]具有默认配置（多线程模型）的NioSocketConnector的构造函数。

代码示例

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

IoConnector connector = new NioSocketConnector();
connector.setHandler(this);
ConnectFuture future = connector.connect(forward);

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

@Override
protected void clientStart() throws RemotingException {
  try {
    connector = new NioSocketConnector(); //TCP Connector
    // connector.getFilterChain().addFirst("logging", new MinaLoggingFilter());
    connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MinaCodecFactory(getCodec())));
    connector.getFilterChain().addLast("mdc", new MdcInjectionFilter());
    connector.setHandler(new MinaHandler(this));
    IoSessionConfig cfg = connector.getSessionConfig();
    cfg.setReaderIdleTime(remotingClientConfig.getReaderIdleTimeSeconds());
    cfg.setWriterIdleTime(remotingClientConfig.getWriterIdleTimeSeconds());
    cfg.setBothIdleTime(remotingClientConfig.getClientChannelMaxIdleTimeSeconds());
  } catch (Exception e) {
    throw new RemotingException("Mina Client start error", e);
  }
}

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

@Override
protected void clientStart() throws RemotingException {
  try {
    connector = new NioSocketConnector(); //TCP Connector
    // connector.getFilterChain().addFirst("logging", new MinaLoggingFilter());
    connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MinaCodecFactory(getCodec())));
    connector.getFilterChain().addLast("mdc", new MdcInjectionFilter());
    connector.setHandler(new MinaHandler(this));
    IoSessionConfig cfg = connector.getSessionConfig();
    cfg.setReaderIdleTime(remotingClientConfig.getReaderIdleTimeSeconds());
    cfg.setWriterIdleTime(remotingClientConfig.getWriterIdleTimeSeconds());
    cfg.setBothIdleTime(remotingClientConfig.getClientChannelMaxIdleTimeSeconds());
  } catch (Exception e) {
    throw new RemotingException("Mina Client start error", e);
  }
}

代码示例来源：origin: com.github.kmbulebu.dsc/dsc-it100-library

/**
 * Use a TCP connection for remotely connecting to the IT-100.
 * 
 * Typically used with a utility such as ser2net for connecting to a remote serial port.
 * @param host Hostname or IP address of the remote device.
 * @param port TCP port of the remote device.
 * @return This builder instance.
 */
public ConfigurationBuilder withRemoteSocket(String host, int port) {
  configuration.connector = new NioSocketConnector();
  configuration.address = new InetSocketAddress(host, port);
  return this;
}

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

public static IoConnector createIoConnector(SocketAddress address) throws ConfigError {
    if (address instanceof InetSocketAddress) {
      return new NioSocketConnector();
    } else if (address instanceof VmPipeAddress) {
      return new VmPipeConnector();
    } else {
      throw new ConfigError("Unknown session acceptor address type: "
          + address.getClass().getName());
    }
  }
}

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

public static IoConnector createIoConnector(SocketAddress address) throws ConfigError {
    if (address instanceof InetSocketAddress) {
      return new NioSocketConnector();
    } else if (address instanceof VmPipeAddress) {
      return new VmPipeConnector();
    } else {
      throw new ConfigError("Unknown session acceptor address type: "
          + address.getClass().getName());
    }
  }
}

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

public static IoConnector createIoConnector(SocketAddress address) throws ConfigError {
    if (address instanceof InetSocketAddress) {
      return new NioSocketConnector();
    } else if (address instanceof VmPipeAddress) {
      return new VmPipeConnector();
    } else {
      throw new ConfigError("Unknown session acceptor address type: "
          + address.getClass().getName());
    }
  }
}

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

public boolean connect(String address, int port) {
  this.connector = new NioSocketConnector();
  this.address = new InetSocketAddress( address, port );
  this.connector.setHandler( this.handler );
  return connect();
}

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

private static final NioSocketConnector getSocketConnector(long timeout, IoHandler handler) {
  NioSocketConnector connector = new NioSocketConnector();
  connector.setHandler(handler);
  connector.setConnectTimeoutMillis(timeout);
  return connector;
}

代码示例来源：origin: org.apache.sshd/sshd-mina

protected IoConnector createConnector() {
  NioSocketConnector connector = new NioSocketConnector(ioProcessor);
  configure(connector.getSessionConfig());
  return connector;
}

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

/**
 * 初始化tcp连接
 * @param clientProtocolHandler
 */
private void init(IoHandler clientProtocolHandler) {
  connector = new NioSocketConnector();
  DefaultIoFilterChainBuilder chain = connector.getFilterChain();
  chain.addLast("codec", codecFilter);
  if(filters != null){
    filters.forEach((key, filter)->{
      if("ssl".equalsIgnoreCase(key) || "tls".equalsIgnoreCase(key)){	//ssl过滤器必须添加到首部
        chain.addFirst(key, filter);
      }else{
        chain.addLast(key, filter);
      }
    });
  }
  connector.setHandler(clientProtocolHandler);
  connector.setConnectTimeoutMillis(60000L);
  connector.setConnectTimeoutCheckInterval(10000);
}

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

private NioSocketConnector createConnector(CountDownLatch authenticatedLatch) {
  NioSocketConnector connector = new NioSocketConnector();
  DefaultIoFilterChainBuilder filterChainBuilder = new DefaultIoFilterChainBuilder();
  filterChainBuilder.addLast("xmppCodec", new ProtocolCodecFilter(new XMPPProtocolCodecFactory()));
  filterChainBuilder.addLast("loggingFilter", new StanzaLoggingFilter());
  connector.setFilterChainBuilder(filterChainBuilder);
  connector.setHandler(new ConnectorIoHandler(authenticatedLatch));
  return connector;
}

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

@Override
public void connect(Request request) {
  if (connector == null) {
    connector = new NioSocketConnector();
    connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MinaCodecAdapter(Request.class, Response.class)));
    connector.setHandler(new MinaClientHandler(this));
    connector.setConnectTimeoutMillis(5000);
    DefaultSocketSessionConfig sessionConfiguration = (DefaultSocketSessionConfig) connector.getSessionConfig();
    sessionConfiguration.setTcpNoDelay(true);
    sessionConfiguration.setKeepAlive(true);
    sessionConfiguration.setWriteTimeout(5);
  }
}
@Override

代码示例来源：origin: tangyanbo/springmore

/**
 * 初始化
 * 
 * @author 唐延波
 * @date 2015-6-24
 */
private void init() {
  // 设置连接参数
  connector = new NioSocketConnector();
  connector.setConnectTimeoutMillis(connectTimeoutMillis);
  connector.getFilterChain().addLast("logger", new LoggingFilter());
  //设置读缓冲,传输的内容必须小于此缓冲
  connector.getSessionConfig().setReadBufferSize(readBufferSize);
  
  if(protocolCodecFactory != null){
    connector.getFilterChain().addLast("codec",
        new ProtocolCodecFilter(protocolCodecFactory));
  }        
  ShortClientHandler clientHandler = new ShortClientHandler();		
  connector.setHandler(clientHandler);
}

代码示例来源：origin: cuihp/AndroidServer

@Override
public void run() {
  mAddress = new InetSocketAddress(mConfig.getIp(), mConfig.getPort());
  mConnection = new NioSocketConnector();
  mConnection.getSessionConfig().setReadBufferSize(mConfig.getReadBufferSize());
  mConnection.getFilterChain().addLast("logger", new LoggingFilter());
  mConnection.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
  mConnection.setConnectTimeoutMillis(mConfig.getConnectionTimeout());
  mConnection.setHandler(new ClientHandler());
  mConnection.setDefaultRemoteAddress(mAddress);
  reConnect();
}

代码示例来源：origin: tangyanbo/springmore

/**
 * 初始化
 * 
 * @author 唐延波
 * @date 2015-6-24
 */
private void init() {
  // 设置连接参数
  connector = new NioSocketConnector();
  connector.setConnectTimeoutMillis(connectTimeoutMillis);
  connector.getFilterChain().addLast("logger", new LoggingFilter());
  //设置读缓冲,传输的内容必须小于此缓冲
  connector.getSessionConfig().setReadBufferSize(readBufferSize);
  
  if(protocolCodecFactory != null){
    connector.getFilterChain().addLast("codec",
        new ProtocolCodecFilter(protocolCodecFactory));
  }        
  LongClientHandler clientHandler = new LongClientHandler();
  
  connector.setHandler(clientHandler);
  initConnection(poolSize);
}

代码示例来源：origin: com.bbossgroups.rpc/bboss-rpc

public ClinentTransport(RPCAddress rpcaddress, boolean dummy)
{
  this.host = rpcaddress.getIp();
  this.port = rpcaddress.getPort();
  this.rpcaddress = rpcaddress;
  this.dummy = dummy;
  connector = new NioSocketConnector();
  connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
  connector.setConnectTimeoutMillis(MinaRPCServer.getMinaRPCServer().getCONNECT_TIMEOUT());
  connector.setHandler(new DummyIOHandler());
  // scheduler = Executors.newScheduledThreadPool(1);
  // ScheduledThreadPoolExecutor scheduler = new
  // ScheduledThreadPoolExecutor
  // (Runtime.getRuntime().availableProcessors());
  // filter = new RequestResponseFilter(new RPCRequestInterceptor(),
  // scheduler);
  // connector.getFilterChain().addLast("reqres", filter);
  this.connect();
}

代码示例来源：origin: Fanping/iveely.search

public AsynClient(String ipAddress, int port, IHandler handler) {
 this.ipAddress = ipAddress;
 this.port = port;
 this.handler = handler;
 this.connector = new NioSocketConnector();
 this.connector.setConnectTimeout(DEFAULT_CONNECT_TIMEOUT);
 LoggingFilter loggingFilter = new LoggingFilter();
 loggingFilter.setSessionClosedLogLevel(LogLevel.NONE);
 loggingFilter.setSessionCreatedLogLevel(LogLevel.NONE);
 loggingFilter.setSessionOpenedLogLevel(LogLevel.NONE);
 loggingFilter.setMessageSentLogLevel(LogLevel.NONE);
 loggingFilter.setMessageReceivedLogLevel(LogLevel.NONE);
 this.connector.getFilterChain().addLast("logger", loggingFilter);
 this.connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(
   new PacketCodecFactory()));
 this.connector.setHandler(new InnerHanlder());
}

代码示例来源：origin: r17171709/android_demo

private PushManager() {
  connector=new NioSocketConnector();
  connector.setConnectTimeoutMillis(Params.CONNECT_TIMEOUT);
  //为接收器设置管理服务
  connector.setHandler(new ClientSessionHandler());
  //设置过滤器（使用Mina提供的文本换行符编解码器）
  connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(),LineDelimiter.WINDOWS.getValue())));
  //读写通道5秒内无操作进入空闲状态
  connector.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, Params.REQUEST_TIMEOUT);
  //设置读取数据的缓冲区大小
  connector.getSessionConfig().setReadBufferSize(2048);
  //设置心跳
  KeepAliveMessageFactory heartBeatFactory = new ClientKeepAliveMessageFactoryImp();
  KeepAliveRequestTimeoutHandler heartBeatHandler = new ClientKeepAliveMessageTimeoutFactoryImp();
  KeepAliveFilter heartBeat = new KeepAliveFilter(heartBeatFactory, IdleStatus.BOTH_IDLE, heartBeatHandler);
  //是否回发
  heartBeat.setForwardEvent(true);
  //心跳发送频率
  heartBeat.setRequestInterval(Params.REQUEST_INTERVAL);
  connector.getSessionConfig().setKeepAlive(true);
  connector.getFilterChain().addLast("keepalive", heartBeat);
}

代码示例来源：origin: com.github.ltsopensource/lts-core

@Override
protected void clientStart() throws RemotingException {
  try {
    connector = new NioSocketConnector(); //TCP Connector
    // connector.getFilterChain().addFirst("logging", new MinaLoggingFilter());
    connector.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MinaCodecFactory(getCodec())));
    connector.getFilterChain().addLast("mdc", new MdcInjectionFilter());
    connector.setHandler(new MinaHandler(this));
    IoSessionConfig cfg = connector.getSessionConfig();
    cfg.setReaderIdleTime(remotingClientConfig.getReaderIdleTimeSeconds());
    cfg.setWriterIdleTime(remotingClientConfig.getWriterIdleTimeSeconds());
    cfg.setBothIdleTime(remotingClientConfig.getClientChannelMaxIdleTimeSeconds());
  } catch (Exception e) {
    throw new RemotingException("Mina Client start error", e);
  }
}