本章介绍使用 Java 实现RocketMQ 的客户端、 以及各种消息的方式的实现。

本章实现了以下几种消息的实现方式：

一：普通消息

　　普通的消息分为三种：

　　1> 可靠的同步消息

　　　　可靠的同步传输用于广泛的场景，如重要通知信息，短信通知，短信营销系统等。

　　2> 可靠的异步消息

　　　　异步传输通常用于响应时间敏感的业务场景。

　　3> 单向传输消息

　　　　单向传输用于要求中等可靠性的情况，如日志收集。

二：顺序消费

　　RocketMQ使用FIFO顺序提供有序消息

三：广播消息

　　广播正在向主题的所有订阅者发送消息。 如果您希望所有订阅者接收有关主题的消息，广播是一个不错的选择。

四：定时消息

　　定时的消息与正常消息不同，因为它们将在以后提供的时间内不会被传送。

五：事务消息

　　事务消息为了解决分布式事务最终一致性。

应为以上五中消息类型的实现代码比较多、不方便在此处贴出。如有感兴趣的同学可以到如下地址查看。

git: