websocket-socketTask.uvue

<template>
	<view>
		<page-head title="websocket通讯示例"></page-head>
		<view class="uni-padding-wrap">
			<view class="uni-btn-v">
				<view class="websocket-msg">{{showMsg}}</view>
				<button class="uni-btn-v" type="primary" @click="connect">连接websocket服务</button>
				<button class="uni-btn-v" v-show="connected" type="primary" @click="send">发送一条消息</button>
				<button class="uni-btn-v" type="primary" @click="close">断开websocket服务</button>
				<view class="websocket-tips">发送消息后会收到一条服务器返回的消息（与发送的消息内容一致）</view>
			</view>
		</view>
	</view>
</template>

<script>
	import SocketTask from 'uts.sdk.modules.DCloudUniWebsocket.SocketTask';
	import CloseSocketOptions from 'uts.sdk.modules.DCloudUniWebsocket.CloseSocketOptions';
	import SendSocketMessageOptions from 'uts.sdk.modules.DCloudUniWebsocket.SendSocketMessageOptions';

	export default {
		data() {
			return {
				connected: false,
				connecting: false,
				socketTask: null as SocketTask | null,
				msg: "",
				platform: "",
				pageVisible: false
			}
		},
		computed: {
			showMsg(): string {
				if (this.connected) {
					if (this.msg.length > 0) {
						return '收到消息：' + this.msg
					} else {
						return '等待接收消息'
					}
				} else {
					return '尚未连接'
				}
			}
		},
		onLoad() {
			this.platform = uni.getSystemInfoSync().platform;
			this.pageVisible = true;
		},
		onUnload() {
			this.pageVisible = false;
			uni.hideLoading()
			let task = this.socketTask;
			if (task != null) {
				const closeOptions = new CloseSocketOptions();
				task.close(closeOptions)
			}
		},
		methods: {
			connect() {
				if (this.connected || this.connecting) {
					uni.showModal({
						content: '正在连接或者已经连接，请勿重复连接',
						showCancel: false
					})
					return
				}
				this.connecting = true
				uni.showLoading({
					title: '连接中...'
				})
				this.socketTask = uni.connectSocket({
					url: 'ws://websocket.dcloud.net.cn',
					success(res) {
						// 这里是接口调用成功的回调，不是连接成功的回调，请注意
					},
					fail(err) {
						// 这里是接口调用失败的回调，不是连接失败的回调，请注意
					}
				})
				this.socketTask?.onOpen((res) => {
					if (this.pageVisible) {
						this.connecting = false
						this.connected = true
						uni.hideLoading()
						uni.showToast({
							icon: 'none',
							title: '连接成功'
						})
						console.log('onOpen', res);
					}
				})
				this.socketTask?.onError((err) => {
					if (this.pageVisible) {
						this.connecting = false
						this.connected = false
						uni.hideLoading()
						uni.showModal({
							content: '连接失败，可能是websocket服务不可用，请稍后再试',
							showCancel: false
						})
						console.log('onError', err);
					}
				})
				this.socketTask?.onMessage((res) => {
					if (this.pageVisible) {
						this.msg = res.data as string
						console.log('onMessage', res)
					}
				})
				this.socketTask?.onClose((res) => {
					if (this.pageVisible) {
						this.connected = false
						this.socketTask = null
						this.msg = ""
						console.log('onClose', res)
					}
				})
			},
			send() {
				const data = 'from ' + platform + ' : ' + parseInt((Math.random() * 10000) + "").toString()
				let content = new SendSocketMessageOptions(data, function(res) {
					console.log(res);
				}, function(err) {
					console.log(err);
				}, null);
				this.socketTask?.send(content)
			},
			close() {
				let task = this.socketTask;
				if (task != null) {
					let closeOptions = new CloseSocketOptions();
					task.close(closeOptions)
				}
			}
		}
	}
</script>

<style>
	.uni-btn-v {
		padding: 10rpx 0;
	}

	.uni-btn-v {
		margin: 20rpx 0;
	}

	.websocket-msg {
		padding: 40px 0px;
		text-align: center;
		font-size: 14px;
		line-height: 40px;
		color: #666666;
	}

	.websocket-tips {
		padding: 40px 0px;
		text-align: center;
		font-size: 14px;
		line-height: 24px;
		color: #666666;
	}
</style>