Language:
Format:

第 3 章企业级集成模式简介

摘要

Apache Camel 的 企业集成模式通过 Gregor Hohpe 和 Bobby Woolf 编写的书写。这些作者描述的模式为开发企业集成项目提供了一个卓越的 toolbox。除了提供讨论集成架构的通用语言外，许多模式可直接使用 Apache Camel 的编程界面和 XML 配置来实施。

3.1. Patterns 概述

企业级集成模式书

Apache Camel 支持书本中的大多数模式，即 Gregor Hohpe 和 Bobby Woolf 的 Enterprise Integration Patterns。

消息传递系统

表 3.1 “消息传递系统” 中显示的消息传递系统模式介绍了组成消息传递系统的基本概念和组件。

表 3.1. 消息传递系统

图标	名称	使用案例
	图 5.1 “消息模式”	邮件通道连接的两个应用程序如何交换信息？
	图 5.2 “Message Channel Pattern”	一个应用程序如何使用消息传递与另一个应用程序通信？
	图 5.3 “Message Endpoint Pattern”	应用程序如何连接到消息传递频道以发送和接收消息？
	图 5.4 “pipes 和 Filters Pattern”	我们可以如何对消息执行复杂的处理，同时仍然保持独立性和灵活性？
	图 5.7 “Message Router Pattern”	您可以如何分离单独的处理步骤，以便可以根据一组定义的条件将消息传递给不同的过滤器？
	图 5.8 “Message Translator Pattern”	如何使用不同数据格式的系统使用消息传递相互通信？

消息传递频道

消息传递频道是连接消息传递系统中的参与者的基本组件。表 3.2 “消息传递频道” 中的模式描述了可用的不同类型的消息频道。

表 3.2. 消息传递频道

图标	名称	使用案例
	图 6.1 “指向点频道模式”	调用者如何确保精确的一个接收器接收文档或执行调用？
	图 6.2 “发布 Subscribe Channel Pattern”	发件人如何将事件广播到所有感兴趣的接收器？
	图 6.3 “死的频道模式”	消息传递系统与无法发送的消息有什么作用？
	图 6.4 “保证交付模式”	发件人如何确保要发送消息，即使消息传递系统失败也是如此？
	图 6.5 “消息总线模式”	哪个架构使分离应用程序可以协同工作，以便在不影响其他应用程序的情况下添加或删除一个或多个应用程序？

消息构建

消息构建模式（如表 3.3 “消息构建” 所示）描述了通过系统传递的信息的各种形式和功能。

表 3.3. 消息构建

图标	名称	使用案例
	“概述”一节	请求者如何识别生成接收回复的请求？
	第 7.3 节 “返回地址”	replier 如何知道回复在哪里？

消息路由

消息路由模式（在表 3.4 “消息路由” 所示）描述了将消息通道连接各种方法，包括可应用于消息流的各种算法（无需修改消息正文）。

表 3.4. 消息路由

图标	名称	使用案例
	第 8.1 节 “基于内容的路由器”	我们如何处理单一逻辑功能的实施（例如清单检查）到多个物理系统时？
	第 8.2 节 “Message Filter”	组件如何避免接收不必要的消息？
	第 8.3 节 “接收者列表”	如何将消息路由到动态指定收件人列表？
	第 8.4 节 “Splitter”	如果消息包含多个元素，则我们可以处理一条消息，其中每个元素可能需要以不同的方式进行处理？
	第 8.5 节 “聚合器”	我们如何组合单个结果，但相关消息以便可以作为一个整体进行处理？
	第 8.6 节 “Resequencer”	我们可以如何把相关的消息流返回至正确的顺序？
	第 8.14 节 “由消息处理器”	在处理由多个元素组成的消息时，您可以维护整个消息流，每个项可能需要不同的处理？
	第 8.15 节 “scatter-Gather”	当您需要向多个接收者发送消息时，如何维护整个消息流，每个都可能会发送回复？
	第 8.7 节 “路由 Slip”	在设计时不知道步骤时，我们如何连续通过一系列处理步骤来连续路由消息，每种消息可能会有所不同？
	第 8.8 节 “Throttler”	如何节流消息以确保特定端点不会超载，或者我们没有超出一些外部服务的 SLA？
	第 8.9 节 “Delayer”	如何延迟消息发送？
	第 8.10 节 “Load Balancer”	如何在多个端点之间平衡负载？
	第 8.11 节 “Hystrix”	在调用外部服务时，如何使用 Hystrix 断路器？Camel 2.18 中的新功能.
	第 8.12 节 “service Call”	如何在 registry 中查找该服务在分布式系统中调用远程服务？Camel 2.18 中的新功能.
	第 8.13 节 “多播”	如何同时将消息路由到多个端点？
	第 8.16 节 “loop”	如何在循环中重复处理消息？
	第 8.17 节 “sampling”	我该如何把给定时间段内的许多消息进行抽样，以避免超载下游路由？

消息转换

消息转换模式（如表 3.5 “消息转换” 所示）描述了如何根据不同的目的修改信息内容。

表 3.5. 消息转换

图标	名称	使用案例
	第 10.1 节 “内容增强器”	如果消息源器没有所有必需的数据项，我如何与另一个系统通信？
	第 10.2 节 “内容过滤器”	当您只对一些数据项目感兴趣时，您如何简化处理大量消息？
	第 10.4 节 “声明检查 EIP”	如何在不牺牲信息内容的情况下减少系统发送的消息量？
	第 10.3 节 “规范化程序”	您如何以其他格式格式处理语义等同的信息？
	第 10.5 节 “排序”	如何对邮件的正文进行排序？

消息传递端点

消息传递端点表示消息传递频道和应用程序之间的联系点。消息端点模式（如表 3.6 “消息传递端点” 所示）介绍了可以在端点上配置的各种功能和服务质量。

表 3.6. 消息传递端点

图标	名称	使用案例
	第 11.1 节 “消息传递映射程序”	您如何在域对象和消息传递基础架构之间移动数据，同时保持相互独立的这两个数据？
	第 11.2 节 “event Driven Consumer”	应用程序如何在消息可用时自动消耗消息？
	第 11.3 节 “polling Consumer”	应用程序如何在应用程序就绪时消耗消息？
	第 11.4 节 “竞争消费者”	消息传递客户端如何同时处理多个消息？
	第 11.5 节 “Message Dispatcher”	单个频道中的多个消费者如何协调其消息处理？
	第 11.6 节 “选择ive Consumer”	消息消费者如何选择希望接收的消息？
	第 11.7 节 “durable Subscriber”	在订阅者没有侦听它们时，如何避免缺少消息？
	第 11.8 节 “幂等的消费者”	邮件接收器如何处理重复的消息？
	第 11.9 节 “事务客户端”	客户端如何通过消息传递系统控制其事务？
	第 11.10 节 “消息传递网关”	您如何从应用的其余部分封装对消息传递系统的访问？
	第 11.11 节 “Service Activator”	应用程序如何设计要被各种消息传递技术以及非消息传递技术调用的服务？