本例以spring boot框架为基础
下载该实例,并启动。该实例端口号为10000。
我们先对实例进行验证测试。
测试页面地址为:http://localhost:10000/subscribe.html
测试步骤如下:
1、进入http://localhost:10000/subscribe.html ,页面如下图所示:
左侧是订阅消息的操作和展示页面,右侧是发布内容的页面。
2、左侧输入订阅消息主题,点击订阅,订阅相关主题消息,例如:输入财经新闻主题FinancialNews,点击订阅,这样就订阅了财经新闻了。
3、在右侧发布内容页面输入主题和内容,点击发布。这样就可以发布内容了。
测试结果如下:
订阅了财经主题新闻,右侧发布了5条新闻,3条财经新闻,一条天气新闻,一条时政新闻,订阅者收到了3条财经新闻推送信息,证明我们工程已经跑起来了,实现了http流推送的最基本功能。
有两个接口:
"/subscribe"接口:用于消息订阅,该接口有一个参数topic,即订阅的消息主题。
"/publish"接口:发布消息接口,有两个参数,topic是发布消息主题,content是发布消息内容。
订阅和发布消息的才做都封装在ReqContextUtils类中
前端代码在Subscribe.html。
上述代码都有注释,也没有难理解的地方,就不进行讲解了。