simpleMessageQueue
所属分类：中间件编程
开发工具：Java
文件大小：0KB
下载次数：0
上传日期：2018-11-22 16:31:18
上 传 者：
sh-1993
说明： 简易消息中心的实现
(Implementation of simple message center)
文件列表:
mvnw (9113, 2018-11-22)
pom.xml (1623, 2018-11-22)
src/ (0, 2018-11-22)
src/main/ (0, 2018-11-22)
src/main/java/ (0, 2018-11-22)
src/main/java/com/ (0, 2018-11-22)
src/main/java/com/yb/ (0, 2018-11-22)
src/main/java/com/yb/demo/ (0, 2018-11-22)
src/main/java/com/yb/demo/Broker.java (1294, 2018-11-22)
src/main/java/com/yb/demo/BrokerServer.java (1617, 2018-11-22)
src/main/java/com/yb/demo/ConsumeClient.java (255, 2018-11-22)
src/main/java/com/yb/demo/DemoApplication.java (311, 2018-11-22)
src/main/java/com/yb/demo/MqClient.java (1094, 2018-11-22)
src/main/java/com/yb/demo/ProduceClient.java (187, 2018-11-22)
src/main/resources/ (0, 2018-11-22)
src/main/resources/application.properties (0, 2018-11-22)
src/test/ (0, 2018-11-22)
src/test/java/ (0, 2018-11-22)
src/test/java/com/ (0, 2018-11-22)
src/test/java/com/yb/ (0, 2018-11-22)
src/test/java/com/yb/demo/ (0, 2018-11-22)
src/test/java/com/yb/demo/DemoApplicationTests.java (335, 2018-11-22)
# 工程说明
简易消息中心的实现
## BrokerServer
表示消息的分发中心 启动main方法监听9999
##ProduceClient
表示生产者
启动main方法
BrokerServer服务出现：
接受到的原始数据为：hello world
成功向消息中心投递消息：hello world,当前暂存的消息的数量是：1
======================================================
表示消息投递成功
##ConsumeClient
表示消费者
启动main方法
BrokerServer服务出现：
接受到的原始数据为：CONSUME
已经消费消息：hello world,当前暂存的消息数量为：2
=================================================
ConsumeClient服务出现：
获取到的消息为：hello world
表示消息消费成功
## MqClient
封装了对9999端口消息的发送以及接受;目前的模式只有拉取的模式，没有推送的模式
近期下载者：
相关文件：
收藏者：