Github 开源项目（一）websocketd （实战：实时监控服务器内存信息）

时间 2019-12-05

标签 github 开源项目 websocketd 实战实时监控服务器内存信息栏目 Git 繁體版

原文原文链接

websocketd 是WebSocket守护进程，它负责处理WebSocket链接，启动您的程序来处理WebSockets，并在程序和Web浏览器之间传递消息。javascript

安装：websocketd

wget https://github.com/joewalnes/websocketd/releases/download/v0.2.12/websocketd-0.2.12-linux_amd64.zip

unzip  websocketd-0.2.12-linux_amd64.zip

解压后生成这个文件：websocketdphp

复制该文件到 /usr/bin目录下，修改环境变量html

sudo cp websocketd /usr/bin/websocketd sudo vim /etc/profile export PATH=$PATH:/usr/bin/websocketd

可能出现的错误：若是修改了/etc/profile，那么编辑结束后执行source profile 或执行点命令 ./profile,PATH的值就会当即生效了，可是会提示如下错误：java

#source /etc/profile   以后为何会出现
command not found

解决办法，直接切换到root 用户模式既可，再次执行source profile 就能够了，输入help 看是否配置合适，以下所示：jquery

tinywan@tinywan:~/shell$ websocketd --help websocketd (0.2.12 (go1.6 linux-amd64) --) websocketd is a command line tool that will allow any executable program that accepts input on stdin and produces output on stdout to be turned into a WebSocket server. Usage: Export a single executable program a WebSocket server: websocketd [options] COMMAND [command args] Or, export an entire directory of executables as WebSocket endpoints: websocketd [options] --dir=SOMEDIR Options: --port=PORT HTTP port to listen on. --address=ADDRESS Address to bind to (multiple options allowed) Use square brackets to specify IPv6 address. Default: "" (all)

开启WebSocketd 服务^Tinywan

tinywan@tinywan:~/shell$ websocketd --port=63800 ./count.sh Mon, 08 May 2017 17:26:50 +0800 | INFO   | server     |  | Serving using application   : ./count.sh Mon, 08 May 2017 17:26:50 +0800 | INFO   | server     |  | Starting WebSocket server   : ws://tinywan:8080/

测试代码：count.shlinux

#!/bin/bash for ((COUNT = 1; COUNT <= 10; COUNT++)); do
  echo $COUNT sleep 1
done

运行脚本时你可能会遇到如下错误：git

root@TinywanAliYun:/home/www/bin# websocketd --port=63800 ./count.sh Unable to locate specified COMMAND './count.sh' in OS path. Usage: Export a single executable program a WebSocket server: websocketd [options] COMMAND [command args] Or, export an entire directory of executables as WebSocket endpoints: websocketd [options] --dir=SOMEDIR Or, show extended help message using: websocketd --help

请赋予权限，使其可执行：github

$ chmod +x ./count.sh

随便打开一个浏览器，在console中输入一下代码测试：web

var ws = new WebSocket('ws://192.168.18.12:63800/'); ws.onopen = function() { console.log('CONNECT'); }; ws.onclose = function() { console.log('DISCONNECT'); }; ws.onmessage = function(event) { console.log('MESSAGE: ' + event.data); };

（1）测试结果以下所示：sql

（2）新创建一个客户端测试client.html

<!doctype html>
<html lang="">
<head>
    <meta charset="utf-8">
    <meta name="description" content="">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <meta http-equiv="x-ua-compatible" content="ie=edge">
    <title>websocketd</title>
</head>
<body>
<h2>websocketd 客户端的简单测试</h2>
<pre id="log"></pre>
<script>
    // helper function: log message to screen
    function log(msg) { document.getElementById('log').textContent += msg + '\n'; } // setup websocket with callbacks
    var ws = new WebSocket('ws://192.168.18.12:8080/'); ws.onopen = function() { console.log('CONNECT'); }; ws.onclose = function() { console.log('DISCONNECT'); }; ws.onmessage = function(event) { console.log('MESSAGE: ' + event.data); }; </script>
