第 3 章企业集成模式简介

企业集成模式书

Apache Camel 通过 Gregor Hohpe 和 Bobby Woolf 支持《企业集成模式》中的大多数模式。

消息传递系统

消息传递系统模式（如表 3.1 “消息传递系统” 所示）介绍了构成消息传递系统的基本概念和组件。

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

消息传递频道

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

表 3.2. 消息传递频道
图标	Name	使用案例
	图 6.1 “指向 point Channel Pattern”	调用者如何确定一个接收器将接收文档或执行调用？
	图 6.2 “发布订阅频道模式”	发件人如何将事件广播到所有感兴趣的接收器？
	图 6.3 “死信频道模式”	消息传递系统通过消息进行哪些操作无法交付？
	图 6.4 “Guaranteed Delivery Pattern”	发件人如何确保消息发送，即使消息传递系统失败也是如此？
	图 6.5 “消息总线模式”	是什么架构使分离的应用程序协同工作，以便在不影响他人的情况下添加或删除一个或多个应用程序的架构？

消息构建

消息构建模式显示在表 3.3 “消息结构” 中，描述通过系统传递的消息的各种形式和功能。

表 3.3. 消息结构
图标	Name	使用案例
	“概述”一节	请求者如何识别生成接收回复的请求？
	第 7.3 节 “返回地址”	replier 如何知道如何发送回复？

消息路由

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

表 3.4. 消息路由
图标	Name	使用案例
	第 8.1 节 “基于内容的路由器”	我们如何处理在一个逻辑功能（例如清单检查）分布到多个物理系统中的一种逻辑函数实现的情况？
	第 8.2 节 “消息过滤器”	组件如何避免接收不间断的信息？
	第 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 节 “服务调用”	如何通过在注册表中查找该服务，在分布式系统中调用远程服务？Camel 2.18 中的新功能.
	第 8.13 节 “多播”	如何同时将消息路由到多个端点？
	第 8.16 节 “循环”	如何在循环中重复处理消息？
	第 8.17 节 “sampling”	在给定时间段内如何显示一条消息，以避免出现下游路由的问题？

消息转换

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

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

消息传递端点

消息传递端点表示消息传递通道和应用程序间的联系点。消息传递端点模式（如表 3.6 “消息传递端点” 所示）描述了端点上可以配置的各种功能及服务数量。

表 3.6. 消息传递端点
图标	Name	使用案例
	第 11.1 节 “消息传递映射程序”	您如何在域对象和消息传递基础架构之间移动数据，同时保持两个相互独立的数据？
	第 11.2 节 “event Driven Consumer”	应用程序如何在消息可用时自动使用消息？
	第 11.3 节 “轮询消费者”	应用在应用就绪时如何消耗消息？
	第 11.4 节 “竞争消费者”	消息传递客户端如何同时处理多个消息？
	第 11.5 节 “消息 Dispatcher”	单个渠道中的多个消费者如何协调其消息处理？
	第 11.6 节 “selective Consumer”	消息使用者如何选择它要接收的消息？
	第 11.7 节 “durable Subscriber”	订阅者如何避免在未侦听邮件时丢失的信息？
	第 11.8 节 “幂等的消费者”	消息接收器如何处理重复的信息？
	第 11.9 节 “事务性客户端”	客户端如何使用消息传递系统控制其事务？
	第 11.10 节 “消息传递网关”	您如何封装从应用的其余部分中对消息传递系统的访问？
	第 11.11 节 “service Activator”	应用程序如何设计各种消息传递技术以及非消息传递技术需要调用的服务？