国内最专业的IT技术学习网

UI设计

当前位置:主页 > 亚博2018体育博彩 >

利用Kafka设置可靠的高性能分布式消息传递基础架

发布时间:2019/09/12标签:   应用程序    点击量:

原标题:利用Kafka设置可靠的高性能分布式消息传递基础架
天下曾经迈进"挪动"时期,当初利用顺序必需可能及时供给数据,这不只包含数据库表中存储的主要终极成果,还包含用户应用利用顺序时履行的全部操纵。任何可用信息,比方,用户点击量、日记数据或传感器数据都可用于改良用户休会、天生讲演、向呆板进修体系供给数据,等等。现现在,开辟者必需存眷基于及时变乱流的体系。下图展现了基于变乱流处置的架构示例。利用Kafka设置可靠的高性能分布式消息传递基础架构Apache Kafka 已成为构建基于变乱的高度可扩大体系的首选处理计划。Kafka 可为变乱流平台供给疾速进级换代的功效,以供开辟者在古代化营业处理计划中应用。但是,开辟者平日须要将现有 Java EE 营业处理计划(基于 IBM MQ 或 IBM WebSphere Application Platform 之类的技巧而构建的)集成到这些新的变乱流架构中。斟酌以下示例: 某个网上市肆领有一个挪动利用顺序,该利用顺序应用 Kafka 向企业 Java 中实行的散布式付出体系发送付出恳求数据。该处理计划必需相对保障一次性实现付出恳求的处置(幸免屡次向买家免费)。然而,在散布式体系中,毛病是弗成幸免的,因而该处理计划须要采纳稳当的方法来处置毛病。应用 Apache Kafka 实行新闻通报Apache Kafka 是一种用于变乱流处置的散布式体系,普遍利用于微效劳架构和基于云的情况中。它在统一个平台内供给变乱的新闻通报、存储和处置。下图展现了 Apache Kafka 组件的基础拓扑,此中包含经过 Kafka 集群基本架构交流新闻的出产者和应用者。利用Kafka设置可靠的高性能分布式消息传递基础架构即便 Kafka 存在诸多上风,但 Kafka 仍面对以下成绩: 新闻处置失利时须要实行手动弥补逻辑,这能够招致无奈处置新闻 不支撑 XA 事件处置 确保在应用者利用顺序中仅履行一次托付处置 须要实现额定的开辟和可保护性任务才干将其集成到企业处理计划中要处理 Kafka 集成成绩,您能够利用传统新闻通报拓扑观点,比方,事件日记、规复日记和 XA 事件。 您能够实行基于 Java EE Connector Architecture (JCA) 的资本适配器。应用此 JCA 资本适配器,您能够为利用顺序效劳器供给 ACID 功效,以便停止 Kafka 新闻处置。此 JCA 资本适配器随后可供给与企业 Java 利用顺序的无缝 Kafka 集成。实行 JCA 资本适配器Java EE Connector Architecture 可界说一组可扩大且非常保险的事件性机制。您能够将 JCA 资本适配器装置到兼容 Java EE 的恣意利用顺序效劳器中,比方,IBM Websphere Application Server、IBM Business Process Manager、JBoss、WebSphere Liberty、Glassfish 或 Weblogic。Java EE Connector Architecture 标准还供给了一组尺度合约,用于支撑企业利用顺序与企业信息体系(如 Kafka)之间的通讯。JCA 资本适配器能够拔出到利用顺序效劳器,可经过处置全部体系级其余机制(事件、衔接治理、瓦解规复、过错跟踪和日记记载)来支撑 Kafka 集成。JCA 资本适配器将对须要与之集成的企业利用顺序暗藏全部 Kafka 通讯逻辑。经过实行 JCA 资本适配器,企业利用顺序供给商能够会合精神实行营业和演示逻辑,而无需担忧与 Kafka 集成相干的初级别逻辑。因而,JCA 资本适配器只要开辟一次,便可供种种利用顺序复用。让咱们将它与网上市肆付出场景接洽起来,观看下图,它展现了指定的处理计划体系高低文。

上一篇:怎么解决Linux LVM I/O报错

下一篇:没有了

返回
版权信息Copyright ? 银河官网 版权所有??? ICP备案编号:鲁ICP备09013610号