gyfl
/
xyzshop


			
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163
							<?php defined('InShopNC') or exit('Access Invalid!'); ?>

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>websocket测试</title>
    <style type="text/css">
        .msg_list p:first-child {
            color: red;
        }
    </style>
</head>

<body>
<div class="maincontent">
    <input type="text" placeholder="输入内容" id="msg">
    <input type="text" placeholder="输入内容" id="to_user">

    <div>
     <button id="room_single_msg">单条房间消息</button>      <button id="room_millon_msg">压力房间消息</button>
    </div>
    <button id="peer_msg">单点消息</button>
    <button id="offline">断开websocket</button>
    <button id="reconnet">重新连接websocket</button>

    <div class="msg_list"></div>
</div>


<script type="text/javascript" src="<?php echo RESOURCE_SITE_URL; ?>/mobile/shake/js/zepto.min.js"></script>
<script type="text/javascript">

    var token = "<?php echo $output['token']; ?>";
    var addr  = "<?php echo $output['addr']; ?>";
    var room  = <?php echo $output['room']; ?>;
    var user  = <?php echo $output['user']; ?>;

    var seq = 1;
    var client = null;

    var WebStreamer = function()
    {
        client = new WebSocket(addr);

        client.onopen = function ()
        {
            var msg = "websocket已连接";
            var msgHTML = "<p>" + msg + "</p>";
            $('.msg_list').prepend(msgHTML);

            var msg = {
                act: 'access',
                op: 'login',
                seq : "" + seq++,
                token: token,
                msgtype: 'message',
            };
            client.send(JSON.stringify(msg));
        };

        client.onmessage = function (datas) {
            console.table(JSON.parse(datas.data));
        };

        client.onerror = function () {
            console.log('error');
            var msg = "websocket已关闭";
            var msgHTML = "<p>" + msg + "</p>";
            $('.msg_list').prepend(msgHTML);
        };

        client.onclose = function (e) {
            console.log("websocket已关闭...");
            var msg = "websocket已关闭";
            var msgHTML = "<p>" + msg + "</p>";
            $('.msg_list').prepend(msgHTML);
        };
    };

    WebStreamer();

    document.getElementById('offline').addEventListener('click',function(){
        client.close();
    });

    document.getElementById('reconnet').addEventListener('click',function(){
        WebStreamer();
    });

    document.getElementById('room_single_msg').addEventListener('click', function ()
    {
        var inputVal = $('#msg').val();
        if(!inputVal) {
            return;
        }

        var msg = {
            act: 'room',
            op:  'message',
            msgtype: 'message',
            seq : "" + seq++,
            room:room,
            user:user,
            type : "text",
            content:inputVal
        };
        client.send(JSON.stringify(msg));
    });

    document.getElementById('room_millon_msg').addEventListener('click', function ()
    {
        var inputVal = $('#msg').val();
        if(!inputVal) {
            return;
        }

        for (var i = 0; i < 1; i++)
        {
            var msg = {
                act: 'room',
                op:  'message',
                msgtype: 'message',
                seq : "" + seq++,
                room:room,
                user:user,
                type : "text",
                content:inputVal
            };
            client.send(JSON.stringify(msg));
        }
    });

    document.getElementById('peer_msg').addEventListener('click', function ()
    {
        var inputVal = $('#msg').val();
        if(!inputVal) {
            return;
        }

        var to_user = $('#to_user').val();
        if(!to_user) {
            return;
        }

        var msg = {
            act: 'chatwo',
            op:  'message',
            msgtype: 'message',
            seq : "" + seq++,
            from:user,
            to: to_user,
            type : "text",
            content:inputVal
        };

        client.send(JSON.stringify(msg));
    });

</script>

</body>
</html>