</body>
</html>

在查看结果信息，查看结果已经ok

查看服务端信息

我本机IP地址为，也就是client.html客户端

websocketd --port=9501 --devconsole luajit ./json_ws.lua

》》》实际案例，使用WebSocketd 实时监控内存信息

一、编写脚本，system_info_send_websocketd.sh

#!/bin/bash PATH=/usr/local/bin:/usr/bin:/bin SHELL_DIR="/home/www/bin" SHELL_NAME="system_info_websocketd" SHELL_TIME=$(date '+%Y-%m-%d') SHELL_LOG="${SHELL_DIR}/${SHELL_NAME}-${SHELL_TIME}.log" REDIS_MEMORY_KEYS_NAME="REDIS_MEMORY_INFO:001" REDIS_DISH_KEYS_NAME="REDIS_DISH_INFO:001"

while(true) do FIND_DATA=$(cat /proc/meminfo | grep "MemFree:" | awk '{print $2}') echo  "[$SHELL_TIME]: FIND_DATA = $FIND_DATA INSERT_RES = ${INSERT_RES} CUT_LIST_LEN = ${CUT_LIST_LEN}" >> $SHELL_LOG echo   '{"data":'"${FIND_DATA}"',"errcode":0,"errmsg":0}'
        sleep 2
done

二、客户端实时监控代码：

<div class="panel-footer" id="container" style="width: 100%; height: 400px; margin: 0 auto"></div>
<script language="JavaScript">
    //数据获取
    var moniServerIp = "{{moniServerIp}}"; var moniServerSshUsername = "{$moniServerSshUsername}"; var moniServerSshPassword = "{$moniServerSshPassword}"; var wsServerIP = "127.0.0.1"; var wsServerPort = "12380"; var moniMehtod = "server02"; var moniInterval = 1; var moniDataUnit = 'MB'; var wsData = 0.0; wsSend = { "action": moniMehtod, "name": "tinywan", }; $(document).ready(function () { //----------WebSocket部分--------------
        var ws = new WebSocket("ws://" + wsServerIP + ":" + wsServerPort); ws.onopen = function () { ws.send(JSON.stringify(wsSend)); }; ws.onclose = function () { console.log('连接已断开'); ws.close(); }; ws.onmessage = function (e) { var response = JSON.parse(e.data); if (Number(response.errcode) !== 0) { console.log(String(response.errmsg)); ws.close(); alert('出错啦!' + String(response.errmsg)); return; } var divisor = 1; switch (moniDataUnit.toLocaleLowerCase()) { case 'mb': divisor = 1024; break; } wsData = response.data / divisor; console.log("收到服务端的消息：" + wsData); }; //----------highcharts的图标插件部分--------------
 Highcharts.setOptions({ global: { useUTC: false } }); $('#container').highcharts({ chart: { type: 'spline', animation: Highcharts.svg, // don't animate in old IE
 marginRight: 10, events: { load: function () { // set up the updating of the chart each second
                        var series = this.series[0]; setInterval(function () { // current time
                            var x = (new Date()).getTime(), y = wsData * 1.00; series.addPoint([x, y], true, true); }, 2000); } } }, title: { text: '服务器【' + moniServerIp + '】内存指标(单位:' + moniDataUnit + ')' }, xAxis: { type: 'datetime', tickPixelInterval: 150 }, yAxis: { title: { text: 'MemFree' }, plotLines: [{ value: 0, width: 1, color: '#808080' }] }, tooltip: { formatter: function () { return '<b>' + this.series.name + '</b><br/>' + Highcharts.dateFormat('%Y-%m-%d %H:%M:%S', this.x) + '<br/>' + Highcharts.numberFormat(this.y, 2); } }, legend: { enabled: false }, exporting: { enabled: false }, series: [{ name: 'MemFree指标', data: (function () { // generate an array
                    var data = [], time = (new Date()).getTime(), i; for (i = -19; i <= 0; i += 1) { data.push({ x: time + i * 1000, y: wsData }); } return data; }()) }] }); }); </script>
