我们多执行几次客户端的生产方法和消费方法就可以看到一个完整的MQ的通讯过程,下面是我执行了几次的一些日志
接收到原始数据：SEND:Hello World 成功向消息处理中心投递消息：SEND:Hello World，当前暂存的消息数量是：1 ======================= 接收到原始数据：SEND:Hello World 成功向消息处理中心投递消息：SEND:Hello World，当前暂存的消息数量是：2 ======================= 接收到原始数据：SEND:Hello World 成功向消息处理中心投递消息：SEND:Hello World，当前暂存的消息数量是：3 ======================= 接收到原始数据：SEND:Hello World 消息处理中心内暂存的消息达到最大负荷，不能继续放入消息！ ======================= 接收到原始数据：Hello World 原始数据:Hello World没有遵循协议,不提供相关服务 接收到原始数据：CONSUME 已经消费消息：SEND:Hello World，当前暂存的消息数量是：2 ======================= 接收到原始数据：CONSUME 已经消费消息：SEND:Hello World，当前暂存的消息数量是：1 ======================= 接收到原始数据：CONSUME 已经消费消息：SEND:Hello World，当前暂存的消息数量是：0 ======================= 接收到原始数据：CONSUME 消息处理中心内没有消息可供消费！ ======================= 小结本章示例代码主要源自分布式消息中间件实践一书 , 这里我们自己使用Java语言写了一个MQ消息队列 , 通过这个消息队列我们对MQ中的几个角色 "生产者,消费者,消费处理中心,协议"有了更深的理解 ; 那么下一章节我们就来一块学习具体厂商的MQ RabbitMQ