Message Bus - 消息总线

Liferay的*消息总线(Message Bus)*是一种服务级API，组件可以用它来发送和接收消息。它提供了消息生产者(producers)和消费者(consumers)之间的松耦合。 消息总线(Message Bus)位于Liferay的全局类加载器中，使每个已部署的Web应用程序都可以访问它。 它不支持远程消息传递，但在启用ClusterLink时，可在集群中发送消息。

以下是消息总线的一些常见用法：

• 发送消息触发检索索引写入事件
• 发送订阅电子邮件
• 在调度程序端点处理消息
• 运行异步(asynchronous)进程

你可以利用消息总线在plugins之间以及plugins内部发送消息。

在阅读消息总线教程时，你将学习*同步(synchronous)和异步(asynchronous)*消息传递，*串行(serial)与并行(in-psrallel)*消息调度，以及如何定义消息格式的样式。

在直奔主题之前，你应该首先了解Message Bus系统的体系结构(architecture)。

Liferay’s Message Bus System - Liferay的消息总线系统

Liferay的消息总线系统是处理应用程序之间和应用程序内部通信的解决方案。 但是，在开始使用Message Bus之前，你应该了解Message Bus的结构基础知识。 本教程提供有关Message Bus系统组件的信息，以及可以发送的不同类型的消息。

Message Bus System Components - 消息总线系统组件

消息总线系统包含以下组件：

• Message Bus(消息总线)：管理从消息*sender(发送者)到消息listener(收听者)*的消息传输。
• Destinations(目的地)：listener注册的用来接收消息的地址或端点(endpoint)。
• Listener(收听者)：消费在Destinations收到的消息。 他们接收发送到其注册的Destinations的所有消息。
• Sender(发送者)：调用Message Bus将消息发送到Destinations。

你的服务可以将消息发送到一个或多个destinations，并可以收听一个或多个destination。 下图描绘了这一点。 单个服务既可以是消息发送者，也可以是消息监听者。 例如，在下图中，plugin 2 - Service 3和Plugin 5 - Service 7都发送和收听消息。

[外链图片转存失败(img-JVyZo4Cj-1562829682539)(https://dev.liferay.com/documents/12052/832136/msg-bus-system.png/bdcd50b2-1abf-1779-2345-9ca0bca9d08f?version=1.0&t=1537564289954 ‘‘Message Bus System’’)]

Message Types - 消息类型

消息总线支持同步synchronous 和异步asynchronous消息传递：

• Synchronous messaging 同步消息传递：发送消息后，发送方会阻塞线程，等待收件人的响应。
• Asynchronous messaging 异步消息传递：发送消息后，发件人可以继续处理。 发件人可以配置为接收回调(Call-back)或发送且忘记(Send-and-Forget)这两种模式。
  • Call-back 回调：发送者包含call-back destination key，作为响应消息(response message)的destination 。 然后，接收者(listener)通过此response destination将响应消息发送回发送者。
  • Send-and-Forget 发送并忘记：发送者在发送的消息中不包含回调信息。

可以通过以下文件配置Message Bus：

• WEB-INF/src/META-INF/messaging-spring.xml

  ：指定destinations，listener以及其彼此之间的映射。

• WEB-INF/web.xml

  ：包含plugin的部署描述符列表。 你需要将

  messaging-spring.xml

  添加到此文件中的Spring Configurations中。

Note:

portal-impl.jar

的内部文件

META-INF/messaging-core-spring.xml

指定Liferay的默认Message Bus类，默认异步消息发送方类和默认同步消息发送方类。

你可以使用

com.liferay.portal.kernel.messaging.Message

类或

com.liferay.portal.kernel.json.JSONObject

类来控制消息类型(Message Type)。 这些类包含在Liferay的

portal-service.jar

文件中。 Liferay核心服务通常以JSON格式序列化和反序列化。 以下教程中将使用这两种类型的消息类来展示如何实现同步和异步消息传递。