java.net.ServerSocket.setReceiveBufferSize()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(11.6k)|赞(0)|评价(0)|浏览(151)

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

ServerSocket.setReceiveBufferSize介绍

[英]Sets this socket's SocketOptions#SO_SNDBUF.
[中]设置此套接字的SocketOptions#SO#u SNDBUF。

代码示例

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

  1. @Override
  2. public ServerSocketChannelConfig setReceiveBufferSize(int receiveBufferSize) {
  3.   try {
  4.     javaSocket.setReceiveBufferSize(receiveBufferSize);
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8.   return this;
  9. }

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

  1. @Override
  2. public ServerSocketChannelConfig setReceiveBufferSize(int receiveBufferSize) {
  3.   try {
  4.     javaSocket.setReceiveBufferSize(receiveBufferSize);
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8.   return this;
  9. }

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

  1. @Override
  2. public ServerSocketChannelConfig setReceiveBufferSize(int receiveBufferSize) {
  3.   try {
  4.     javaSocket.setReceiveBufferSize(receiveBufferSize);
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8.   return this;
  9. }

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

  1. public NetJavaServerSocketImpl (Protocol protocol, String hostname, int port, ServerSocketHints hints) {
  2.   this.protocol = protocol;
  3.   // create the server socket
  4.   try {
  5.     // initialize
  6.     server = new java.net.ServerSocket();
  7.     if (hints != null) {
  8.       server.setPerformancePreferences(hints.performancePrefConnectionTime, hints.performancePrefLatency,
  9.         hints.performancePrefBandwidth);
  10.       server.setReuseAddress(hints.reuseAddress);
  11.       server.setSoTimeout(hints.acceptTimeout);
  12.       server.setReceiveBufferSize(hints.receiveBufferSize);
  13.     }
  14.     // and bind the server...
  15.     InetSocketAddress address;
  16.     if( hostname != null ) {
  17.       address = new InetSocketAddress(hostname, port); 
  18.     } else {
  19.       address = new InetSocketAddress(port);
  20.     }
  21.     
  22.     if (hints != null) {
  23.       server.bind(address, hints.backlog);
  24.     } else {
  25.       server.bind(address);
  26.     }
  27.   } catch (Exception e) {
  28.     throw new GdxRuntimeException("Cannot create a server socket at port " + port + ".", e);
  29.   }
  30. }

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

  1. public NetJavaServerSocketImpl (Protocol protocol, String hostname, int port, ServerSocketHints hints) {
  2.   this.protocol = protocol;
  3.   // create the server socket
  4.   try {
  5.     // initialize
  6.     server = new java.net.ServerSocket();
  7.     if (hints != null) {
  8.       server.setPerformancePreferences(hints.performancePrefConnectionTime, hints.performancePrefLatency,
  9.         hints.performancePrefBandwidth);
  10.       server.setReuseAddress(hints.reuseAddress);
  11.       server.setSoTimeout(hints.acceptTimeout);
  12.       server.setReceiveBufferSize(hints.receiveBufferSize);
  13.     }
  14.     // and bind the server...
  15.     InetSocketAddress address;
  16.     if( hostname != null ) {
  17.       address = new InetSocketAddress(hostname, port); 
  18.     } else {
  19.       address = new InetSocketAddress(port);
  20.     }
  21.     
  22.     if (hints != null) {
  23.       server.bind(address, hints.backlog);
  24.     } else {
  25.       server.bind(address);
  26.     }
  27.   } catch (Exception e) {
  28.     throw new GdxRuntimeException("Cannot create a server socket at port " + port + ".", e);
  29.   }
  30. }

代码示例来源：origin: io.netty/netty

  1. public void setReceiveBufferSize(int receiveBufferSize) {
  2.   try {
  3.     socket.setReceiveBufferSize(receiveBufferSize);
  4.   } catch (SocketException e) {
  5.     throw new ChannelException(e);
  6.   }
  7. }

代码示例来源：origin: loklak/loklak_server

  1. private static void checkServerPorts(int httpPort, int httpsPort) throws IOException{
  3.     // check http port
  4.     if(!httpsMode.equals(HttpsMode.ONLY)){
  5.       try (ServerSocket ss = new ServerSocket(httpPort)) {
  6.         ss.setReuseAddress(true);
  7.         ss.setReceiveBufferSize(65536);
  8.       } catch (IOException e) {
  9.         // the socket is already occupied by another service
  10.         throw new IOException("port " + httpPort + " is already occupied by another service, maybe another loklak is running on this port already. exit.");
  11.       }
  12.     }
  14.     // check https port
  15.     if(httpsMode.isGreaterOrEqualTo(HttpsMode.ON)){
  16.       try (ServerSocket sss = new ServerSocket(httpsPort)) {
  17.         sss.setReuseAddress(true);
  18.         sss.setReceiveBufferSize(65536);
  19.       } catch (IOException e) {
  20.         // the socket is already occupied by another service
  21.         throw new IOException("port " + httpsPort + " is already occupied by another service, maybe another loklak is running on this port already. exit.");
  22.       }
  23.     }
  24.   }
  25. }

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

  1. @Override
  2. protected void startInner() {
  3.   if(logger.isEnabledFor(Level.INFO))
  4.     logger.info("Starting Voldemort NIO socket server (" + serviceName + ") on port "
  5.           + port);
  6.   try {
  7.     for(int i = 0; i < selectorManagers.length; i++) {
  8.       selectorManagers[i] = new NioSelectorManager(endpoint,
  9.                              requestHandlerFactory,
  10.                              socketBufferSize,
  11.                              socketKeepAlive,
  12.                              selectorMaxHeartBeatTimeMs);
  13.       selectorManagerThreadPool.execute(selectorManagers[i]);
  14.     }
  15.     serverSocketChannel.socket().bind(endpoint, acceptorBacklog);
  16.     serverSocketChannel.socket().setReceiveBufferSize(socketBufferSize);
  17.     serverSocketChannel.socket().setReuseAddress(true);
  18.     acceptorThread.start();
  19.   } catch(Exception e) {
  20.     throw new VoldemortException(e);
  21.   }
  22.   enableJmx(this);
  23. }

代码示例来源：origin: TooTallNate/Java-WebSocket

  1. /**
  2.  * Setup the selector thread as well as basic server settings
  3.  * @return true, if everything was successful, false if some error happened
  4.  */
  5. private boolean doSetupSelectorAndServerThread() {
  6.   selectorthread.setName( "WebSocketSelector-" + selectorthread.getId() );
  7.   try {
  8.     server = ServerSocketChannel.open();
  9.     server.configureBlocking( false );
  10.     ServerSocket socket = server.socket();
  11.     socket.setReceiveBufferSize( WebSocketImpl.RCVBUF );
  12.     socket.setReuseAddress( isReuseAddr() );
  13.     socket.bind( address );
  14.     selector = Selector.open();
  15.     server.register( selector, server.validOps() );
  16.     startConnectionLostTimer();
  17.     onStart();
  18.   } catch ( IOException ex ) {
  19.     handleFatal( null, ex );
  20.     return false;
  21.   }
  22.   return true;
  23. }

代码示例来源：origin: jphp-group/jphp

  1. @Signature(@Arg("size"))
  2. public Memory setReceiveBufferSize(Environment env, Memory... args) throws SocketException {
  3.   socket.setReceiveBufferSize(args[0].toInteger());
  4.   return Memory.NULL;
  5. }

代码示例来源：origin: h2oai/h2o-2

  1. SOCK.socket().setReceiveBufferSize(AutoBuffer.BBSIZE);
  2. SOCK.socket().bind(H2O.SELF._key);

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

  1. public ServerSocket createServerSocket(int nport, int backlog, InetAddress bindAddr,
  2.   List<GatewayTransportFilter> transportFilters, int socketBufferSize) throws IOException {
  3.  if (transportFilters.isEmpty()) {
  4.   return createServerSocket(nport, backlog, bindAddr, socketBufferSize);
  5.  } else {
  6.   printConfig();
  7.   ServerSocket result = new TransportFilterServerSocket(transportFilters);
  8.   result.setReuseAddress(true);
  9.   // Set the receive buffer size before binding the socket so
  10.   // that large buffers will be allocated on accepted sockets (see
  11.   // java.net.ServerSocket.setReceiverBufferSize javadocs)
  12.   result.setReceiveBufferSize(socketBufferSize);
  13.   try {
  14.    result.bind(new InetSocketAddress(bindAddr, nport), backlog);
  15.   } catch (BindException e) {
  16.    BindException throwMe =
  17.      new BindException(String.format("Failed to create server socket on %s[%s]",
  18.        bindAddr, Integer.valueOf(nport)));
  19.    throwMe.initCause(e);
  20.    throw throwMe;
  21.   }
  22.   return result;
  23.  }
  24. }

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

  1. private void init() {
  2.   ServerSocketChannel socketChannel = processor.javaChannel();
  3.   ServerSocket javaSocket = socketChannel.socket();
  4.   try {
  5.     if (serverConfig.getReceiveBufferSize() != null) {
  6.       javaSocket.setReceiveBufferSize(serverConfig.getReceiveBufferSize());
  7.     }
  8.     if (serverConfig.getReuseAddress() != null) {
  9.       javaSocket.setReuseAddress(serverConfig.getReuseAddress());
  10.     }
  11.   } catch (SocketException e) {
  12.     throw new NioException("config channel error:" + e.getMessage(), e);
  13.   }
  14. }

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

  1. private void init() {
  2.   ServerSocketChannel socketChannel = processor.javaChannel();
  3.   ServerSocket javaSocket = socketChannel.socket();
  4.   try {
  5.     if (serverConfig.getReceiveBufferSize() != null) {
  6.       javaSocket.setReceiveBufferSize(serverConfig.getReceiveBufferSize());
  7.     }
  8.     if (serverConfig.getReuseAddress() != null) {
  9.       javaSocket.setReuseAddress(serverConfig.getReuseAddress());
  10.     }
  11.   } catch (SocketException e) {
  12.     throw new NioException("config channel error:" + e.getMessage(), e);
  13.   }
  14. }

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

  1. srvrCh.socket().setReceiveBufferSize(sockRcvBuf);

代码示例来源：origin: square/okio

  1. final ServerSocket serverSocket = new ServerSocket(0);
  2. serverSocket.setReuseAddress(true);
  3. serverSocket.setReceiveBufferSize(SOCKET_BUFFER_SIZE);

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

  1. protected AcceptingChannel<StreamConnection> createTcpConnectionServer(final InetSocketAddress bindAddress, final ChannelListener<? super AcceptingChannel<StreamConnection>> acceptListener, final OptionMap optionMap) throws IOException {
  2.   checkShutdown();
  3.   boolean ok = false;
  4.   final ServerSocketChannel channel = ServerSocketChannel.open();
  5.   try {
  6.     if (optionMap.contains(Options.RECEIVE_BUFFER)) channel.socket().setReceiveBufferSize(optionMap.get(Options.RECEIVE_BUFFER, -1));
  7.     channel.socket().setReuseAddress(optionMap.get(Options.REUSE_ADDRESSES, true));
  8.     channel.configureBlocking(false);
  9.     if (optionMap.contains(Options.BACKLOG)) {
  10.       channel.socket().bind(bindAddress, optionMap.get(Options.BACKLOG, 128));
  11.     } else {
  12.       channel.socket().bind(bindAddress);
  13.     }
  14.     if (false) {
  15.       final NioTcpServer server = new NioTcpServer(this, channel, optionMap);
  16.       server.setAcceptListener(acceptListener);
  17.       ok = true;
  18.       return server;
  19.     } else {
  20.       final QueuedNioTcpServer server = new QueuedNioTcpServer(this, channel, optionMap);
  21.       server.setAcceptListener(acceptListener);
  22.       ok = true;
  23.       return server;
  24.     }
  25.   } finally {
  26.     if (! ok) {
  27.       IoUtils.safeClose(channel);
  28.     }
  29.   }
  30. }

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

  1. public static ServerSocket createServerSocket(final int port, final ServerSocketConfiguration config)
  2.     throws IOException, KeyManagementException, UnrecoverableKeyException, NoSuchAlgorithmException, KeyStoreException, CertificateException {
  3.   if (config == null) {
  4.     throw new NullPointerException("Configuration may not be null.");
  5.   }
  6.   final SSLContext sslContext = config.createSSLContext();
  7.   final ServerSocket serverSocket;
  8.   if (sslContext == null) {
  9.     serverSocket = new ServerSocket(port);
  10.   } else {
  11.     serverSocket = sslContext.getServerSocketFactory().createServerSocket(port);
  12.     ((SSLServerSocket) serverSocket).setNeedClientAuth(config.getNeedClientAuth());
  13.   }
  14.   if (config.getSocketTimeout() != null) {
  15.     serverSocket.setSoTimeout(config.getSocketTimeout());
  16.   }
  17.   if (config.getReuseAddress() != null) {
  18.     serverSocket.setReuseAddress(config.getReuseAddress());
  19.   }
  20.   if (config.getReceiveBufferSize() != null) {
  21.     serverSocket.setReceiveBufferSize(config.getReceiveBufferSize());
  22.   }
  23.   return serverSocket;
  24. }

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

  1. public void open() throws Exception {
  2.   serverSocket = createServerSocket(target);
  3.   serverSocket.setReuseAddress(true);
  4.   if (receiveBufferSize > 0) {
  5.     serverSocket.setReceiveBufferSize(receiveBufferSize);
  6.   }
  7.   if (proxyUrl == null) {
  8.     serverSocket.bind(new InetSocketAddress(listenPort), acceptBacklog);
  9.     proxyUrl = urlFromSocket(target, serverSocket);
  10.   } else {
  11.     serverSocket.bind(new InetSocketAddress(proxyUrl.getPort()));
  12.   }
  13.   acceptor = new Acceptor(serverSocket, target);
  14.   if (pauseAtStart) {
  15.     acceptor.pause();
  16.   }
  17.   new Thread(null, acceptor, "SocketProxy-Acceptor-" + serverSocket.getLocalPort()).start();
  18.   closed = new CountDownLatch(1);
  19. }

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

  1. private void openSocket() throws IOException {
  2.   U.notNull(net.protocol(), "protocol");
  3.   U.notNull(net.helperClass(), "helperClass");
  4.   String blockingInfo = net.blockingAccept() ? "blocking" : "non-blocking";
  5.   Log.debug("Initializing server", "address", net.address(), "port", net.port(), "sync", net.syncBufs(), "accept", blockingInfo);
  6.   serverSocketChannel = ServerSocketChannel.open();
  7.   if ((serverSocketChannel.isOpen()) && (selector.isOpen())) {
  8.     serverSocketChannel.configureBlocking(net.blockingAccept());
  9.     ServerSocket socket = serverSocketChannel.socket();
  10.     Log.info("!Starting server", "!address", net.address(), "!port", net.port(), "I/O workers", net.workers(), "sync", net.syncBufs(), "accept", blockingInfo);
  11.     InetSocketAddress addr = new InetSocketAddress(net.address(), net.port());
  12.     socket.setReceiveBufferSize(16 * 1024);
  13.     socket.setReuseAddress(true);
  14.     socket.bind(addr, MAX_PENDING_CONNECTIONS);
  15.     Log.debug("Opened server socket", "address", addr);
  16.     if (!net.blockingAccept()) {
  17.       Log.debug("Registering accept selector");
  18.       serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
  19.     }
  20.     initWorkers();
  21.   } else {
  22.     throw U.rte("Cannot open socket!");
  23.   }
  24. }

内容来源于网络，如有侵权，请联系作者删除！

serversocket

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com