Apache CXF负载平衡和故障转移

前一段时间，我们已经面临基于Apache CXF的负载平衡Web服务客户端的需求。 此外，当某些服务器关闭时，客户端应自动进行故障转移。 更糟糕的是，服务器目标地址列表要从外部服务获取并在运行时更新。

最终，我们最终获得了自己开发的负载平衡微库（ESB / UDDI / WS-Addressing似乎是一个有趣的替代方案，但在我们的情况下这是一个过大的选择）。 如果我们只知道Apache CXF已经（几乎）开箱即用地支持所有这些功能？

但是，不要怪我们，仅提及此功能会指向非常糟糕的文档页面（如果您将404称为“差”）。 如果不在正式文档中，我希望可以在Apache CXF Web服务开发书中找到它-不幸的是，那里也很不幸。 但是，嘿，您自己探索这些功能不是更有趣吗？ 这是我们开始的客户端配置： 
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:jaxws="http://cxf.apache.org/jaxws"xmlns:clustering="http://cxf.apache.org/clustering"xmlns:util="http://www.springframework.org/schema/util"><jaxws:client id="testServiceClient"serviceClass="com.blogspot.nurkiewicz.cxfcluster.SimpleService"address="http://serverA/simple"></jaxws:client></beans>
端点接口在这里并不重要，足以知道将testServiceClient注入到其他一些服务中，并且负载平衡和故障转移功能不应影响现有代码。 请注意，服务地址是固定的且经过硬编码的（当然可以将其外部化并在启动时读取）。
令人惊讶的是，仅启用故障转移是非常简单，直接和不言自明的（尽管是XML）： 
<jaxws:client id="testServiceClient"serviceClass="com.blogspot.nurkiewicz.cxfcluster.SimpleService"address="http://serverA/simple"><jaxws:features><clustering:failover><clustering:strategy><bean class="org.apache.cxf.clustering.RandomStrategy"><property name="alternateAddresses"><util:list><value>http://serverB/simple</value><value>http://serverC/simple</value><value>http://serverD/simple</value></util:list></property></bean></clustering:strategy></clustering:failover></jaxws:features></jaxws:client>
serverA地址用作主要端点，但是当它失败时， 将以随机顺序检查所有故障转移端点（ serverB ， serverC和serverD ）。 为了发挥这种配置的作用，我建议您打开Apache CXF请求和响应日志记录 ： 
<cxf:bus><cxf:features><cxf:logging/></cxf:features>
</cxf:bus>
再次（！），官方文档中没有提到非常方便的配置参数prettyLogging ，该参数可以应用于日志记录功能，以便在进行记录之前对XML请求和响应进行正确的格式化（ 换行和缩进）。 我不建议在生产设置中使用它，但是在开发和测试过程中，格式化SOAP消息是非常宝贵的： 
<bean id="abstractLoggingInterceptor" abstract="true"><property name="prettyLogging" value="true"/>
</bean>
<bean id="loggingInInterceptor" class="org.apache.cxf.interceptor.LoggingInInterceptor" parent="abstractLoggingInterceptor"/>
<bean id="loggingOutInterceptor" class="org.apache.cxf.interceptor.LoggingOutInterceptor" parent="abstractLoggingInterceptor"/><cxf:bus><cxf:inInterceptors><ref bean="loggingInInterceptor"/></cxf:inInterceptors><cxf:outInterceptors><ref bean="loggingOutInterceptor"/></cxf:outInterceptors><cxf:outFaultInterceptors><ref bean="loggingOutInterceptor"/></cxf:outFaultInterceptors><cxf:inFaultInterceptors><ref bean="loggingInInterceptor"/></cxf:inFaultInterceptors>
</cxf:bus>
因此，如果主要端点不可用，我们的服务很好地故障转移到备份端点。 但是我们有四个等效的服务器，我们希望我们的客户以相同的概率（轮循，随机？）平等地对待它们。 这是负载均衡进入阶段的时候： 
<jaxws:client id="testServiceClient" serviceClass="com.blogspot.nurkiewicz.cxfcluster.SimpleService"><jaxws:features><clustering:loadDistributor><clustering:strategy><bean class="org.apache.cxf.clustering.SequentialStrategy"><property name="alternateAddresses"><util:list><value>http://serverA/simple</value><value>http://serverB/simple</value><value>http://serverC/simple</value><value>http://serverD/simple</value></util:list></property></bean></clustering:strategy></clustering:loadDistributor></jaxws:features></jaxws:client>
请注意，客户端本身不再定义地址属性。 这表明， alternateAddresses列表仅在所有调用中使用，并且不存在主地址-实际上是这种情况。 SequentialStrategy将使用一个端点接另一个端点，以提供良好的循环实现（也提供RandomStrategy ）。 同样，在此配置中，您将免费获得故障转移–如果任何端点发生故障，将从第一个端点开始的所有端点都将受到检查（显然，刚刚发生故障的端点除外）。
大！ 现在，CXF客户端更加严格和容错。 但是，在我们追求更高可用性并最大程度地减少停机时间的过程中，仅在应用程序启动时才加载备用节点（换句话说，添加新服务器需要重新启动所有客户端）实在太过局限了。 幸运的是，我们可以通过两个简单的步骤使负载均衡更加动态。 
<jaxws:client id="testServiceClient" serviceClass="com.blogspot.nurkiewicz.cxfcluster.SimpleService"><jaxws:features><clustering:loadDistributor><clustering:strategy><bean class="org.apache.cxf.clustering.SequentialStrategy"><property name="alternateAddresses" ref="alternateAddresses"/></bean></clustering:strategy></clustering:loadDistributor></jaxws:features></jaxws:client><util:list id="alternateAddresses" list-class="java.util.concurrent.CopyOnWriteArrayList"><value>http://serverA/simple</value><value>http://serverB/simple</value><value>http://serverC/simple</value><value>http://serverD/simple</value>
</util:list>
没什么，提取嵌套的匿名bean。 但是可以访问此列表（请注意，我使用了java.util.concurrent.CopyOnWriteArrayList ）使我们可以将其注入任何其他服务，从而可能改变其状态。 我怎么知道这会起作用？ 好吧，我花了几天的时间调试Apache CXF，以最终发现负载平衡算法：第一次调用时，CXF要求策略提供可能节点的列表。 然后它会将这个列表返回策略要求到（在这里小编WTF ......）挑选一个战略决定哪些地址，使用和删除列表中挑选地址（另一个小一个在这里...）当CXF发现列表是空的，故事重复本身。 因此，如果我们在运行时替换备用地址列表，则一轮新列表将返回到核心CXF基础结构。
因为我是JMX的拥护者，所以这是我们修改地址列表的方法（您可以使用任何喜欢的机制）： 
@Service
@ManagedResource
public class AlternateAddressesManager {@Resourceprivate List alternateAddresses;@ManagedOperationpublic void addAlternateAddress(String address) {alternateAddresses.add(address);}@ManagedOperationpublic boolean removeAlternateAddress(String address) {return alternateAddresses.remove(address);}@ManagedAttributepublic List getAlternateAddresses() {return Collections.unmodifiableList(alternateAddresses);}}
是的，这是SequentialStrategy使用的非常相同的alternateAddresses列表，因此，只需对其进行修改，就可以更改CXF寻址行为。 可以说，我们可以扩展CopyOnWriteArrayList，添加一些额外的启用JMX的方法（或者，探索Springs的灵活性，直接通过JMX公开List方法！），但这会降低可维护性，我认为这是较差的设计。
最后，我们可以按照下面的屏幕快照启动jconsole或JVisualVM，并享受我们的负载平衡基础架构：
快乐？ 并不是的。 在研究CXF源代码时，我遇到了有关LoadDistributorFeature和FailoverTargetSelector类的可怕的JavaDoc注释，它们在负载平衡过程中起着重要的作用：
/ **
* […]
*请注意，此功能会即时更改导管，从而使
* 客户端不是线程安全的。
* /
重点放在粗体的文本上（好的，老实说，我不理解其余内容）。 如果您已经使用Spring一段时间，您就会知道testServiceClient bean是多个线程同时使用的共享单例（否，使其原型作用域无济于事；为什么？），这与默认的EJB无状态会话bean相反，被汇集。 幸运的是，Spring也有一个内置的解决方案。 但是，在我最终提出正确的解决方案之前，出现了一些障碍。
首先，来自CXF名称空间的jaxws：client标记不允许定义bean范围，默认情况下为单例，而我们要合并客户端。 因此，我不得不使用org.apache.cxf.jaxws.JaxWsProxyFactoryBean恢复到良好的旧bean定义。 没问题，稍微冗长些，尽管如果您不希望使用自定义Spring名称空间，则可能从一开始就使用它。 现在最好的部分是：我可以将具有原型范围的任何bean封装在特殊的代理中，Spring会自动创建一个对象池（基于commons-pool库），并根据需要创建尽可能多的bean实例，以使每个bean仅由一个使用。线。 配置如下： 
<bean id="testServiceClientFactoryBean" class="org.apache.cxf.jaxws.JaxWsProxyFactoryBean"><property name="serviceClass" value="com.blogspot.nurkiewicz.cxfcluster.SimpleService"/><property name="features"><util:list><bean class="org.apache.cxf.clustering.LoadDistributorFeature"><property name="strategy"><bean class="org.apache.cxf.clustering.SequentialStrategy"><property name="alternateAddresses" ref="alternateAddresses"/></bean></property></bean></util:list></property>
</bean><bean id="testServiceClientTarget" factory-bean="testServiceClientFactoryBean" factory-method="create" scope="prototype" lazy-init="true"/><bean id="testServiceClient" class="org.springframework.aop.framework.ProxyFactoryBean"><property name="targetSource"><bean class="org.springframework.aop.target.CommonsPoolTargetSource"><property name="targetClass" value="com.blogspot.nurkiewicz.cxfcluster.SimpleService"/><property name="targetBeanName" value="testServiceClientTarget"/><property name="maxSize" value="10"/><property name="maxWait" value="5000"/></bean></property>
</bean>
您是否注意到maxSize和maxWait池属性？ 他们真是太酷了 ！ 您可以告诉Spring在池中创建的客户端不要超过10个，并且如果池为空（当前正在使用所有Bean），则我们应该等待不超过5000毫秒（此后可以配置！）实际上是非常简单但功能强大的限制机制，比JMS或显式线程池简单得多，我们绝对免费！ 例如，不想服务超过20个并发Web服务客户端？ 使服务器端点访问服务Bean的大小限制为20。超过此限制的客户端将被拒绝，因为没有可用的服务Bean。
当然，在成人世界中，没有任何效果可以预期。 我很快发现JaxWsProxyFactoryBean.create不是线程安全的， 并报告了CXF-3558 。 作为解决方法，我必须通过将其 子类化 来同步 CommonsPoolTargetSource 使用的客户端工厂 ： 
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.PoolUtils;
import org.springframework.aop.target.CommonsPoolTargetSource;public class SynchCommonsPoolTargetSource extends CommonsPoolTargetSource {@Overrideprotected ObjectPool createObjectPool() {return PoolUtils.synchronizedPool(super.createObjectPool());}}
似乎需要同步工厂，因此我创建了SPR-8382-也许它将找到正式发行的方式。 顺便说一句，在撰写本文时，我还报告了IDEA-70365 – 报告了List类型bean的 虚假 “无法自动装配”错误 。
最后！ 我们的负载平衡和故障转移就像一个魅力。 下一步将是暂时丢弃掉了几秒钟的节点，如果此后端点仍然掉线，则增加此时间。 但是Apache CXF在这一领域的API如此糟糕，以至于我不得不离开这个话题一段时间。 也许您可以帮忙？

