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

Server.getMaxQueueSize介绍

[英]The maximum size of the rpc call queue of this server.
[中]此服务器的rpc调用队列的最大大小。

代码示例

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Test
public void testConfRpc() throws IOException {
 Server server = new RPC.Builder(conf).setProtocol(TestProtocol.class)
   .setInstance(new TestImpl()).setBindAddress(ADDRESS).setPort(0)
   .setNumHandlers(1).setVerbose(false).build();
 // Just one handler
 int confQ = conf.getInt(
      CommonConfigurationKeys.IPC_SERVER_HANDLER_QUEUE_SIZE_KEY,
      CommonConfigurationKeys.IPC_SERVER_HANDLER_QUEUE_SIZE_DEFAULT);
 assertEquals(confQ, server.getMaxQueueSize());
 int confReaders = conf.getInt(
      CommonConfigurationKeys.IPC_SERVER_RPC_READ_THREADS_KEY,
      CommonConfigurationKeys.IPC_SERVER_RPC_READ_THREADS_DEFAULT);
 assertEquals(confReaders, server.getNumReaders());
 server.stop();
 
 server = new RPC.Builder(conf).setProtocol(TestProtocol.class)
   .setInstance(new TestImpl()).setBindAddress(ADDRESS).setPort(0)
   .setNumHandlers(1).setnumReaders(3).setQueueSizePerHandler(200)
   .setVerbose(false).build();        
   
 assertEquals(3, server.getNumReaders());
 assertEquals(200, server.getMaxQueueSize());
 server.stop();    
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Test
public void testConfRpc() throws IOException {
 Server server = new RPC.Builder(conf).setProtocol(TestProtocol.class)
   .setInstance(new TestImpl()).setBindAddress(ADDRESS).setPort(0)
   .setNumHandlers(1).setVerbose(false).build();
 // Just one handler
 int confQ = conf.getInt(
      CommonConfigurationKeys.IPC_SERVER_HANDLER_QUEUE_SIZE_KEY,
      CommonConfigurationKeys.IPC_SERVER_HANDLER_QUEUE_SIZE_DEFAULT);
 assertEquals(confQ, server.getMaxQueueSize());
 int confReaders = conf.getInt(
      CommonConfigurationKeys.IPC_SERVER_RPC_READ_THREADS_KEY,
      CommonConfigurationKeys.IPC_SERVER_RPC_READ_THREADS_DEFAULT);
 assertEquals(confReaders, server.getNumReaders());
 server.stop();
 
 server = new RPC.Builder(conf).setProtocol(TestProtocol.class)
   .setInstance(new TestImpl()).setBindAddress(ADDRESS).setPort(0)
   .setNumHandlers(1).setnumReaders(3).setQueueSizePerHandler(200)
   .setVerbose(false).build();        
   
 assertEquals(3, server.getNumReaders());
 assertEquals(200, server.getMaxQueueSize());
 server.stop();    
}