<script src="http://apps.bdimg.com/libs/jquery/2.1.4/jquery.min.js"></script>
<script src="http://code.highcharts.com/highcharts.js"></script>

三、测试结果：

四、客户端可能会出现超时连接的，可使用 ReconnectingWebSocket

 var ws = new ReconnectingWebSocket("ws://" + wsServerIP + ":" + wsServerPort);

》》》》》》》》》》》》参数详解

（1）参数一：--staticdir=.

--staticdir=.  Allow websocketd to serve count.html as a static file
//容许websocketd做为静态文件提供count.html

这个参数是什么意思来，就是在当前项目指定通知执行的语言脚本文件(count.sh)同名的count.html做为静态文件，直接使用http访问

当前目录

count.sh 文件（tinywan@tinywan:~/Go/websocket$ cat count.sh）

#!/bin/bash # Count from 1 to 10, pausing for a second between each iteration. for COUNT in $(seq 1 10); do
  echo $COUNT sleep 1
done

count.html 文件

<!DOCTYPE html>
<html>
  <head>
    <title>websocketd count example</title>
    <style> #count { font: bold 150px arial; margin: auto; padding: 10px; text-align: center;
      }
    </style>
  </head>
  <body>

    <div id="count"></div>

    <script>
      var ws = new WebSocket('ws://192.168.18.180:8080/'); ws.onopen = function() { document.body.style.backgroundColor = '#cfc'; }; ws.onclose = function() { document.body.style.backgroundColor = null; }; ws.onmessage = function(event) { document.getElementById('count').textContent = event.data; }; </script>

  </body>
</html>

打开谷歌浏览器，在地址栏输入：http://192.168.18.180:8080/

点击count.html后的效果图

（2）参数二： --devconsole

　　该--devconsole标志使内置的控制台websocketd与WebSocket端点手动交互。

　　指向浏览器http://localhost:8080/，您将看到控制台。按复选框链接。

请注意，您不能同时使用--devconsole和--staticdir。开发控制台旨在提供临时用户界面，直到您构建了真实的用户界面。

开始测试：

打开浏览器测试，发送一个空数据是没办法发送的，因为咱们没有指定开启那个一个语言脚本文件充当WebSocket 服务器，为咱们提供客户端的服务

指定/home/tinywan/Go/websocket 目录下的 count.sh 做为服务文件，继续测试的结果以下所示

Websocket 代理服务器

一、没代理以前访问

var ws = new WebSocket('ws://192.168.18.188:63800'); ws.onopen = function() { console.log('CONNECT'); }; ws.onclose = function() { console.log('DISCONNECT'); }; ws.onmessage = function(event) { console.log('MESSAGE: ' + event.data); };

二、代理以后访问

var ws = new WebSocket('ws://192.168.18.188:8087/chat/'); ws.onopen = function() { console.log('CONNECT'); }; ws.onclose = function() { console.log('DISCONNECT'); }; ws.onmessage = function(event) { console.log('MESSAGE: ' + event.data); };

守护进程运行

nohup websocketd --port=63800 /home/www/bin/system_info_send_all_websocketd.sh >/dev/null  2>&1 &

加载证书

 sudo websocketd --port=6500 --ssl --sslcert="/etc/letsencrypt/live/www.tinywan.top/fullchain.pem" -- sslkey="/etc/letsencrypt/live/www.tinywan.top//privkey.pem" /home/www/bin/system_info_send_all_websocketd.s

wss 协议测试

var ws = new WebSocket('wss://www.tinywan.top:6500'); ws.onopen = function() { console.log('CONNECT'); }; ws.onclose = function() { console.log('DISCONNECT'); }; ws.onmessage = function(event) { console.log('MESSAGE: ' + event.data); };

实时监控服务器日志信息

服务端执行脚本执行脚本