参考： NoBlogDefFound博客上的 JCG合作伙伴 Tomasz 在Apache CXF中启用负载平衡和故障转移 。

相关文章 ：
  • 带有Spring和Maven教程的JAX–WS
  • Spring3 RESTful Web服务
  • Tomcat 7上具有RESTeasy JAX-RS的RESTful Web服务-Eclipse和Maven项目

翻译自: https://www.javacodegeeks.com/2011/06/apache-cxf-load-balancing-failover.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/374778.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Java局部变量一定要赋初值

Java局部变量一定要赋初值

根据大佬文章https://blog.csdn.net/wjw521wjw521/article/details/79243596的理解而写的 1.类成员变量在 类加载 时会被系统赋初值&#xff0c;比如定义一个整型变量int num 系统默认num值为0 2.但是方法内的局部变量执行进栈操作&#xff0c;这个过程中系统不会赋初值&…
阅读更多...
隐式的类类型转换

隐式的类类型转换

如果构造函数只接受一个实参&#xff0c;则它实际上定义了转换为此类类型的隐式转换机制。将这种构造函数称为转换构造函数。 #ifndef MAIN_H_INCLUDED#define MAIN_H_INCLUDED#include<iostream>usingnamespace std;classClassTest{public:ClassTest(){ cout <<&q…
阅读更多...
负数的 %求余和取模

