1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
|
// import store from '../store'
// import router from '../router'
// import {Message} from "element-ui";
// var websock = null
// var globalCallback = null;
// var interval = null; //定时器
// var isOver80 = false; //硬盘使用率是否超过80%%
// var isOver = false; //用户启动检测,如果硬盘使用率超过80%自动停止,并弹窗提示用户为何停止
//
// //初始化websocket
// function initWebSocket() {
// const userId = sessionStorage.getItem('userId')
// console.log("%%%%%%%%%%%%%################^^^^^^^^^^^^^")
// console.log(userId)
// console.log("%%%%%%%%%%%%%################^^^^^^^^^^^^^")
//
// var ws = 'ws://' + window.g.baseURL + '/websocket/' + 'admin';
//
// websock = new WebSocket(ws)
// websock.onmessage = function(e) {
// websocketonmessage(e)
// }
// websock.onclose = function(e) {
// websocketclose(e);
// }
// websock.onopen = function() {
// websocketOpen()
// }
// // 连接发生错误的回调方法
// websock.onerror = function() {
// console.log('链接失败--重新链接');
// initWebSocket()
// }
// //发送心跳包
// interval = window.setInterval(function() {
// if (websock != null) {
// let heart = {
// "heart": "HeartBeat"
// }
// websock.send(JSON.stringify(heart));
// console.log("发送心跳包：HeartBeat");
// }
// }, 1800000);
// // }, 180);
// }
//
// // 实际调用的方法
// function sendSock(agentData, callback) {
// globalCallback = callback
// if (websock.readyState === websock.OPEN) {
// // 若是ws开启状态
// websocketsend(agentData)
// } else if (websock.readyState === websock.CONNECTING) {
// // 若是 正在开启状态，则等待1s后重新调用
// setTimeout(function() {
// sendSock(agentData, callback)
// }, 1000)
// } else {
// // 若未开启 ，则等待1s后重新调用
// setTimeout(function() {
// sendSock(agentData, callback)
// }, 1000)
// }
// }
// //实际调用--用户退出登录时----手动关闭ws连接
// function closews() {
// websock.close();
// }
// //实际调用--用户登录成功(login.vue)或刷新页面(app.vue)时--启动ws重新连接//用户刷新页面但是未登录不做处理
// function linkws() {
// initWebSocket()
// console.log('登录成功--开始连接.......')
// }
//
// // 数据接收 ---------将所需数据存到store里面
// function websocketonmessage(e) {
// var data = JSON.parse(e.data)
// // console.log(data)
// if (data.msg_type == "stat") { //实时数据图标展示
// var yingpan = data.fs_used / (data.fs_used + data.fs_free);
// var neicun = data.mem_used / data.mem_total;
// var msg = {
// // "flow":(data.ring_recv_bytes*8/1024/1024).toFixed(2),
// "flow": (data.recv_bytes * 8 / 1024 / 1024).toFixed(2),
// "meek": data.new_conns.TOR_MEEK,
// "tor": data.new_conns.TOR_DIRECT,
// "lwhttp": data.new_conns.ZERONET_TRACKER,
// "lwssl": data.new_conns.ZERONET_SSL,
// "tor2web": data.new_conns.TOR2WEB,
// "tempmail": data.new_conns.TEMPMAIL,
// "cpu": (100 - data.cpu_idl).toFixed(2), //cpu使用率
// "mem": (neicun * 100).toFixed(2), //内存使用率
// "fs": (yingpan * 100).toFixed(2), //硬盘使用率
// }
// store.commit("timedatafn", msg) //存储实时数据
// if ((yingpan * 100).toFixed(2) > 80) { //硬盘使用率超过80%自动提示
// if (isOver80 == false) {
// Message.warning('警告:硬盘使用率已超过80%!');
// isOver80 = true
// }
// } else {
// isOver80 = false;
// }
// };
// if (data.info == 'disk quota exceeded' && data.msg_type == "task_done") {
// if (isOver == false) {
// Message.warning('警告:硬盘使用率已超过80%!');
// isOver = true
// }
// } else {
// isOver = false;
// }
// if (data.msg_type == "task_done" && data.result == "success") { //流量导入结果回传
// var msg = {
// "action": data.action,
// "info": data.info,
// "result": data.result
// };
// store.commit("flowbackfn", msg) //存储实时数据
// };
// if (data.info == 'License invalid' && data.msg_type == "task_done") { //License失效--跳到license认证页面
// Message.error('License失效,请重新认证！');
// store.commit("isAuthorize", true);
// router.push('/authmessage')
// }
//
// //实时检测是否停止 lightnet_mode-->0在线 1离线 lightnet_heartbeat 0停止 >0启动
// if (data.lightnet_heartbeat == 0) {
// store.commit("isCheckfn", false) // 当前用户关闭了实时数据检测
// } else if (data.lightnet_heartbeat > 0) {
// store.commit("isCheckfn", true) // 当前用户开启了实时数据检测
// }
// if (data.type == "loginOut") { //用户二次登陆踢掉第一次登陆 并清空数据
// if (data.token == sessionStorage.getItem('token')) {
// router.push('/login')
// sessionStorage.setItem('isLogin', false)
// sessionStorage.setItem('sessionId', '')
// sessionStorage.setItem('token', '')
// sessionStorage.setItem('userId', '')
// }
// }
//
// // 铃声提示
// if (data.new_meek_conns > 0) {
// store.commit("newMeekfn", new Date().getTime())
// }
// }
//
// // 数据发送
// function websocketsend(agentData) {
// websock.send(JSON.stringify(agentData))
// }
//
// // 关闭
// function websocketclose(e) {
// console.log('连接关闭');
// if (interval) { //关闭连接请求定时器
// window.clearInterval(interval);
// console.log("清除定时器");
// }
// }
// // 创建 websocket 连接
// function websocketOpen(e) {
// console.log('连接成功')
// }
//
// //initWebSocket() 登录和页面刷新重新连接
//
// // 将方法暴露出去
// export {
// sendSock, //发送数据
// closews, //退出登录--手动关闭链接
// linkws, //登录成功--建立ws连接
// }
|
