tomzhao
2021-12-21 c56e391b5af6d858b469864719a987bc051f13fe
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
<!DOCTYPE html>
<head>
    <title>socket demo</title>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
    <script type="text/javascript" src="https://cdn.staticfile.org/jquery/1.10.2/jquery.min.js"></script>
</head>
<body>
<input type="text" id="msg" />
<button id="send">发送</button>
</body>
</html>
<script>
    $(function()
    {
        // 创建socket对象
        var socket = new WebSocket('ws://127.0.0.1:9501');
 
        // 打开Socket
        socket.onopen = function(event)
        {
 
            $('#send').on('click', function()
            {
                var msg = $('#msg').val();
                var url = 'application/index/data';
                var fullData = {
                    url:url,
                    data:{
                        session_id:'1a2e0ca9c7404b765a37a5ab07546fa8',
                        group_id:'1a2e0ca9c7404b765a37a5ab07546fa8',
                        msg:msg
                    }
                };
                socket.send(JSON.stringify(fullData));
                console.log(msg);
            });
                var url = 'application/index/reg';
                var fullData = {
                    url:url,
                    data:{
                        session_id:'1a2e0ca9c7404b765a37a5ab07546fa8',
                        group_id:'1a2e0ca9c7404b765a37a5ab07546fa8'
                    }
                };
            // 发送一个初始化消息
            socket.send(JSON.stringify(fullData));
            if (socket.readyState == 1) {
                setInterval(function(){
                    var fullData = {
                        url: 'plumeWSService/cluster/ping',
                        data: 'ping'
                    };
                    socket.send(JSON.stringify(fullData));
                },1000)
            }
            // 监听消息
            socket.onmessage = function(event) {
                if(event.data == 'pingpong'){//处理心跳接收事件
 
                }else{
                    var fullData = JSON.parse(event.data);
                    console.log("客户端监听到的消息:", fullData);
                }
            };
 
            // 监听Socket的关闭
            socket.onclose = function(event) {
                console.log("Socket关闭了", event);
            };
 
            // 关闭Socket....
            //socket.close()
        };
    });
</script>