负数的 %求余和取模

1.求余和取模是不同的 2.‘%’ 在C/C&#xff0c;Java等语言中意为 求余 &#xff0c;在python 中意为 取模 3.a%b c 求余: c的符号和a一致 取模&#xff1a;c的符号和b一致 比如&#xff0c;一个小李子&#xff1a; public class Solution{public static void main(String…
阅读更多...
PAT-BASIC-1038-统计同成绩学生

PAT-BASIC-1038-统计同成绩学生

本题要求读入N名学生的成绩&#xff0c;将获得某一给定分数的学生人数输出。 输入格式&#xff1a; 输入在第1行给出不超过105的正整数N&#xff0c;即学生总人数。随后1行给出N名学生的百分制整数成绩&#xff0c;中间以空格分隔。最后1行给出要查询的分数个数K&#xff08;不…
阅读更多...
JavaScript事件处理的三种方式(转)

JavaScript事件处理的三种方式(转)

一、什么是JavaScript事件&#xff1f;事件(Event)是JavaScript应用跳动的心脏&#xff0c;也是把所有东西粘在一起的胶水&#xff0c;当我们与浏览器中Web页面进行某些类型的交互时&#xff0c;事件就发生了。 事件可能是用户在某些内容上的点击、鼠标经过某个特定元素或按下键…
阅读更多...
Erlang与Java内存架构

