org.eclipse.jetty.client.HttpClient.getMaxConnectionsPerDestination()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(3.4k)|赞(0)|评价(0)|浏览(116)

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

HttpClient.getMaxConnectionsPerDestination介绍

暂无

代码示例

代码示例来源:origin: org.eclipse.jetty/jetty-client

public HttpClientTransportOverHTTP(int selectors)
{
  super(selectors);
  setConnectionPoolFactory(destination -> new DuplexConnectionPool(destination, getHttpClient().getMaxConnectionsPerDestination(), destination));
}

代码示例来源:origin: com.ovea.tajin.server/tajin-server-jetty9

return result;
final int maxConnections = client.getMaxConnectionsPerDestination();
while (true)

代码示例来源:origin: org.eclipse.jetty.http2/http2-http-client-transport

public HttpClientTransportOverHTTP2(HTTP2Client client)
{
  this.client = client;
  setConnectionPoolFactory(destination ->
  {
    HttpClient httpClient = getHttpClient();
    return new MultiplexConnectionPool(destination, httpClient.getMaxConnectionsPerDestination(), destination, httpClient.getMaxRequestsQueuedPerDestination());
  });
}

代码示例来源:origin: com.ovea.tajin.servers/tajin-server-jetty9

return result;
final int maxConnections = client.getMaxConnectionsPerDestination();
while (true)

代码示例来源:origin: com.ovea.tajin.server/tajin-server-jetty9

public HttpDestination(HttpClient client, String scheme, String host, int port)
{
  this.client = client;
  this.scheme = scheme;
  this.host = host;
  this.address = new Address(host, port);
  int maxRequestsQueued = client.getMaxRequestsQueuedPerDestination();
  int capacity = Math.min(32, maxRequestsQueued);
  this.exchanges = new BlockingArrayQueue<>(capacity, capacity, maxRequestsQueued);
  int maxConnections = client.getMaxConnectionsPerDestination();
  capacity = Math.min(8, maxConnections);
  this.idleConnections = new BlockingArrayQueue<>(capacity, capacity, maxConnections);
  this.activeConnections = new BlockingArrayQueue<>(capacity, capacity, maxConnections);
  this.requestNotifier = new RequestNotifier(client);
  this.responseNotifier = new ResponseNotifier(client);
  ProxyConfiguration proxyConfig = client.getProxyConfiguration();
  proxyAddress = proxyConfig != null && proxyConfig.matches(host, port) ?
      new Address(proxyConfig.getHost(), proxyConfig.getPort()) : null;
  hostField = new HttpField(HttpHeader.HOST, host + ":" + port);
}

代码示例来源:origin: com.ovea.tajin.servers/tajin-server-jetty9

public HttpDestination(HttpClient client, String scheme, String host, int port)
{
  this.client = client;
  this.scheme = scheme;
  this.host = host;
  this.address = new Address(host, port);
  int maxRequestsQueued = client.getMaxRequestsQueuedPerDestination();
  int capacity = Math.min(32, maxRequestsQueued);
  this.exchanges = new BlockingArrayQueue<>(capacity, capacity, maxRequestsQueued);
  int maxConnections = client.getMaxConnectionsPerDestination();
  capacity = Math.min(8, maxConnections);
  this.idleConnections = new BlockingArrayQueue<>(capacity, capacity, maxConnections);
  this.activeConnections = new BlockingArrayQueue<>(capacity, capacity, maxConnections);
  this.requestNotifier = new RequestNotifier(client);
  this.responseNotifier = new ResponseNotifier(client);
  ProxyConfiguration proxyConfig = client.getProxyConfiguration();
  proxyAddress = proxyConfig != null && proxyConfig.matches(host, port) ?
      new Address(proxyConfig.getHost(), proxyConfig.getPort()) : null;
  hostField = new HttpField(HttpHeader.HOST, host + ":" + port);
}

相关文章

HttpClient类方法