c语言实现stomp协议客户端,Uni APP微信小程序websocket stomp.js
创建如下文件websocket.js：
let socketOpen = false;
let socketMsgQueue = [];
export default {
client: null,
baseURL: 'ws://localhost:8080/stomp',
init() {
if (this.client) {
return Promise.resolve(this.client);
}
return new Promise((resolve, reject) => {
const ws = {
send: this.sendMessage,
onopen: null,
onmessage: null,
close: this.closeSocket,
};
uni.connectSocket({
url: this.baseURL,
header: {
'X-ACCESS-TOKEN': uni.getStorageSync('token'), // toekn认证
},
});
uni.onSocketOpen(function(res) {
console.log('WebSocket连接已打开！', res);
socketOpen = true;
for (let i = 0; i < socketMsgQueue.length; i++) {
ws.send(socketMsgQueue[i]);
}
socketMsgQueue = [];
ws.onopen && ws.onopen();
});
uni.onSocketMessage(function(res) {
ws.onmessage && ws.onmessage(res);
});
uni.onSocketError(function(res) {
console.log('WebSocket 错误！', res);
});
uni.onSocketClose((res) => {
this.client.disconnect();
this.client = null;
socketOpen = false;
console.log('WebSocket 已关闭！', res);
});
const Stomp = require('./stomp.js').Stomp;
Stomp.setInterval = function(interval, f) {
return setInterval(f, interval);
};
Stomp.clearInterval = function(id) {
return clearInterval(id);
};
const client = this.client = Stomp.over(ws);
client.connect({}, function() {
console.log('stomp connected');
resolve(client);
});
});
},
disconnect() {
uni.closeSocket();
},
sendMessage(message) {
if (socketOpen) {
uni.sendSocketMessage({
data: message,
});
} else {
socketMsgQueue.push(message);
}
},
closeSocket() {
console.log('closeSocket');
},
};
页面内用法：
import websocket from '/path/to/websocket';
onLoad() {
websocket.init().then(client => {
this.client = client;
this.subscription = this.client.subscribe('/topic/test', this.messageHandler);
});
},