Erlang与Java内存架构

我读了一篇关于Erlang VM的内存管理策略的非常非常有趣的文章。 它是Jesper Wilhelmsson撰写的论文 &#xff0c;我认为讨论Erlang的内存设置和Oracle的Java VM之间的差异可能会很好。 作为对从未听说过Erlang的人的真正的简短介绍; 它是一种功能语言&#xff0c;使用异步消息传…
阅读更多...
Xuggler教程：转码和媒体修改

Xuggler教程：转码和媒体修改

注意&#xff1a;这是我们的“ Xuggler开发教程 ”系列的一部分。 在之前的教程中&#xff0c;我对视频处理Xuggler进行了简短介绍 。 在这一部分中&#xff0c;我们将看到Xuggler和FFmpeg提供的一些更令人兴奋的功能&#xff0c;例如视频转码和媒体修改。 不要忘记Xuggler是一…
阅读更多...
Web工程师必备的43款可视化工具

Web工程师必备的43款可视化工具

国外站点DATAVISUALIZATION.CH为大家总结出了当前热用的43款可视化工具&#xff0c;包括Arbor、Chroma.js、D3.js、Google Chart Tools等&#xff0c;绝对让你一饱眼福。 1.Arbor.js Arbor是一个免费的、可视化的图形库&#xff0c;基于矢量创建动态的连接图。它为图形组织和屏…
阅读更多...
力扣7. 整数反转

力扣7. 整数反转

方法一&#xff1a;官方给的&#xff0c;自己懂了后照着敲了一遍 class Solution {public int reverse(int x) {int rev 0;while (x ! 0) {//if判断条件过于复杂&#xff0c;我好不容易看懂了if (rev < Integer.MIN_VALUE / 10 || rev > Integer.MAX_VALUE / 10) {retu…
阅读更多...
AndroidManifest.xml中的application中的name属性

AndroidManifest.xml中的application中的name属性

被这个不起眼的属性折磨了一天&#xff0c;终于解决了。 由于项目需要&#xff0c;要合并两个android应用&#xff0c;于是拷代码&#xff0c;拷布局文件&#xff0c;拷values&#xff0c;所有的都搞定之后程序还是频频崩溃&#xff0c;一直没有找到原因&#xff0c;学android…
阅读更多...
完美单身

完美单身

