uniapp使用uni自带websocket进行即时通讯详细步骤

// 创建webSocket
this.webSocketTask = uni.connectSocket({
	url: '这里面写的是连接地址',
	header: {
	    'content-type': 'application/json'
	},
	success(res) {
		console.log('成功', res);
	},
})

//监听WebSocket连接打开事件
this.webSocketTask.onOpen((res) => {
	console.info("监听WebSocket连接打开事件", res)
});

//接收websocket消息及处理
this.webSocketTask.onMessage((res) => {
	let data = JSON.parse(res.data);
//判断服务器返回的type类型
	switch (data.type){
		//如果返回的ping，说明服务端ping客户端
		case 'ping':
            //我们要给服务器说一个pong告诉服务器我还活着
			this.webSocketTask.send({
				data: JSON.stringify({
					type: 'pong'
				})
			});
			break;
		//登录更新用户列表
        //如果type是init，说明服务器知道我们活着，给我们传一个标识，我们通过这个标识去请求接口，                            
          建立唯一链接。
		case 'init':
			uni.setStorageSync('client_id', data.client_id);
			this.$u.post('common/pub/bindUid',{
				client_id: data.client_id,
				user_id: this.userId
			}).then(res => {
				this.webSocketTask.send({
					data: JSON.stringify({
						type: 'bindUid',
						user_id:2
					})
				});
			});
			break;
		case 'simple':
			this.userList.push(data.data)
			this.scrollToBottom()
			break;
		case 'group':
			this.userList.push(data.data)
			this.scrollToBottom()
			break
	}

this.webSocketTask.send({
	data: JSON.stringify({type: 'pong'})
});

onUnload(){
	uni.closeSocket({
		success:() => {
			console.info("退出成功")
		},
	})
},

onLoad(){
    this.socket()
};
methods:{
    socket(){
    //创建webSocket
    this.webSocketTask = uni.connectSocket({
	    url: 'ws地址',
		header: {
			'content-type': 'application/json'
		},
		success(res) {
			console.log('成功', res);
		},
	})
	// 监听WebSocket连接打开事件
	this.webSocketTask.onOpen((res) => {
		console.info("监听WebSocket连接打开事件", res)
	});
	// 监听WebSocket错误
	uni.onSocketError((res) => {
		console.info("监听WebSocket错误" + res)
	});
}
onShow(){
    // 接收websocket消息及处理
    this.webSocketTask.onMessage((res) => {
		let data = JSON.parse(res.data);
		switch (data.type) {
			// 服务端ping客户端
			case 'ping':
				this.webSocketTask.send({
					data: JSON.stringify({
						type: 'pong'
					})
				});
				break;
			// 登录 更新用户列表
			case 'init':
				uni.setStorageSync('client_id', data.client_id);
				this.$u.post('接口', {
					client_id: data.client_id,
					user_id: this.userId
				}).then(res => {
					this.webSocketTask.send({
						data: JSON.stringify({
							type: 'bindUid',
							user_id: this.userId
						})
					});
				});
				break;
			case 'simple':
				this.userList.push(data.data)
				this.scrollToBottom()
				break;
			case 'group':
				// this.groupMenuList()
				this.userList.push(data.data)
				this.scrollToBottom()
				break
		}
	});
}
onUnload() {
	uni.closeSocket({
		success: () => {
			console.info("退出成功")
		},
	})
},