vent-app/common/js-sdk/socket/socket.js

import configService from '@/common/service/config.service.js';
import store from '@/store/index.js';
import {ACCESS_TOKEN} from '@/common/util/constants.js'
class socket {
	constructor(options) {
		this.socketUrl = configService.apiUrl;
		this.socketStart = false;
		this.monitorSocketError();
		this.monitorSocketClose();
		this.socketReceive();
	}
	init(socket_type,callback) {
		const _this = this;
		if (configService.apiUrl) {
			if(this.socketStart){
				console.log('webSocket已经启动了');
			}else{
				let userid=store.state.userid?store.state.userid:store.getters.userid;
				let url=this.socketUrl.replace("https://","wss://").replace("http://","ws://")+"/"+socket_type+"/"+userid+"_app";
				console.log("启动this.socketUrl连接地址:",url);
				// update-begin-author:lsq date:20230506 for:[issues/497]websocket连接打开失败 
				let token = uni.getStorageSync(ACCESS_TOKEN)
				uni.connectSocket({
					url: url,
					method: 'GET',
					protocols:[token]
				});
				// update-end-author:lsq date:20230506 for:[issues/497]websocket连接打开失败 

				uni.onSocketOpen((res) => {
					this.socketStart = true;
					callback && callback();
					console.log('WebSocket连接已打开！');
				});
				/*setTimeout(() => {
				   _this.getHeartbeat();
				}, 5000);*/
			}
		}else{
			console.log('config/baseUrl socketUrl为空');
		}
	}
	//Socket给服务器发送消息
	send(data, callback) {
		const _this = this;
		if (store.state.userid) {
			data.userUid =store.state.userid;
		}
		console.log(data);
		uni.sendSocketMessage({
			data: JSON.stringify(data),
			success: () => {
				callback && callback(true);
			},
			fail: () => {
				callback && callback(false);
			}
		});
	}
	//Socket接收服务器发送过来的消息
	socketReceive() {
		const _this = this;
		uni.onSocketMessage(function(res) {
			console.log("APP:----》收到服务器内容:",res);
			let data = JSON.parse(res.data);
			//console.log('收到服务器内容：', data);
			_this.acceptMessage && _this.acceptMessage(data);
		});
	}
	//关闭Socket
	closeSocket() {
		const _this = this;
		uni.closeSocket();
		_this.socketStart = false;
	}
	//监听Socket关闭
	monitorSocketClose() {
		const _this = this;
		uni.onSocketClose(function(res) {
			console.log('WebSocket 已关闭！');
			_this.socketStart = false;
			setTimeout(function() {
				//_this.init();
			}, 3000); 
		});
	}
	//监听Socket错误
	monitorSocketError() {
		const _this = this;
		uni.onSocketError(function(res) {
			_this.socketStart = false;
			console.log('WebSocket连接打开失败，请检查！');
		});
	}
	//心跳
	getHeartbeat() {
		const _this = this;
		this.send({
			type: "心跳",
			userUid: store.state.userid
		}, (val) => {
			setTimeout(() => {
				if (val) {
					//_this.getHeartbeat();
				} else {
					if(!_this.socketStart){
						//_this.init();
					}
				}
			}, 10000);
		});
	}
};
const mySocket = new socket();
export default mySocket;