MingGaoApp_vue/MingGaoApp/App.vue

<script>
	export default {
		globalData: {
			token: "",

			// 文本消息
			socketTask: null,
			urlData: "ws://192.168.1.17:12345/api/api_gateway?method=control_center.real_time.im_message",
			is_open_socket: false, // 确保websocket是打开状态
			list: [],
			userId: null, // 用户ID

			// 即构
			video: null, //房间密码和token
		},
		onLaunch: function() {
			// App启动
			var that = this
			uni.getStorage({
				key: 'session_key',
				success: function(res) {
					// console.log(res)
					that.globalData.token = res.data
					// console.log('登录成功了')
					that.msgInit(); // 文本初始化
				},
				fail: function(err) {
					// console.log(err)
					// console.log('没有登录成功')
				}
			})
		},
		onShow: function() {
			// App展示在前台
			// console.log('App Show')
		},
		onHide: function() {
			// App不再再展示在前台
			// console.log('App Hide')
		},
		methods: {
			// 实时通信 - 初始化
			msgInit() {
				var that = this
				// 连接webscoket
				// console.log(this.globalData.urlData)
				that.globalData.socketTask = uni.connectSocket({
					url: this.globalData.urlData + "&token=" + that.globalData.token,
					success(data) {
						// console.log("websocket连接成功");
					}
				});

				// 发送消息 - 获取对话列表
				var obj = {
					'action': 'list', // 动作标识，必填
					'recv_user_id': '', // 接收人用户id， 非必填
					'data': {}
				}
				that.globalData.socketTask.onOpen((res) => {
					that.globalData.socketTask.send({
						data: JSON.stringify(obj),
						async success(res) {
							that.globalData.is_open_socket = true
							console.log("消息发送成功");
						},
					});
				})

				// // 接收服务器返回的消息
				// // 注：只有连接正常打开中 ，才能正常收到消息
	 			that.globalData.socketTask.onMessage((res) => {
					console.log("收到服务器内容：");
					var val = JSON.parse(res.data)
					if (val.action == 'list') {
						var obj1 = {
							'action': 'list', // 动作标识，必填
							'recv_user_id': that.globalData.userId, // 接收人用户id， 非必填
							'data': {
								'msg_status': false, // 消息未读
								'msg_info': '', // 发送消息
							}
						}
						that.globalData.socketTask.send({
							data: JSON.stringify(obj1),
							async success(res) {
								// console.log("消息发送成功");
							},
						});
					} else if (val.action == 'none') {
						// console.log('进入了')
						that.globalData.list = val.data
						console.log(that.globalData.list)
						this.$store.state.list = val.data
						// console.log(this.$store.state.list)
					} else if (val.action == 'recv_video') {
						// console.log(val.data)
						that.globalData.video = val.data
						this.$store.state.video = val.data
						console.log(this.$store.state.video)
					}
				});
				// console.log(that.socketTask)

			},
		},
	}
</script>

<!-- // App.vue文件  中首行的位置引入，注意给style标签加入lang="scss"属性 -->
<style lang="scss">
	/* 注意要写在第一行，同时给style标签加入lang="scss"属性 */
	@import "uview-ui/index.scss";
</style>