nodejs 搭建websocket长连接服务实现前端页面调用第三方接口获取数据的实时更新

本文转载自查看原文 2020-11-19 17:07 528 websocket/ 前端

1、页面与 js ：

<html xmlns="http://www.w3.org/1999/xhtml">
<head>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
    <title>WebSocket Echo Demo</title>
    <meta name="viewport" content="width=device-width, initial-scale=1"/>
    <link href="../bootstrap-3.3.5/css/bootstrap.min.css" rel="stylesheet" />
    <script src="../js/jquery-1.12.3.min.js"></script>
    <script src="../bootstrap-3.3.5/js/bootstrap.min.js"></script>
</head>

<body>
    <div class="vertical-center" id="test">
        <div class="container">
            <h1>Stock Chart over WebSocket</h1>
            <div>{{message}}</div>
            <!--<button class="btn btn-primary">开始</button>
            <button class="btn btn-danger">停止</button>-->
            <table class="table" id="stockTable">
                <thead>
                    <tr>
                        <th>Symbol</th>
                        <th>Price</th>
                    </tr>
                </thead>
                <tbody id="stockRows">

                    <tr>
                        <td>
                            <h3>售票数</h3>
                        </td>
                        <td id="sale">
                            <h3><span class="label label-default" id="num1">{{numData}}</span></h3>
                        </td>
                    </tr>
                </tbody>
            </table>
        </div>
    </div>
    <script>
        var ws = new WebSocket("ws://localhost:8181");
        var stock_request = { "stocks": ["AAPL", "MSFT", "AMZN", "GOOG", "YHOO"] };
        var isClose = false;
        var stocks = {
            "AAPL": 0, "MSFT": 0, "AMZN": 0, "GOOG": 0, "YHOO": 0
        };
        function updataUI() {
            // debugger
            ws.onopen = function (e) {
                console.log('Connection to server opened');
                isClose = false;
                //ws.send(JSON.stringify(stock_request));
                //ws.send('plese to conection');
                //console.log("sened a mesg");
            }
            // UI update function
            var changeStockEntry = function (symbol, originalValue, newValue) {
                var valElem = $('#' + symbol + ' span');
                valElem.html(newValue.toFixed(2));
                if (newValue < originalValue) {
                    valElem.addClass('label-danger');
                    valElem.removeClass('label-success');
                } else if (newValue > originalValue) {
                    valElem.addClass('label-success');
                    valElem.removeClass('label-danger');
                }
            }
            // WebSocket message handler
            ws.onmessage = function (e) {
                var stocksData = JSON.parse(e.data);
                console.log(stocksData);
                for (var symbol in stocksData) {
                    if (stocksData.hasOwnProperty(symbol)) {
                        changeStockEntry(symbol, stocks[symbol], stocksData[symbol]);
                        stocks[symbol] = stocksData[symbol];
                    }
                }
            };
        }

        //updataUI();

        $(".btn-primary").click(function () {
            if (isClose) {
                ws = new WebSocket("ws://localhost:8181");
            }
            updataUI();
        });
        $(".btn-danger").click(function () {
            ws.close();
        });

        ws.onclose = function (e) {
            console.log("Connection closed", e);
            isClose = true;
        };




    </script>

    <script src="config/jquery-1.10.2.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/vue/dist/vue.js"></script>
    <script type="text/javascript">
        var app2 = new Vue({
            el: '#test',
            data: {
                message: '页面加载于 ' + new Date().toLocaleString(),
                numData: 0,

            },
            mounted: function () {
            },
            methods: {

                init() {
                    //debugger
                    that = this;
                    var ws = new WebSocket('ws://localhost:8181');
                    ws.onopen = function (e) {
                        console.log('开始连接服务器')
                        // 发送消息

                        ws.send('连接到服务器');

                    }
                    ws.onmessage = function (event) { // 监听消息
                        //debugger
                        //定时器设置数字变化的滚动效果
                        var number = event.data - that.numData;
                        var boo = number > 0 ? true : false;// boo = true动画效果为递增;boo = false动画效果为递减
                        setInterval(function () {
                            if (boo) {
                                //数字变大
                                number--;
                                if (number >= 0) {
                                    that.numData++;
                                    return that.numData;
                                }
                            }else {
                                //数字变小
                                number++;
                                if (number <= 0) {
                                    that.numData--;
                                    return that.numData;
                                }
                            }
                        }, 1);
                        

                        //that.numData = event.data;直接赋值没有动画效果，想要动画效果采用上面方法
                        console.log("监听到消息：" + that.numData);

                        //that.numData = msg.data.salesNum;
                    }
                    ws.onerror = function (evt) {
                        //产生异常
                        console.log("产生异常");
                    };
                    ws.onclose = function (evt) {
                        //产生异常
                        console.log("关闭");
                    };
                },
            },
            created: function () {
                this.init();
            }
        });
    </script>
</body>
</html>

nodejs 搭建server.js服务：