我不时遇到一些Java程序员&#xff0c;他们不确定他们应该如何正确实现Singleton模式。 &#xff08;如果您不知道什么是Singleton&#xff0c;请尝试Wikipedia&#xff1a; Singleton模式 &#xff09;。 我并不是在谈论在线程环境中的正确实现。 但是&#xff0c;使用最常见的…
阅读更多...
力扣移动零

力扣移动零

给定一个数组 nums&#xff0c;编写一个函数将所有 0 移动到数组的末尾&#xff0c;同时保持非零元素的相对顺序。 我写的代码思路是从开始元素找0&#xff0c;找到了就将这个0后面的元素向前移一位 class Solution {public void moveZeroes(int[] nums) {int n nums.length;…
阅读更多...
Doclava：来自Google的自定义Javadoc Doclet

Doclava：来自Google的自定义Javadoc Doclet

Doclava是Google的自定义Javadoc Doclet&#xff0c;由Google Guice使用&#xff08;请参阅稍冷的 Javadocs &#xff09;。 Doclava使用JSilver作为其模板引擎&#xff0c;这是Clearsilver的纯Java实现。 我个人喜欢联合文档的想法&#xff0c;它允许文档在打开的项目上相互链…
阅读更多...
linux cat显示若干行

linux cat显示若干行

【一】从第3000行开始&#xff0c;显示1000行。即显示3000~3999行 cat filename | tail -n 3000 | head -n 1000 【二】显示1000行到3000行 cat filename| head -n 3000 | tail -n 1000 *注意两种方法的顺序 分解&#xff1a; tail -n 1000&#xff1a;显示最后1000行 tail -n …
阅读更多...
【Stackoverflow好问题】java在，如何推断阵列Array是否包括指定的值

【Stackoverflow好问题】java在，如何推断阵列Array是否包括指定的值

问题java中&#xff0c;怎样推断数组Array是否包括指定的值精华回答1.Arrays.asList(...).contains(...) 2.使用 Apache Commons Lang包中的ArrayUtils.containsString[] fieldsToInclude { "id", "name", "location" };if ( ArrayUtils.contai…
阅读更多...
力扣移除元素

力扣移除元素

给你一个数组 nums 和一个值 val&#xff0c;你需要 原地 移除所有数值等于 val 的元素&#xff0c;并返回移除后数组的新长度。 不要使用额外的数组空间&#xff0c;你必须仅使用 O(1) 额外空间并 原地 修改输入数组。 元素的顺序可以改变。你不需要考虑数组中超出新长度后面…
阅读更多...
在域驱动设计中使用状态模式

在域驱动设计中使用状态模式

域驱动设计&#xff08;DDD&#xff09;是一种软件开发方法&#xff0c;其中&#xff0c;通过将实现与核心业务概念的不断发展的模型相连接&#xff0c;可以解决问题的复杂性。 该术语是由Eric Evans创造的&#xff0c;并且有一个DDD专用站点可以促进其使用。 根据其定义&#…
阅读更多...
使用selenium进行密码破解（绕过账号密码JS加密）

使用selenium进行密码破解（绕过账号密码JS加密）

经常碰到网站&#xff0c;账号密码通过js加密后进行提交。通过burp拦截抓到的账号密码是加密后的&#xff0c;所以无法通过burp instruder进行破解。只能模拟浏览器填写表单并点击登录按钮进行破解。于是想到了自动化web测试工具selenium&#xff0c;代码如下&#xff0c;测试效…
阅读更多...
力扣删除排序数组中的重复项

力扣删除排序数组中的重复项

给你一个有序数组 nums &#xff0c;请你 原地 删除重复出现的元素&#xff0c;使每个元素 只出现一次 &#xff0c;返回删除后数组的新长度。 不要使用额外的数组空间&#xff0c;你必须在 原地 修改输入数组 并在使用 O(1) 额外空间的条件下完成。 我没注意到“有序”这一条…
阅读更多...
POJ1789-Truck History .

POJ1789-Truck History .

题目链接&#xff1a;http://poj.org/problem?id1789 题目的大概意思就是给你n个字符串。每个字符串只有7的长度。然后分别给这些字符串编号。不同编号之间的距离就是他们有多少个不同的字母。&#xff08;同一个位置字母不相同也算&#xff09;然后一个编号只能由另一个派生…
阅读更多...
最新文章

Copyright @ 2022~2023