NSQ部署

<?php
/**
 * Created by PhpStorm.
 * User: Lenovo
 * Date: 2015/8/22
 * Time: 18:05
 */

error_reporting(E_ALL || ~E_NOTICE); //ÏÔʾ³ýÈ¥ E_NOTICE Ö®ÍâµÄËùÓдíÎóÐÅÏ¢

// http://192.168.30.54:4161/nodes

function queryLookupdForNsqd($lookupAddrs) {
    foreach ($lookupAddrs as $addr) {
        $text = file_get_contents("http://$addr/nodes");
        // $nodes¸ñʽ
        // {"status_code":200,"status_txt":"OK","data":{"producers":[{"remote_address":"192.168.30.54:38631","hostname":"localhost.localdomain","broadcast_address":"192.168.30.54","tcp_port":4150,"http_port":4151,"version":"0.3.6-alpha","tombstones":[false,false],"topics":["demo","hancj"]},{"remote_address":"192.168.30.55:35621","hostname":"localhost.localdomain","broadcast_address":"192.168.30.55","tcp_port":4150,"http_port":4151,"version":"0.3.6-alpha","tombstones":[false,false],"topics":["demo","hancj"]}]}}
        $nodes = json_decode($text, true);

        $arrNode = array();
        foreach ($nodes[‘data‘][‘producers‘] as $nsqd) {
            $addr = "{$nsqd[‘broadcast_address‘]}:{$nsqd[‘http_port‘]}";
            //echo $addr, PHP_EOL;
            $arrNode[] = $addr;
        }

        return $arrNode;
    }
}

function queryNsqd($nsqdAddr) {
    $httpAddr = "http://$nsqdAddr/stats?format=json";
    // infoµÄ¸ñʽ
    // {"status_code":200,"status_txt":"OK","data":{"version":"0.3.6-alpha","health":"OK","start_time":1440233123,"topics":[{"topic_name":"demo","channels":[{"channel_name":"nsq_to_http","depth":0,"backend_depth":0,"in_flight_count":0,"deferred_count":0,"message_count":7010004,"requeue_count":1046,"timeout_count":649,"clients":[],"paused":false,"e2e_processing_latency":{"count":0,"percentiles":null}}],"depth":0,"backend_depth":0,"message_count":7010004,"paused":false,"e2e_processing_latency":{"count":0,"percentiles":null}},{"topic_name":"hancj","channels":[{"channel_name":"nsq_to_http","depth":1,"backend_depth":0,"in_flight_count":0,"deferred_count":0,"message_count":0,"requeue_count":0,"timeout_count":0,"clients":[],"paused":false,"e2e_processing_latency":{"count":0,"percentiles":null}}],"depth":0,"backend_depth":0,"message_count":0,"paused":false,"e2e_processing_latency":{"count":0,"percentiles":null}}]}}
    $info = json_decode(file_get_contents($httpAddr), true);

    $nsqd = array(‘health‘ => $info[‘data‘][‘health‘], ‘channels‘ => 0, ‘topics‘ => 0);

    foreach ($info[‘data‘][‘topics‘] as $topic) {
        $nsqd[‘topics‘] += 1;
        foreach ($topic[‘channels‘] as $channel) {
            $nsqd[‘channels‘] += 1;
            if ($channel[‘channel_name‘] == ‘nsq_to_http‘) {
                if (!$nsqd[‘max_channel‘] || $nsqd[‘max_channel‘][‘depth‘] < $channel[‘depth‘]) {
                    $nsqd[‘max_channel‘] = $channel;
                }
            }
        }
    }

    return $nsqd;
}

function main($argv) {
    if (count($argv) < 3) {
        echo "Usage: {$argv[0]} nsqd_count nsqlookupd_address...\n";
        exit;
    }

    $nsqdCount = $argv[1];
    $nsqlookupd = array_slice($argv, 2);

    $now = date(‘Y-m-d H:i:s‘);
    $arrNSQD = queryLookupdForNsqd($nsqlookupd);//array("192.168.30.54:4161",));
    $warn = (count($arrNSQD) == $nsqdCount ? "off" : "on");
    echo "$now nsqd_count[" . count($arrNSQD) . "] should_be[{$nsqdCount}] warning[$warn]", PHP_EOL;
    foreach ($arrNSQD as $nsqdAddr) {
        $info = queryNsqd($nsqdAddr);

        $warn = ((!$info || $info[‘health‘] != ‘OK‘ || $info[‘max_channel‘][‘depth‘] > 100000) ? "on" : "off");
        echo "$now nsqd[$nsqdAddr] health[{$info[‘health‘]}] warning[$warn] topics[{$info[‘topics‘]}]";
        echo " channels[{$info[‘channels‘]}] depth[{$info[‘max_channel‘][‘depth‘]}]";
        echo PHP_EOL;
    }
}

main($argv);