项目中经常会遇到这样的场景

1)  用户注册成功之后，不仅仅会有短信通知，可能还会有系统消息弹出，或者是其他形式，但是不论是什么形式，都离不开消息的传递行为

2)    之前在200x年的时候，我们都会使用不停的polling 轮训的方式，对后台不停的刷新，只有后端也或者是数据库中有新加入的数据，立即取出将数据展示在界面上，以便通知用户

3)    在后来也就是大部分现在的模式，都是使用websocket的形式进行服务端反推送的模式，这样效果可以达到，但是如果用户注册成功之后，就退出系统，或者是用户没有手机通知，这个时候，就算用户注册

成功,他也不知道自己已经注册成功了，因为我们都知道websocket本身是不具备消息持久化的

综上所述，我们可以使用ActiveMQ/RabbitMQ+MQTT协议+前端mqtt.js 实现消息的同步以及持久化，这样就解决了，如果该用户注册之后，立即退出，等他上线之后，会通知他，之前注册的结果是成功还是

失败

1 工具汇总介绍：

IDE：Eclipse 2019.6 若有版本问题请更换idea2018之后的版本，不在赘述，我这里是用的是基于Eclipse的 spring sts4

ActiveMQ：5.15.12  linux下安装 linux使用centos6.x/7.x均可   RHEL

MQTT：v3版本  (MQTT只是一种协议，并非是一个产品，而ActiveMQ是包含MQTT协议的一款产品)

web：用简单的web html5 渲染一下即可

MQTT.js :https://github.com/mqttjs/MQTT.js 直接下载即可，也可以从其他网站引入，不多可能时间加载会相对较长一点

2 系统准备：

使用上面介绍的开发工具以及相关插件包，进行如下部署

2.1 打开Eclipse，新建一个springboot项目，其实自己演示的话，什么项目类型都无所谓的，一般的webapp项目也可以，maven类型的托管也可以，只不过现在走一把主流用boot而已，也确实简单，项目路

径以及项目名称，坐标地址，打包方式，各位随意，如下图所示：

直接点击finish待项目构建成功之后即可，若项目构建途中失败，可以自己获取依赖包进行安装(关键要看maven仓库的安装路径)，后期的工作不在赘述。

包结构如下：

com.mqttapp: 核心包是不能改变位置的，除非是包的层级关系发生变更，否则一般不走变更

com.mqttapp.config:一些常用的mqtt的一些工具方法放在这个包下

com.mqttapp.controller: 对外界的一些接口位置，存放在此处

com.mqttapp.handler: 句柄处理，其实这块就是具体的业务逻辑存放的地方

com.mqttapp.service: 业务接口定义的包

至此后台的单体架构准备完毕，跟着就是对于场景的描述

可以看出，在web端我们可以任意订阅消息Broker中的主题Topic，在订阅成功之后，mqttjs会有各种回调方法，这些回调方法，在实际开发中还是比较有用的

onMessage->onMessageArrived->当有消息到达web端的时候，即刻出发该方法

onConnectionLost->若连接丢失，或者出现了其他连接上的问题，会触发该方法

onConnect 当web端的mqtt与服务端的Broker连接成功之后会触发该方法，这个方法很重要，里面涉及到了订阅主题，以及指定连接消息质量qos等定义

mqttws31.js整体配置如下：

web端页面

mqttws31.min.js 测试

display: inline-block;

padding: 20px;

border: 2px solid #00ff00;

border-radius: 6px;

margin: 20px 0px;

user-select: none;

}

.divblock:active {

background-color: #455072;

border: 1px solid #0044ff;

}

ClientID:

Topic:

var options ={

timeout: 50,

keepAliveInterval: 100,

useSSL: false,

// userName: userName,

// password: password,

onSuccess: onConnect,

onFailure: function(e) {

console.log(e);

s = "{time:" + new Date().Format("yyyy-MM-dd hh:mm:ss") + ", onFailure()}";

console.log(s);

}

};

var client = null;

functionsubscriber(){

// Create a client instance

var clientid = document.getElementById("clientid").value;

client = new Paho.MQTT.Client('127.0.0.1',Number(61614),clientid); // "hostname,port,clientid"

// set callback handlers

client.onConnectionLost = onConnectionLost; // 指定丢失事件

client.onMessageArrived = onMessageArrived; // 当对端消息到达web端之后处理

// connect the client 指定mqtt 事件 onSuccess 回调函数

// client.connect(options);

client.connect(

{

onSuccess: onConnect,

cleanSession:false //这里是表示作为持久化订阅者出现，不清楚在broker中的缓存数据}

);

}

// called when the client connects 成功连接mqtt服务器之后的事件函数

functiononConnect() {

//Once a connection has been made, make a subscription and send a message.

console.log("onConnect");

//这里可以订阅多个不同的主题,只需要迭代对象数组即可

client.subscribe("bigdata",{qos:2}); // 订阅主题带qos的参数

//client.subscribe("hotekey_cloud"); // 订阅主题

}

// called when the client loses its connection mqtt 丢失或连接不存在而触发的事件函数

functiononConnectionLost(responseObject) {

if (responseObject.errorCode !== 0) {

console.log("onConnectionLost:" +responseObject.errorMessage);

}

}

// called when a message arrives 接收到订阅消息

functiononMessageArrived(message) {

console.log("onMessageArrived:" +message.payloadString); //若发布者发送的消息为对象类型，需要使用Json工具进行反序列化为对象，才能获取报文中的数据

}

// 推送消息函数

functionmqttPublish(sendata) {

message = new Paho.MQTT.Message(sendata); // 消息内容

message.destinationName = "bigdata"; // 目标主题

client.send(message); // 推送主题

}

// 用户程序点击事件

functionOnmqtttest() {

message = "message from browser with mqtt protocol"; // 消息内容

mqttPublish(message);

}

我们在定义订阅的主题协议时，可以这么去考虑

1 我们的交互场景有几种？没一种场景是否会再次细分 即主题的分层结构

/Sys/Module/xxxxx

这样的分层结构比较常用，需要注意的是符号 "/"在ActiveMQ的Broker中会以符号"."出现

2 若需要一对一交互，我们在设计topic时，需要加上详细的对象编号或者是用户编号，或者是设别编号 如：

/Sys/Notice/UserRegister/1449