$ websocketd --port=63800 ./system_info_send_all_websocketd.sh 
Sun, 09 Sep 2018 14:34:55 +0800 | INFO   | server     |  | Serving using application   : .../system_info_send_all_websocketd.sh 
Sun, 09 Sep 2018 14:34:55 +0800 | INFO   | server     |  | Starting WebSocket server   : ws://iZ2zec3dge6rwz2uw4tveuZ:63800/
Sun, 09 Sep 2018 14:35:30 +0800 | ACCESS | session    | url:'http://159.110.213.20:63800/websocket/' id:'1536474930878947882' remote:'60.186.221.134' command:'/home/www/bin/system_info_send_all_websocketd.sh' origin:'file://' | CONNECT

本地随便新建如下文件内容

<!DOCTYPE html>
<html>

<head>
    <style>
        body{
            background-color: #0e1012;color: #ffffff;
        }
        *{
            margin: 0; padding: 0;
        }
        #msg{
            overflow:auto; border:2px solid #303030; color:#ffffff; background-color: #2b2b2b; font-size: 13px; position: absolute; left: 8px; right: 8px; bottom: 8px; top: 40px; word-break:
break-all;
        }
        #log{
            position: fixed; top: 0; left: 0; width: 100%; height: 40px; text-align: left; margin: 4px 0 0 8px;
        }
        #log b{
            font-size: 26px;
        }
        #msgBtn{
            padding: 5px 10px; border: none; background: #777; float: right; margin: 0 16px 0 0;
        }
    </style>
</head>

<body>
    <div id="log"><span><b>服务器实时日志</b></span><button id="msgBtn" type="button">清空</button></div>
    <div id="msg">
        <ul class="list"></ul>
    </div>
    <script src="http://libs.baidu.com/jquery/1.9.1/jquery.min.js"></script>
    <script>
        $(document).ready(function () {
            if (!window.WebSocket) {
                if (window.MozWebSocket) {
                    window.WebSocket = window.MozWebSocket;
                } else {
                    $('#msg').append("<p>你的浏览器不支持websocket</p>");
                }
            }
            var ws = new WebSocket('ws://www.tinywan.com:63800/websocket/');
            ws.onopen = function (evt) {
                $('.list').append('<li>websocket链接成功</li>');
            }
            ws.onmessage = function (evt) {
                $('.list').append('<li>' + evt.data + '</li>');
                setTimeout(function () {
                    $('#msg').scrollTop($('.list').height() - $('#msg').height());
                }, 100)
            }
            $("#msgBtn").click(function () {
                $(".list").html("");
            })
        });
    </script>
</body>
</html>

浏览器打开log.html效果：

Nginx 代理配置

server {
    listen 443 ssl http2;
    server_name wallet.www.top;

    ssl_certificate /etc/letsencrypt/wallet.www.top/full_chain.pem;
    ssl_certificate_key /etc/letsencrypt/wallet.www.top/private.key;

    location /wssd
    {
        proxy_pass http://lnmp-php:8888;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "Upgrade";
        proxy_set_header X-Real-IP $remote_addr;
        proxy_read_timeout 600;

    }
}

链接方式

var ws = new WebSocket('wss://wallet.www.top/wssd');

运行一个PHP案例

#!/usr/local/php/bin/php
<?php

require_once './vendor/autoload.php';

$db = new MysqliDb ([
    'host' => '127.0.0.1',
    'username' => 'test',
    'password' => 'test',
    'db' => 'test',
    'port' => 3308,
    'prefix' => 'cl_',
    'charset' => 'utf8'
]);

$params = [1, -1];
while (true){
    $users = $db->rawQuery("SELECT count(*) as nums FROM cl_investor WHERE is_order_taking = ? AND ws_online = ?", $params);
    echo json_encode(['counts'=>$users[0]['nums']]). "\n";
    usleep(5000000);
}

注意：开头的PHP路径为绝对路径

Github 开源项目（一）websocketd （实战：实时监控服务器内存信息）

安装：websocketd

开启WebSocketd 服务Tinywan

》》》实际案例，使用WebSocketd 实时监控内存信息

》》》》》》》》》》》》 参数详解

开启WebSocketd 服务^Tinywan

》》》》》》》》》》》》参数详解