zhoudw
2022-03-15 db421edddbd72ed4bb77fda2a148eca4a26039a8
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>