如何验证 PoolingHttpClientConnectionManager 是否应用于球衣客户端

如何解决如何验证 PoolingHttpClientConnectionManager 是否应用于球衣客户端

以下是我用于 jersey 客户端连接池的代码片段。

ClientConfig clientConfig = new ClientConfig();
clientConfig.property(ClientProperties.CONNECT_TIMEOUT,defaultConnectTimeout);
clientConfig.property(ClientProperties.READ_TIMEOUT,defaultReadTimeout);
        
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
cm.setMaxTotal(50);
cm.setDefaultMaxPerRoute(5);
clientConfig.property(ApacheClientProperties.CONNECTION_MANAGER,cm);

clientConfig.connectorProvider(new ApacheConnectorProvider());

如何验证我的客户端是否正在使用连接池? poolStats.getAvailable() 计数是确定的有效方法吗?就我而言,当我测试客户端时,可用计数为 1。

解决方法

是的,计数可以是 1,但要确认您可以尝试以下步骤。

  1. 您可以先添加一个在后台继续运行的线程,并每隔一段时间打印一次 poolstats 的现有状态,比如每 60 秒一次。您可以使用以下逻辑。确保您在下面作为后台线程的一部分运行的逻辑代码中引用了相同的 PoolingHttpClientConnectionManager 对象实例。
  2. 然后,尝试使用上述 jersey 客户端继续调用内部调用外部服务的逻辑(可能处于 for 循环中)
  3. 您应该会看到不同的日志(在您的线程逻辑中)被打印出来,这将确认 jersey 客户端实际上正在使用池配置。

逻辑:

PoolStats poolStats = cm.getTotalStats();
        Set<HttpRoute> routes = cm.getRoutes();
        if(CollectionUtils.isNotEmpty(routes)) {
            for (HttpRoute route : routes) {
                PoolStats routeStats = poolingHttpClientConnectionManager.getStats(route);
                int routeAvailable = routeStats.getAvailable();
                int routeLeased = routeStats.getLeased();
                int routeIdle = (routeAvailable - routeLeased);
                log.info("Pool Stats for Route - Host = {},Available = {},Leased = {},Idle = {},Pending = {},Max = {} ",route.getTargetHost(),routeAvailable,routeLeased,routeIdle,poolStats.getPending(),poolStats.getMax());
            }
        }

        int available = poolStats.getAvailable();
        int leased = poolStats.getLeased();
        int idle = (available - leased);
        log.info("Pool Stats - Available = {},available,leased,idle,poolStats.getMax());

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?