伪造zabbix server与zabbix agent通信获取数据

Zabbix agent分为两种模式：被动模式、主动模式
官网对应的地址：
https://www.zabbix.com/documentation/current/manual/appendix/items/activepassive
      被动模式是指Zabbix agent被动接受Zabbix server的轮询；
      主动模式是Zabbix agent主动将客户端监控信息发送给Zabbix server
Server的通信端口默认是10050
Agent的通信端口默认是10051（这些配置都在配置文件中，就不细说了）

说明：
-“ ZBXD”（4字节）。
-协议标志（1个字节）。0x01-Zabbix通信协议，0x02-压缩）。
-数据长度（4个字节）。1将被格式化为01/00/00/00（4字节，32位数字为Little-endian格式）。
zabbix的组件之间相互通信采用自定义的tcp协议，每次通信都会带上这个自定义头信息，所以各种语言的通信框架都不好使，要伪造就需要自己做定制。相关的官网说明地址：
https://www.zabbix.com/documentation/current/manual/appendix/protocols/header_datalen
建立连接之后，采用的json的方式传输数据，后面就比较简单了。
上代码

# encoding: utf-8
import json
import socket
import struct
import threading

data = json.dumps(
    {
        "response": "success",
        "data": [
            {
                "key": "log[/var/log/zabbix/zabbix_agentd.log]",
                "delay": 30,
                "lastlogsize": 0,
                "mtime": 0
            },
            {
                "key": "agent.version",
                "delay": 600,
                "lastlogsize": 0,
                "mtime": 0
            },
            {
                "key": "vfs.fs.size[/nono]",
                "delay": 600,
                "lastlogsize": 0,
                "mtime": 0
            }
        ]
    }
)

class Reader(threading.Thread):
    total_content = ''
    request_value = ''

    def __init__(self, client):
        threading.Thread.__init__(self)
        self.client = client

    def tuple_str(self):
        client_msg = self.client.recv(BUFSIZE)
        if "active checks" in client_msg:
            self.request_value = "active checks"
            self.total_content += client_msg
        if "agent data" in client_msg or (len(client_msg) > 0 and "active checks" not in client_msg):
            self.request_value = "agent data"
            self.total_content += client_msg
            self.tuple_str()
        return self.request_value, 0, self.total_content

class Listener(threading.Thread):
    def __init__(self, host, port):
        threading.Thread.__init__(self)
        self.port = port
        self.server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.server.bind((host, port))
        self.server.listen(0)

    def run(self):
        print ("listener started")
        while True:
            client, cltaddr = self.server.accept()
            reader = Reader(client)
            print("accept aconnect")
            if reader.tuple_str()[0] == "active checks":
                packet = "ZBXD1" + struct.pack('
                    "response": "success",
                    "info": "processed: 3; failed: 0; total: 3; seconds spent: 0.003534"
                })
                packet = "ZBXD1" + struct.pack('
                    "response": "fails"
                })
                packet = "ZBXD1" + struct.pack(' 
上述代码是基于官网的agent check说明写的，地址：
 https://www.zabbix.com/documentation/current/manual/appendix/items/activepassive
 注意：
       “lastlogsize”: 0,“mtime”: 0。这两个服务端返回值分别表示的是主动模式中，接收日志的最大行数和对应某个key接收到最新的时间，两个值有一个有值即可。agent会根据这两个值，续传后续的日志或监控项，包括server设置返回的最大值。
 比如：
 
{
    "key": "system.cpu.load[,avg5]",
    "delay": 10,
    "lastlogsize": 0,
    "mtime": 1599795928
}
 
      agent返回的system.cpu.load[,avg5]对应的最后时间，包括timestamp=1599795928时间点的数据，日志同理。
 总结：
       说说代码中的不足，本来我想截取头信息，获取数据长度，然后sorkcet通信得到指定长度后关闭通道，奈何对python理解不深，截取到的数据是乱码以及一段空格。
       本来还想写个buffer，用来缓存同一session传出来的数据，以及断线重连的数据续传，因为上述原因，打算在项目实施的时候去系统解决。
 
 反正是demo，后续还会用java去落地实施，有意见的同学，大声赐教哈。