135 lines
3.7 KiB
JavaScript
135 lines
3.7 KiB
JavaScript
"use strict";
|
||
const common_vendor = require("../../../common/vendor.js");
|
||
let platform = common_vendor.index.getSystemInfoSync().platform;
|
||
const _sfc_main = {
|
||
data() {
|
||
return {
|
||
connected: false,
|
||
connecting: false,
|
||
socketTask: false,
|
||
msg: false
|
||
};
|
||
},
|
||
computed: {
|
||
showMsg() {
|
||
if (this.connected) {
|
||
if (this.msg) {
|
||
return "收到消息：" + this.msg;
|
||
} else {
|
||
return "等待接收消息";
|
||
}
|
||
} else {
|
||
return "尚未连接";
|
||
}
|
||
}
|
||
},
|
||
onUnload() {
|
||
common_vendor.index.hideLoading();
|
||
if (this.socketTask && this.socketTask.close) {
|
||
this.socketTask.close();
|
||
}
|
||
},
|
||
methods: {
|
||
connect() {
|
||
if (this.connected || this.connecting) {
|
||
common_vendor.index.showModal({
|
||
content: "正在连接或者已经连接，请勿重复连接",
|
||
showCancel: false
|
||
});
|
||
return false;
|
||
}
|
||
this.connecting = true;
|
||
common_vendor.index.showLoading({
|
||
title: "连接中..."
|
||
});
|
||
this.socketTask = common_vendor.index.connectSocket({
|
||
url: "wss://echo.websocket.org",
|
||
data() {
|
||
return {
|
||
msg: "Hello"
|
||
};
|
||
},
|
||
header: {
|
||
"content-type": "application/json"
|
||
},
|
||
method: "GET",
|
||
success(res) {
|
||
},
|
||
fail(err) {
|
||
}
|
||
});
|
||
console.log(this.socketTask);
|
||
this.socketTask.onOpen((res) => {
|
||
this.connecting = false;
|
||
this.connected = true;
|
||
common_vendor.index.hideLoading();
|
||
common_vendor.index.showToast({
|
||
icon: "none",
|
||
title: "连接成功"
|
||
});
|
||
console.log("onOpen", res);
|
||
});
|
||
this.socketTask.onError((err) => {
|
||
this.connecting = false;
|
||
this.connected = false;
|
||
common_vendor.index.hideLoading();
|
||
common_vendor.index.showModal({
|
||
content: "连接失败，可能是websocket服务不可用，请稍后再试",
|
||
showCancel: false
|
||
});
|
||
console.log("onError", err);
|
||
});
|
||
this.socketTask.onMessage((res) => {
|
||
this.msg = res.data;
|
||
console.log("onMessage", res);
|
||
});
|
||
this.socketTask.onClose((res) => {
|
||
this.connected = false;
|
||
this.startRecive = false;
|
||
this.socketTask = false;
|
||
this.msg = false;
|
||
console.log("onClose", res);
|
||
});
|
||
console.log("task", this.socketTask);
|
||
},
|
||
send() {
|
||
this.socketTask.send({
|
||
data: "from " + platform + " : " + parseInt(Math.random() * 1e4).toString(),
|
||
success(res) {
|
||
console.log(res);
|
||
},
|
||
fail(err) {
|
||
console.log(err);
|
||
}
|
||
});
|
||
},
|
||
close() {
|
||
if (this.socketTask && this.socketTask.close) {
|
||
this.socketTask.close();
|
||
}
|
||
}
|
||
}
|
||
};
|
||
if (!Array) {
|
||
const _easycom_page_head2 = common_vendor.resolveComponent("page-head");
|
||
_easycom_page_head2();
|
||
}
|
||
const _easycom_page_head = () => "../../../components/page-head/page-head.js";
|
||
if (!Math) {
|
||
_easycom_page_head();
|
||
}
|
||
function _sfc_render(_ctx, _cache, $props, $setup, $data, $options) {
|
||
return {
|
||
a: common_vendor.p({
|
||
title: "websocket通讯示例"
|
||
}),
|
||
b: common_vendor.t($options.showMsg),
|
||
c: common_vendor.o((...args) => $options.connect && $options.connect(...args)),
|
||
d: $data.connected,
|
||
e: common_vendor.o((...args) => $options.send && $options.send(...args)),
|
||
f: common_vendor.o((...args) => $options.close && $options.close(...args))
|
||
};
|
||
}
|
||
const MiniProgramPage = /* @__PURE__ */ common_vendor._export_sfc(_sfc_main, [["render", _sfc_render], ["__file", "E:/xianyu/app/greenPro/pages/API/websocket-socketTask/websocket-socketTask.vue"]]);
|
||
wx.createPage(MiniProgramPage);
|