var WebSocketServer = require('ws').Server,
wss = new WebSocketServer({ port: 8181 });

//引入模块
var http = require('http');
const querystring = require('querystring');
var numData = -1;
var isTrue = false;
var clientStockUpdater;

//定义请求消息头
var headers = {
    'XverifyApi': 'fzY08dHMxkRRaDM9m7y+ptFf9qsVzmLb0enT7NRfBdAhtI0+iKv3Sg==',
    'XownerId': 'fqszs',
    'XsysId': 'sys-0'
};
//定义请求消息url和头部
var options = {
    method: 'GET',
    url: 'http//api.whlyw.net/bo/api/v1/big-data-ticket-market/list/res/sales',
    headers: headers
};

function handleGetData() {
    //发送请求
    var request = require('request');
    
    //console.log("33");

    request({
        url: 'http://api.whlyw.net/bo/api/v1/big-data-ticket-market/list/res/sales',
        method: 'GET',
        headers: headers
    }, function (error, response, body) {
       // console.log(response.statusCode)
        if (!error && response.statusCode == 200) {
           // console.log(JSON.parse(body)) // 请求成功的处理逻辑，注意body是json字符串  .data.salesNum
            console.log('页面数' + numData);
            console.log('售票数'+JSON.parse(body).data.salesNum);
            if (numData == JSON.parse(body).data.salesNum) {
                console.log('进入到页面数与售票数一致的方法中');
                isTrue = false;
            } else {
                console.log('进入到页面数与售票数不一致的方法中');
                numData = JSON.parse(body).data.salesNum
                isTrue = true;
            }  
            //console.log(numData);
            //return numData;
        }
    })

    //request(options, function (error, response, body) {
    //    console.log("33"+response.statusCode);
    //    if (!error && response.statusCode == 200) {
    //        console.log(body) // 请求成功的处理逻辑，注意body是json字符串
    //    }
    //});


    //var req = http.request(options, function (res) {
    //    console.log(res.statusCode);
    //    console.log(res.headers);
    //    res.setEncoding('utf-8');
    //    res.on('data', function (chunk) {
    //        //输出响应内容
    //        console.log("GGG"+chunk);

    //        ////将chunk转为对象
    //        //console.log(JSON.parse(chunk));
    //        ////通过对象调用各参数，不发散其他操作
    //        //console.log(JSON.parse(chunk).resultcode);
    //    });
    //    //res.on('end', function () {
    //    //    console.log('响应结束********');
    //    //});
    //});
    ////监控错误情况时报错
    //req.on('error', function (e) {
    //    console.error(e);
    //});
    ////结束请求输入
    //req.end();
}



wss.on('connection', function (ws) {
    var sendStockUpdates = function (ws) {
        //console.log("11", ws.readyState);
        if (ws.readyState == 1) {
            var stocksObj = {};
           // console.log("第一次");
            handleGetData();

            console.log("dd" + isTrue);
            if (isTrue) {
                console.log("发送前");
                ws.send(JSON.stringify(numData));
            }
        }
    }
    
    ws.on('message', function (message) {
        //var stockRequest = JSON.parse(message);
        var stockRequest = message;
        console.log("收到消息", stockRequest);
        //clientStocks = stockRequest['stocks'];
        //sendStockUpdates(ws);

        //setInterval第一次执行时会延迟对应时间，所以这里先执行该方法；如果每秒轮询就不用下面操作，下面的请求接口还有回调需要时间来的延迟
        //if (ws.readyState == 1) {
        //    var stocksObj = {};
        //    handleGetData();
        //    console.log("dd" + isTrue);
        //    if (!isTrue) {
        //        console.log("发送前");
        //        ws.send(JSON.stringify(numData));
        //    }
        //}

        clientStockUpdater = setInterval(function () {
           // console.log("第二次");
            sendStockUpdates(ws);
        }, 1000);
    });
    ws.on('close', function () {
        if (typeof clientStockUpdater !== 'undefined') {
            clearInterval(clientStockUpdater);
        }
    });
});

备注：

1、cmd打开命令窗口，进入到nodejs安装目录下，执行全局安装request模块命令：

npm i request -g 。

2、进入到项目所在目录执行启动node服务命令：node server.js。

3、再浏览器打开页面初始化并创建websocket长连接，实时监听数据变化。

免责声明！

本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。

猜您在找 Java调用第三方系统接口获取数据 java中调用第三方接口获取数据的方式小程序的数据实时更新websocket长连接 Vue+WebSocket 实现页面实时刷新长连接 Vue+WebSocket 实现页面实时刷新长连接调用第三方接口 Java中调用第三方api接口实现轮询、长轮询与Web Socket的前端实现页面数据实时 NETCORE - 调用第三方接口 vue 调用第三方接口配置

nodejs 搭建websocket长连接服务 实现前端页面调用第三方接口获取数据的实时更新

免责声明！

nodejs 搭建websocket长连接服务实现前端页面调用第三方接口获取数据的实时更新