uniapp中websocket的使用单个长连接

1、新建js文件封装websocket.js

const WEBSOCKET = {
	//是否打开连接
	socketOpen: false,
	//连接socket
	/* 
	 url：链接地址 wss://xxxxxxxx.com
	 socketMessageFunc：收到服务器内容回调
	 */
	connectSocket(url, socketMessageFunc = null) {
		try {
			//连接socket
			uni.connectSocket({
				url,
				success() {
					console.log('websocket连接成功！')
				}
			})
			//监听socket连接
			uni.onSocketOpen((res) => {
				this.socketOpen = true
				console.log('WebSocket连接已打开！',res)
			})
			//监听socket连接失败
			uni.onSocketError((res) => {
				this.socketOpen = false
				console.log('WebSocket连接打开失败，请检查！',res)
			})
			//监听收到消息
			uni.onSocketMessage((res) => {
				console.log('收到服务器内容：' + res.data)
				if(socketMessageFunc){
					socketMessageFunc(res.data)
				}
			})
			//监听socket关闭
			uni.onSocketClose(() => {
				console.log('WebSocket 已关闭！')
				this.socketOpen = false
			})
		} catch (error) {
			console.log('err:' + error)
		}
	},

	//发送消息
	/* 
	 msg：字符串 JSON.stringify({
								"userId": this.uid,
								"targetIds": targetId,
								"data":'哈哈哈'
							})
	 successFunc：成功回调函数
	 errorFunc：失败回调函数
	 */
	sendMessage(msg = '', successFunc = null, errorFunc = null) {
		if (!this.socketOpen || !msg) {
			if (errorFunc) {
				errorFunc('未传消息内容或连接未打开！')
			}
			return
		}
		uni.sendSocketMessage({
			data: msg,
			success(res) {
				console.log('消息发送成功！')
				if (successFunc) {
					successFunc(res)
				}
			},
			fail(err) {
				console.log('消息发送失败！')
				if (errorFunc) {
					errorFunc(err)
				}
			}
		})
	},
	//关闭连接
	closeSocket() {
		if (!this.socketOpen) {
			return
		}
		//关闭socket连接
		uni.closeSocket()
	}
}

export default WEBSOCKET

2、单页面使用

	
		开启定时器定时检测心跳
	



	//导入websocket对象
	import websocket from '@/utils/websocket'

	//定义定时器
	let globalTimer = null

	export default {
		onLoad() {
			try {
				//建立socket连接
				websocket.connectSocket('wss://xxxxxxxx.com', (res) => {
					console.log('收到内容:', res);
                    //做一些处理、方法调用
				})
			} catch (error) {
				console.log('error:' + error)
			}
		},
		onUnload() {
			//关闭socket
			websocket.服务器托管网closeSocket()
		},
		methods: {
			heartBe服务器托管网atTest() {
				//清除定时器
				if(globalTimer){
					clearInterval(globalTimer)
					globalTimer = null
				}
				globalTimer = setInterval(() => {
					//发送消息给服务端
					websocket.sendMessage(
						JSON.stringify({
							"userId": '001',
							"targetIds": '1234',
							"data": '哈哈哈'
						}), //与服务端约定好消息格式
						(res ) => {
							console.log('消息发送成功！',res)
						},
						(err) => {
							console.log('消息发送失败！',err)
							//如果失败则清除定时器
							clearInterval(globalTimer)
						}
					)
				}, 10000)
			}
		}
	}

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net

相关推荐: Anaconda虚拟环境配置Python库与Spyder编译器

  本文介绍在Anaconda中，为Python的虚拟环境安装第三方库与Spyder等配套软件的方法。   在文章创建Anaconda虚拟Python环境的方法中，我们介绍了在Anaconda环境下，创建、使用与删除Python虚拟环境的方法；而创建虚拟环境后…