1、什么是消息?

消息是一个抽象出来的概念，其实就是一串数据的集合，专业术语就是结构化数据对象，Vert.x中消息有如下属性特征：

• 地址（Address）：消息的目标标识符，用于路由到正确的消费者（类似“频道”或“主题”）。
• 主体（Body）：实际传递的数据内容（如字符串、JSON、二进制数据等）。
• 头信息（Headers）：可选的元数据（键值对），用于传递附加信息（如消息类型、优先级等）。
• 回复地址（Reply Address）：用于实现请求-响应模式（发送方可以指定回复的目标地址）。

2、消息的典型形式

Vert.x 支持多种数据类型作为消息的 body，例如：

• 基本类型：String, Number, Boolean。
• 结构化数据：JSON 对象、JSON 数组。
• 二进制数据：Buffer（字节流）。
• 自定义对象：通过编解码器（Codec）序列化的对象（如 Protobuf、POJO）。

// 发送一个 JSON 消息
JsonObject messageBody = new JsonObject()
    .put("userId", 123)
    .put("action", "login");
eventBus.send("user.events", messageBody);

// 发送二进制数据
Buffer buffer = Buffer.buffer().appendString("Hello Vert.x");
eventBus.send("data.channel", buffer);

3、消息的传递模式

Vert.x 通过事件总线支持两种消息传递模式：

1. 点对点（Point-to-Point）
   • 消息发送到特定地址后，仅有一个消费者（通过轮询负载均衡）会接收并处理该消息。
   • 适用于任务分发（如订单处理）。
2. 发布-订阅（Publish-Subscribe）
   • 消息发送到特定地址后，所有订阅该地址的消费者都会收到该消息。
   • 适用于事件广播（如通知系统状态变更）。

4、消息的生命周期

1. 发送消息
   • 生产者调用 eventBus.send(address, body) 或 eventBus.publish(address, body)。
   • 消息被放入事件总线的内部队列，等待调度。
2. 路由消息
   • 事件总线根据 address 将消息分发给已注册的消费者。
   • 在集群模式下，消息可能跨节点传输。