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

企业级集成模式一书

Apache Camel 支持来自书中的大多数模式，Greg or Hohpe 和 Bobby Woolf 的企业集成模式。

消息传递系统

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

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

消息传递频道

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

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

消息构造

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

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

消息路由

表 3.4 “消息路由” 中显示的消息路由模式描述了将消息频道链接在一起的各种算法，包括可应用到消息流的各种算法（无需修改消息正文）。

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

消息转换

表 3.5 “message Transformation” 中显示的消息转换模式描述了如何修改消息的内容，以满足各种用途。

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

消息传递端点

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

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