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

NioSocketConnector.getSessionConfig介绍

暂无

代码示例

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

/**
 * Constructor for {@link NioSocketConnector} with default configuration (multiple thread model).
 */
public NioSocketConnector() {
  super(new DefaultSocketSessionConfig(), NioProcessor.class);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

/**
 *  Constructor for {@link NioSocketConnector} with default configuration but a
 *  specific {@link IoProcessor}, useful for sharing the same processor over multiple
 *  {@link IoService} of the same type.
 * @param processor the processor to use for managing I/O events
 */
public NioSocketConnector(IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

/**
 * Constructor for {@link NioSocketConnector} with default configuration, and
 * given number of {@link NioProcessor} for multithreading I/O operations
 * @param processorCount the number of processor to create and place in a
 * {@link SimpleIoProcessorPool}
 */
public NioSocketConnector(int processorCount) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

/**
 *  Constructor for {@link NioSocketConnector} with a given {@link Executor} for handling
 *  connection events and a given {@link IoProcessor} for handling I/O events, useful for sharing
 *  the same processor and executor over multiple {@link IoService} of the same type.
 * @param executor the executor for connection
 * @param processor the processor for I/O operations
 */
public NioSocketConnector(Executor executor, IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), executor, processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 * Constructor for {@link NioSocketConnector} with default configuration, and
 * given number of {@link NioProcessor} for multithreading I/O operations
 * @param processorCount the number of processor to create and place in a
 * {@link SimpleIoProcessorPool}
 */
public NioSocketConnector(int processorCount) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: kaazing/gateway

/**
 *  Constructor for {@link NioSocketConnector} with default configuration but a
 *  specific {@link IoProcessor}, useful for sharing the same processor over multiple
 *  {@link IoService} of the same type.
 * @param processor the processor to use for managing I/O events
 */
public NioSocketConnector(IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 *  Constructor for {@link NioSocketConnector} with default configuration but a
 *  specific {@link IoProcessor}, useful for sharing the same processor over multiple
 *  {@link IoService} of the same type.
 * @param processor the processor to use for managing I/O events
 */
public NioSocketConnector(IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: kaazing/gateway

/**
 * Constructor for {@link NioSocketConnector} with default configuration, and 
 * given number of {@link NioProcessor} for multithreading I/O operations
 * @param processorCount the number of processor to create and place in a
 * {@link SimpleIoProcessorPool} 
 */
public NioSocketConnector(int processorCount) {
  super(new DefaultSocketSessionConfig(), NioProcessor.class, processorCount);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 * Constructor for {@link NioSocketConnector} with default configuration (multiple thread model).
 */
public NioSocketConnector() {
  super(new DefaultSocketSessionConfig(), NioProcessor.class);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: org.apache.directory.api/api-ldap-client-all

/**
 *  Constructor for {@link NioSocketConnector} with a given {@link Executor} for handling
 *  connection events and a given {@link IoProcessor} for handling I/O events, useful for sharing
 *  the same processor and executor over multiple {@link IoService} of the same type.
 * @param executor the executor for connection
 * @param processor the processor for I/O operations
 */
public NioSocketConnector(Executor executor, IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), executor, processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

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

代码示例来源：origin: kaazing/gateway

/**
 * Constructor for {@link NioSocketConnector} with default configuration (multiple thread model).
 */
public NioSocketConnector() {
  super(new DefaultSocketSessionConfig(), NioProcessor.class);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

代码示例来源：origin: kaazing/gateway

/**
 *  Constructor for {@link NioSocketConnector} with a given {@link Executor} for handling 
 *  connection events and a given {@link IoProcessor} for handling I/O events, useful for sharing 
 *  the same processor and executor over multiple {@link IoService} of the same type.
 * @param executor the executor for connection
 * @param processor the processor for I/O operations
 */
public NioSocketConnector(Executor executor, IoProcessor<NioSession> processor) {
  super(new DefaultSocketSessionConfig(), executor, processor);
  ((DefaultSocketSessionConfig) getSessionConfig()).init(this);
}

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

/**
 * 设置连接配置
 * @param minaClientConfig
 */
public void setMinaClientConfig(MinaClientConfig minaClientConfig) {
  if (minaClientConfig == null) {
    return;
  }
  this.minaClientConfig = minaClientConfig;
  SocketSessionConfig sc = connector.getSessionConfig();
  maxConnectCount = minaClientConfig.getMaxConnectCount();
  sc.setReceiveBufferSize(minaClientConfig.getReceiveBufferSize()); // 524288
  sc.setSendBufferSize(minaClientConfig.getSendBufferSize()); // 1048576
  sc.setMaxReadBufferSize(minaClientConfig.getMaxReadSize()); // 1048576
  factory.getDecoder().setMaxReadSize(minaClientConfig.getMaxReadSize());
  sc.setSoLinger(minaClientConfig.getSoLinger()); // 0
}

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