zabbix（［`z?biks］）是一個基于WEB界面的提供分布式系統(tǒng)監(jiān)視以及網(wǎng)絡(luò)監(jiān)視功能的企業(yè)級的開源解決方案。zabbix能監(jiān)視各種網(wǎng)絡(luò)參數(shù)，保證服務(wù)器系統(tǒng)的安全運營；并提供靈活的通知機制以讓系統(tǒng)管理員快速定位/解決存在的各種問題。

協(xié)議內(nèi)容

《HEADER》 - “ZBXD\x01” （5 bytes）

《DATALEN》 - data length （8 bytes）。 1 will be formatted as 01/00/00/00/00/00/00/00 （eight bytes in HEX， 64 bit number）《DATA》

《DATA》： json格式，內(nèi)容又分為主動檢查和被動檢查

為了避免Zabbix內(nèi)存耗盡，Zabbix限制每個連接最多使用128M內(nèi)存

被動檢查

Server request

《item key》\n

Agent response

《HEADER》《DATALEN》《DATA》［\0《ERROR》］

［］是可選的僅在不支持的items時發(fā)送

主動檢查

（1）獲取相關(guān)items的列表

Agent request

《HEADER》《DATALEN》{

“request”：“active checks”，

“host”：“《hostname》”

}

Server response

《HEADER》《DATALEN》{

“response”：“success”，

“data”：［

{

“key”：“agent.version”，

“delay”：600，

“l(fā)astlogsize”：0，

“mtime”：0

}，

{

“key”：“vfs.fs.size［/nono］”，

“delay”：600，

“l(fā)astlogsize”：0，

“mtime”：0

}

］

}

（2）發(fā)送收集的數(shù)據(jù)

Agent send

《HEADER》《DATALEN》{

“request”：“agent data”，

“data”：［

{

“host”：“《hostname》”，

“key”：“agent.version”，

“value”：“2.4.0”，

“clock”：1400675595，

“ns”：76808644

}，

{

“host”：“《hostname》”，

“key”：“vfs.fs.size［/nono］”，

“state”：1，

“value”：“Cannot obtain filesystem information： ［2］ No such file or directory”，

“clock”：1400675595，

“ns”：78154128

}

］，

“clock”： 1400675595，

“ns”： 78211329

}

Server response

《HEADER》《DATALEN》{

“response”：“success”，

“info”：“processed： 2; failed： 0; total： 2; seconds spent： 0.003534”

}

Zabbix Trapper發(fā)生在主動檢查的第二個步驟，Agent發(fā)送數(shù)據(jù)到Server（zabbix_sender），Trapper items必須事先定義好

python模擬的zabbix_sender

#！/usr/bin/python

#-*- coding:utf8 -*-

__author__ = ‘pdd’

__date__ = ‘2016/11/28’

‘’‘ script simulate zabbix_sender ’‘’

import sys

import json

import time

import struct

import socket

import argparse

parser = argparse.ArgumentParser（description=‘script simulate zabbix_sender’）

parser.add_argument（‘-z’，‘--server’，dest=‘server’，action=‘store’，help=‘Zabbix server ip’）

parser.add_argument（‘-p’，‘--port’，dest=‘port’，action=‘store’，help=‘Zabbix server port’，default=10051，type=int）

parser.add_argument（‘-s’，‘--host’，dest=‘host’，action=‘store’）

parser.add_argument（‘-k’，‘--key’，dest=‘key’，action=‘store’，help=‘item key’）

parser.add_argument（‘-o’，‘--value’，dest=‘value’，action=‘store’，help=‘item value’）

args = parser.parse_args（）

class Metric（object）：

def __init__（self， host， key， value）：

self.host = host

self.key = key

self.value = value

def __repr__（self）：

result = ‘Metric（%r， %r， %r）’ % （self.host， self.key， self.value）

return result

def send_to_zabbix（）：

j = json.dumps

m = Metric（args.host， args.key， args.value）

clock = （‘%d’ % time.time（））

metrics = ‘{“host”：%s，“key”：%s，“value”：%s，“clock”：%s}’ % （j（m.host）， j（m.key）， j（m.value）， j（clock））

json_data = ‘{“request”：“sender data”，“data”：［%s］}’ % metrics

data_len = struct.pack（‘《Q’， len（json_data））

packet = ‘ZBXD\x01’ + data_len + json_data

try：

zabbix = socket.socket（）

zabbix.connect（（args.server， args.port））

zabbix.sendall（packet）

resp_hdr = zabbix.recv（13）

resp_body_len = struct.unpack（‘《Q’， resp_hdr［5：］）［0］

resp_body = zabbix.recv（resp_body_len）

zabbix.close（）

resp = json.loads（resp_body）

print（resp）

except：

print（‘Error while sending data to Zabbix’）

if __name__==‘__main__’：

send_to_zabbix（）

Zabbix的主要優(yōu)勢：

a. All-In-One：Nagios和Cacti的功能全部涵蓋。

b. 配置方便

c. 監(jiān)控完備

d. 文檔完善

e. 界面直觀

整合自：CSDN、博客園、百度百科

編輯：jq