NATS_07：NATS之top工具監控以及測量調優工具
概述
你可以使用 nats-top 來實現類似於 linux 中 top 命令的實時監控 nats 服務；
可以使用 nats 提供的工具來進行鍼對性的調優。
安裝nats-top
| 1 |
$ go get github.com/nats-io/nats-top
|
如果沒有許可權執行，那麼需要以以下方式執行
| 1 |
$ sudo -E go get github.com/nats-io/nats-top
|
啟動相關服務
啟動 NATS 服務並激活對應的監控埠
| 1 |
$ gnatsd -m 8222
|
執行 nats-top 來實時監控 nats 服務
| 1 |
$ nats-top
|
效果如下圖所示：
如上圖所示，此時有兩個客戶端在執行著，nats-top 會實時對這兩個客戶端進行監控，最上面的資訊列印的是 nats-server 相關的資訊，包含：負載、記憶體使用情況、輸入流、輸出流等資訊。如果此時再開啟新的客戶端，隔2～3秒之後上圖就會出現第 3 個客戶端資訊。
nats-top 引數介紹
| 1 |
nats-top [-s server] [-m monitor] [-n num_connections] [-d delay_in_secs] [-sort by]
|
對上面命令中的引數進行一一講解：
| Description | |
|---|---|
-m monitor |
Monitoring http port from gnatsd. |
-n num_connections |
Limit the connections requested to the server (default 1024). |
-d delay_in_secs |
Screen refresh interval (default 1 second). |
-sort by |
Field to use for sorting the connections (see below). |
nats-top 實際使用
1. 在實時監控介面中，輸入字母 o 即可進行指定欄位排序，如上圖所示，其中對應的欄位都為大寫，你要指定的排序欄位只需要輸入小寫的就會按照正排重新排序。可以排序的欄位有：
cid, subs, pending, msgs_to, msgs_from, bytes_to, bytes_from, lang, version
2. 在實時監控介面中，輸入字母 s 即可觸發，使得只顯示連線的訂閱者監控資訊
3. 在 nats-top 介面中，可以使用字母 q 進行安全退出，這和 linux 中的 top 命令退出是一致的
4. 在 nats-top 介面中，可以使用字元 ？來進行檢視具體的引數資訊 (也就是我們常說的幫助文件)
5. 當然，在啟動 nats-top 的時候可以指定查詢規則，顯示自己關心的連線資訊，例如如下所示，只取出最大訂閱者連線數的服務資訊
| 1 |
$ nats-top -n 1 -sort subs
|
NATS 效能測試工具(nats-bench)
NATS 是快速、輕量級和設定效能優先順序的服務，並且NATS為測量和調優效能提供了相應的工具。
1. 安裝調優測量工具nats-bench
go-nats安裝檔案中以及包含了這個工具，只需要我們找到對應檔案進行命令安裝即可。需要我們進入它自帶的例子中，找到：examples/nats-bench.go 執行即可。
| 1 2 |
$ cd $GOPATH/src/github.com/nats-io/go-nats/examples/
$ go install nats-bench.go
|
執行上面的命令如果提示沒有找到對應的 GOBIN，那麼需要我們設定一下 GOBIN 的路徑。預設這個為空，不影響我們正常程式執行，但是 nats-bench 是需要這個路徑的，說白了就是需要告訴它我安裝的 nats-bench 需要放在哪個地方。我是放在了和 $GOPATH/bin 下了。
| 1 |
$ vim ~/.bash_profile
|
GOPATH="$PRE_GOPATH/myblog"
GOBIN="$GOPATH/bin"
export GOPATH=$GOPATH
export GOBIN=$GOBIN
修改完之後 source ～/.bash_profile 即可，之後再執行 go install nats-bench.go 即可成功。
執行 nats-bench 命令會提示相關的幫助資訊：
nats-bench -h
Usage: nats-bench [-s server (nats://localhost:4222)] [--tls] [-np NUM_PUBLISHERS] [-ns NUM_SUBSCRIBERS] [-n NUM_MSGS] [-ms MESSAGE_SIZE] [-csv csvfile] <subject>得到以上資訊說明 nats-bench 已經安裝成功，剩下的我們就可以開始測試和驗證了。
2. publisher 生產能力測試
讓我們執行一個測試,看看一個釋出者可以釋出十萬條16位元組訊息NATS伺服器有多快。
$ nats-bench -np 1 -n 100000 -ms 16 foo
讓我們看一下一個釋出者客戶端每秒傳送訊息的數量與負載：
Starting benchmark [msgs=100000, msgsize=16, pubs=1, subs=0]
Pub stats: 7,055,644 msgs/sec ~ 107.66 MB/sec
那麼讓我們再增加發布訊息到一千萬條資料，再來看一下具體輸出資訊：
$ nats-bench -np 1 -n 10000000 -ms 16 foo
Starting benchmark [msgs=10000000, msgsize=16, pubs=1, subs=0]
Pub stats: 7,671,570 msgs/sec ~ 117.06 MB/sec
3. 生產者／消費者 能力測試
我們使用 nats-bench 命令同時模擬執行一個生產者 和 一個消費者 客戶端，傳送和接收16 byte 的共十萬條資料，結果會顯示對應的聚合結果即會分別打印出生產者 和 消費者各自的吞吐量情況：
$ nats-bench -np 1 -ns 1 -n 100000 -ms 16 foo
執行結果如下：
Starting benchmark [msgs=100000, msgsize=16, pubs=1, subs=1]
NATS Pub/Sub stats: 3,586,227 msgs/sec ~ 54.72 MB/sec
Pub stats: 2,244,296 msgs/sec ~ 34.25 MB/sec
Sub stats: 1,793,113 msgs/sec ~ 27.36 MB/sec
4. 1個生產者／n個消費者(或者n個生產者／1個消費者) 能力測試
當指定多個生產者或者多個消費者的時候，nats-bench 測試結果中會打印出生產者、消費者各個吞吐量詳情，並帶有處理資料 最大條數／最小條數／平均值 以及 每個的偏離誤差等。
<1. 以下執行 1個釋出者／5個消費者 總共資料條數為一千萬的驗證測試
$ nats-bench -np 1 -ns 5 -n 10000000 -ms 16 foo
列印結果如下所示：
Starting benchmark [msgs=10000000, msgsize=16, pubs=1, subs=5]
NATS Pub/Sub stats: 5,730,851 msgs/sec ~ 87.45 MB/sec
Pub stats: 955,279 msgs/sec ~ 14.58 MB/sec
Sub stats: 4,775,709 msgs/sec ~ 72.87 MB/sec
[1] 955,157 msgs/sec ~ 14.57 MB/sec (10000000 msgs)
[2] 955,150 msgs/sec ~ 14.57 MB/sec (10000000 msgs)
[3] 955,157 msgs/sec ~ 14.57 MB/sec (10000000 msgs)
[4] 955,156 msgs/sec ~ 14.57 MB/sec (10000000 msgs)
[5] 955,153 msgs/sec ~ 14.57 MB/sec (10000000 msgs)
min 955,150 | avg 955,154 | max 955,157 | stddev 2 msgs
<2. 以下執行 5個釋出者／1個消費者 總共資料條數為1千萬的測試驗證(這種實際情況很少，一般都是消費者多於生產者，具體的大家可以思考一下)
當指定多個生產者時，nats會根據 -n 總資料量來平均分配在這多個生產者上進行分發
$ nats-bench -np 5 -ns 1 -n 10000000 -ms 16 foo
列印結果如下所示：
Starting benchmark [msgs=10000000, msgsize=16, pubs=5, subs=1]
NATS Pub/Sub stats: 3,279,469 msgs/sec ~ 50.04 MB/sec
Pub stats: 1,642,753 msgs/sec ~ 25.07 MB/sec
[1] 330,667 msgs/sec ~ 5.05 MB/sec (2000000 msgs)
[2] 329,542 msgs/sec ~ 5.03 MB/sec (2000000 msgs)
[3] 329,105 msgs/sec ~ 5.02 MB/sec (2000000 msgs)
[4] 328,667 msgs/sec ~ 5.02 MB/sec (2000000 msgs)
[5] 328,553 msgs/sec ~ 5.01 MB/sec (2000000 msgs)
min 328,553 | avg 329,306 | max 330,667 | stddev 764 msgs
5. n個生產者／m個消費者能力測試
以下指定 5個生產者／5個消費者 來進行驗證測試
$ nats-bench -np 5 -ns 5 -n 10000000 -ms 16 foo
列印結果如下所示：
Starting benchmark [msgs=10000000, msgsize=16, pubs=5, subs=5]
NATS Pub/Sub stats: 6,716,465 msgs/sec ~ 102.49 MB/sec
Pub stats: 1,119,653 msgs/sec ~ 17.08 MB/sec
[1] 226,395 msgs/sec ~ 3.45 MB/sec (2000000 msgs)
[2] 225,955 msgs/sec ~ 3.45 MB/sec (2000000 msgs)
[3] 225,889 msgs/sec ~ 3.45 MB/sec (2000000 msgs)
[4] 224,552 msgs/sec ~ 3.43 MB/sec (2000000 msgs)
[5] 223,933 msgs/sec ~ 3.42 MB/sec (2000000 msgs)
min 223,933 | avg 225,344 | max 226,395 | stddev 937 msgs
Sub stats: 5,597,054 msgs/sec ~ 85.40 MB/sec
[1] 1,119,461 msgs/sec ~ 17.08 MB/sec (10000000 msgs)
[2] 1,119,466 msgs/sec ~ 17.08 MB/sec (10000000 msgs)
[3] 1,119,444 msgs/sec ~ 17.08 MB/sec (10000000 msgs)
[4] 1,119,444 msgs/sec ~ 17.08 MB/sec (10000000 msgs)
[5] 1,119,430 msgs/sec ~ 17.08 MB/sec (10000000 msgs)
min 1,119,430 | avg 1,119,449 | max 1,119,466 | stddev 12 msgs
天道酬勤 循序漸進 技壓群雄