websocket.js
3.21 KB
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
var websocket = null;
//判断当前浏览器是否支持WebSocket
if('WebSocket' in window){
//获取本地项目请求路径，例如：http://127.0.0.1:8080/cmp-model-website/；获取端口和项目名称
var socketUrl=global.basePath.split("//")[1];
var projectName=socketUrl.split("/")[1];
var ip="127.0.0.1";
// websocket = new WebSocket("ws://"+ip+":8080/"+projectName+"/websocket");
websocket = new WebSocket("ws://"+socketUrl+"/websocket");
}
else{
alert('Not support websocket')
}
//连接发生错误的回调方法
websocket.onerror = function(){
setMessageInnerHTML("error");
};
//连接成功建立的回调方法
websocket.onopen = function(event){
setMessageInnerHTML("open");
}
//接收到消息的回调方法
websocket.onmessage = function(event){
setMessageInnerHTML(event.data);
}
//连接关闭的回调方法
websocket.onclose = function(){
setMessageInnerHTML("close");
}
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
window.onbeforeunload = function(){
websocket.close();
}
//将消息显示在网页上
function setMessageInnerHTML(innerHTML){
//若为操作传过来的json数据
if(innerHTML.indexOf("action")!=-1){
// alert(loginname_now);
//loginname_now为当前操作此公文页面的用户,pid都为全局变量
var LoginUser_now=loginname_now;
var pid_now=pid;
//最近操作该公文的用户信息(最近打开公文页面)
var loginJson=JSON.parse(innerHTML);
var LoginUser_before=loginJson.username;
var pid_beofre=loginJson.pid;
var action_before=loginJson.action;
//判断当前页面是不是同一篇公文，并且是同一个登录用户打开的，若不是，则不执行
if(LoginUser_before==LoginUser_now&&pid_beofre==pid_now){
if(action_before=="save"){
history.go(0) ;
}else{
newclose(action_before,"websocket");
}
}
}
}
//关闭连接
function closeWebSocket(){
websocket.close();
}
//发送消息
function send_websocket(message){
websocket.send(message);
}
/**
* 获取当前登录用户的操作信息
* @param loginname_now
* @param pid
* @param action
* @returns
*/
function getMessageJson(loginname_now,pid,action){
var loginJson={
username:loginname_now,
pid:pid,
action:action
}
var jsoStr = JSON.stringify(loginJson);
return jsoStr;
}
/**
* websocke同步方法
* @param loginname_now
* @param pid
* @param action
*/
function websocketAsy(loginname_now,pid,action){
jsoStr = getMessageJson(loginname_now,pid,action);
send_websocket(jsoStr);
}