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

SocketSessionConfig.setReadBufferSize介绍

暂无

代码示例

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

acceptor.getSessionConfig().setReadBufferSize(readBufferSize);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);

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

sessionConf.setTcpNoDelay(true);
sessionConf.setSendBufferSize(sendBufferSize);
sessionConf.setReadBufferSize(receiveBufferSize);

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

acceptor.getSessionConfig().setReadBufferSize(readBufferSize);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);

代码示例来源：origin: org.drools/drools-grid-core

public synchronized void start() throws IOException {
  acceptor.getFilterChain().addLast( "logger",
                    new LoggingFilter() );
  acceptor.getFilterChain().addLast( "codec",
                    new ProtocolCodecFilter( new ObjectSerializationCodecFactory() ) );
  acceptor.getSessionConfig().setReadBufferSize( 2048 );
  acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE,
                       10 );
  acceptor.bind( address );
}

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

acceptor.getSessionConfig().setReadBufferSize(2048);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,
    getIdleTimeout());

代码示例来源：origin: miltonio/milton2

acceptor.getSessionConfig().setReadBufferSize(2048);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE,
    getIdleTimeout());