有什么专门做电子琴音乐的网站,wordpress母公司,阜平网站seo,网站文字规范正如我在上 一篇 文章中所讨论的那样 #xff0c;Spring Integration#xff08;SI#xff09; 是在Spring Framework之上构建的路由框架 #xff0c;它使您可以使用经过验证的企业集成模式来通过消息传递解决系统集成问题。 配置好SI并执行路由和中介逻辑后#xff0c;您… 正如我在上 一篇 文章中所讨论的那样 Spring IntegrationSI 是在Spring Framework之上构建的路由框架 它使您可以使用经过验证的企业集成模式来通过消息传递解决系统集成问题。 配置好SI并执行路由和中介逻辑后您可能会发现您想采取下一步措施并为解决方案增加更多的稳定性 。 您可能希望将某些路由中介或服务逻辑分布在多个主机上可能希望为通过SI通道传输的消息增加一些可靠性并且可能希望比采用传统的客户端-服务器体系结构。 好吧实现上述某些目标的一种方法是使用消息代理来支持您的SI路由。 SI为AMQP代理和JMS代理提供抽象。 在本文中我想使用Spring Integration Samples项目中的Cafe示例来说明如何使用流行的ActiveMQ消息代理通过JMS支持您的SI路由。 JMS是将现有Java解决方案与消息传递集成的好方法。 由于JMS规范是一个API因此无论您使用的是哪个代理都可以充分利用依赖于代理的接口。 您可以使用ActiveMQWebSphere MQ或任何其他符合JMS的消息代理。 在本示例中我选择ActiveMQ是因为它的成熟度健壮性在行业中的普遍性以及它是具有Apache许可的Apache Software Foundation的开源软件。 它完全实现了JMS 1.1提供了高可用性并且可以通过代理网络进行水平扩展。 如果要集成Java应用程序请坚持使用JMS。 ActiveMQ还为C CRubyPythonErlang和其他许多应用程序提供绑定 完整列表请参见其网站 注意AMQP也是可行的选择。 AMQP指定了一种线级协议该协议允许在不同平台和/或异构语言上构建的消息传递系统彼此进行互操作不只是可以使用JMS API的java / JVM。 Cafe演示已经实现了与Spring的RabbitMQ服务器Spring产品组合中的流行开源AMQP代理一起使用的AMQP实现。 有关AMQP和JMS之间区别的更多信息包括它们如何工作各自使用的不同术语以及两者的简要历史记录 请参阅Mark Richards Java消息服务书的作者之一 撰写的这篇出色的PDF文章。 来自OReilly 可以在我在github.com 上的Spring Integration Samples项目的分支版本中找到与该帖子相关的代码。 查看/ applications / cafe maven模块以获取我的代码。 使用点对点或发布-订阅JMS目标支持频道 在我的示例中我选择使用嵌入式代理 。 由于ActiveMQ是纯Java解决方案因此您可以将代理嵌入Java应用程序中并在内部使用它并允许外部客户端连接并参与消息传递。 这样做不会以任何方式限制您配置ActiveMQ的能力。 使用自己的嵌入式代理部署完整的集成解决方案要比依靠由另一个组或在外部配置外部实例更容易。 基于ActiveMQ的解决方案的所有spring配置文件可以在/ src / main / resources下的META-INF / spring / integration / activemq类路径中找到。 与支持具有JMS目标的SI通道有关的文件是cafeDemo-amq-config.xml和cafeDemo-amq-jms-backed.xml 。 cafeDemo-amq-config.xml文件负责配置与ActiveMQ代理的连接。 连接工厂的名称非常重要在本例中为“ connectionFactory”因为SI缺省情况下将查找具有该名称的bean以配置稍后由JMS支持的通道使用的目的地。 cafeDemo-amq-jms-backed.xml文件看起来与cafe示例的非经纪人实现 cafeDemo-xml.xml 非常相似不同之处在于通道已转换为JMS支持的版本并且ActiveMQ代理是嵌入其余配置。 请注意用于嵌入代理的方法允许在spring文件中进行完整配置。对于此示例不依赖于外部运行的代理。 这个小示例的配置仅设置了一个传输连接器在默认端口61616上我们可以使用vm// transport 但是我想显示一个使用TCP的示例并且未配置代理安全性目标策略但是它的确利用了现成的配置详细信息包括JMX管理MBean以及通过推荐并高度优化的KahaDB进行的消息持久性。 有关更多信息请参见ActiveMQ文档。 在原始配置中将用于“ coldDrinks”和“ hotDrinks”的通道设置为轮询通道。 要使用JMS目标完成此操作请将通道上的“消息驱动”属性设置为“ false”。 在这种情况下我们不需要提前声明目的地名称但是如果您想在目的地周围添加额外的安全性和授权属性则不妨在代理上或通过代理提前创建它们。 SI配置。 运行此样本的主要类是org.springframework.integration.samples.cafe.xml.CafeDemoActiveMQBackedChannels 。 观察是否确实在使用ActiveMQ的最佳方法是运行该示例并使用JConsole复审JMX服务器中的MBean。 在JConsole中您确实可以看到消息正在通过队列入队和出队和/或从主题中使用。 要测试使用ActiveMQ获得的鲁棒性请尝试运行示例并中途中止它。 然后注释掉主文件中添加订单到系统的行然后重新启动示例。 当异常终止时它将继续处理从其中断处开始的处理。 只需更改通道的几行配置即可获得可靠性和恢复能力。 如何在不同的服务器上或至少在同一JVM外部运行路由的不同部分呢 这使您可以添加路由的特定部分的更多实例以提高吞吐量和可伸缩性而无需进行任何代码更改其他优点。 只需将更多消费者吸引到队列/主题即可。 两种概念都可以在SI流程内仅使用SI通道使用也可以在其流程外使用JMS使用。 为了证明这一点我们将使用SI提供的JMS入站/出站网关和/或通道适配器。 使用JMS网关我们可以实现请求-答复消息交换而通道适配器则允许我们使用异步语义来激发和忘记。 该示例的设置方法与AMQP示例的设置方法相同它也依赖于外部运行的代理尽管我们可以如上所述嵌入它。 首先运行运行消费者CafeDemoAppBaristaColdActiveMQCafeDemoAppBaristaHotActiveMQ以监听冷饮或热饮订单。 接下来启动负责主要流程和业务流程的流程CafeDemoAppOperationsActiveMQ。 编排流程处理接单将订单分流将其路由到适当的服务上面的冷热咖啡Baristas然后处理响应并汇总以供服务员交付。 在这里您将看到正确设置的JMS网关。 最后您需要运行将订单发送到订单队列CafeDemoAppActiveMQ实际启动订单的过程。 所有这四个过程都彼此独立运行并且在必要时可以在单独的计算机上运行。 它们具有自己的应用程序上下文并且仅对ActiveMQ消息代理可见。 这是一个高度模块化且解耦的解决方案使用消息代理进行可靠的通信。 如上所述可以将代理配置为具有高可用性因此这不是故障点。 这种架构的优点 消息可靠性–消息代理存储和转发消息。 邮件最多只能发送一次。 如果代理崩溃以前未发送的消息将保留并且如果消费者没有收到则可以重新发送 灵活性–通过分离组件并依靠EIP您可以彼此独立维护包括部署增强功能等 限制或增加消息处理–组件在自己/独立的进程或盒子或世界各地运行您可以配置每个组件以消耗或限制消息具体取决于环境可以处理的数量 扩展–为了处理更高的吞吐量只需添加更多组件实例以侦听JMS目标 缺点 复杂性–将多个组件打包到一个流程中维护多个组件更为复杂 调试–复杂性增加调试困难。 异步过程天生就很难调试 看一下我的github repo中的Spring Integration示例 。 完整记录了用于配置ActiveMQ连接的应用程序上下文文件。 参考 Christian Posta软件博客中的JCG合作伙伴 Christian Posta从ActiveMQ支持Spring集成路由 。 翻译自: https://www.javacodegeeks.com/2012/05/backing-spring-integration-routes-with.html
