八、网页版消息推送SDK-WebSockets

<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js" type="text/javascript"></script>

var websocket = function(config) {

	this.host = config.host;// ip 
	this.port = config.port;// 端口
	this.useTLS = config.useTLS; // 是否启用TLS 安全连接
	this.topic = config.topic;// 订阅Topic
	this.userName = config.userName; // 连接用户名
	this.password = config.password; // 密码
	this.cleansession = config.cleansession; //false : 表示每次相同的身份登陆： true ： 表示每次以新身份登陆 
	this.reconnectTimeout = 5000; // 重试超时时间
	this.clientId = config.clientId; // 客户端名称
	var mqttClient;

	this.connect = function MQTTconnect() {
		mqttClient = new Paho.MQTT.Client(this.host, this.port, clientId);

		var options = {
			timeout : 10,
			useSSL : this.useTLS,
			cleanSession : this.cleansession,
			onSuccess : onConnect,
			onFailure : function(message) {
				faildMssge(message.errorMessage, "Retrying",
						fialdMessageCallback)
				setTimeout(MQTTconnect, this.reconnectTimeout);
			}
		};

		mqttClient.onConnectionLost = onConnectionLost;
		mqttClient.onMessageArrived = onMessageArrived;

		if (this.userName != null) {
			options.userName = this.userName;
			options.password = this.password;
		}

		console.log("Host=" + host + ", port=" + port + " TLS = " + useTLS
				+ " username=" + userName + " password=" + password);
		mqttClient.connect(options);
	}
	function onConnect() {
		mqttClient.subscribe(topic, {
			qos : 0
		});
	}

	function onConnectionLost(response) {
		setTimeout(MQTTconnect, this.reconnectTimeout);
		faildMssge("connection lost: " + responseObject.errorMessage,
				". Reconnecting", fialdMessageCallback)
	}
	;

	function onMessageArrived(message) {
		var topic = message.destinationName;
		var payload = message.payloadString;
		callback(topic, payload, messageCallback);
	}
	;

	function callback(topic, payload, messageCallback) {
		messageCallback(topic, payload);
	}

	function faildMssge(errorMessage, type, fialdMessageCallback) {
		fialdMessageCallback(errorMessage, type);
	}

	this.sendMessage = function sendMessage(topic, message) {
		var message = new Paho.MQTT.Message(message);
		message.destinationName = topic;
		message.qos = 0;
		mqttClient.send(message);
	}
}

// Create a config 
config = {
		host : ‘172.16.192.103‘,
		port : 9001,
		topic : ‘#‘,
		useTLS : false,
		userName : null,
		password : null,
		cleansession : true,
		clientId : ‘clientId‘
	}	
//Create a client instance
var client = new websocket(config);
// connect the client
client.connect();
//send message 	
client.sendMessage(topic, message);
// subscribe topic message callback function
function messageCallback(topic, payload) {
	// 业务逻辑处理
}
//error message callback function
function fialdMessageCallback(errorMessage, type) {
	//业务逻辑处理
}