如何使用 Node.js 解决 Cloudflare 挑战

npm install axios

const axios = require('axios');

// -------------------PLEASE MODIFY THESE VALUES-------------------
// 你的代理信息，格式为：http://username:password@ip:port
const PROXY = 'http://username:password@ip:port'; 
// 从CapSolver仪表板获取的API密钥
const CAPSOLVER_API_KEY = 'YourAPIKEY';
// 你想要解决Cloudflare挑战的目标网站的URL
const PAGE_URL = 'https://www.yourwebsite.com';
// ----------------------------------------------------------------


/**
 * 使用CapSolver API创建一个解决Cloudflare挑战的任务。
 * @param {string} websiteURL - 目标网站的URL。
 * @param {string} proxy - 要使用的代理。
 * @returns {Promise<string|null>} - 任务ID，如果创建失败则返回null。
 */
async function createCloudflareTask(websiteURL, proxy) {
    console.log('Creating Cloudflare task for CapSolver...');
    try {
        const response = await axios.post('https://api.capsolver.com/createTask', {
            clientKey: CAPSOLVER_API_KEY,
            task: {
                type: 'AntiCloudflareTask',
                websiteURL: websiteURL,
                proxy: proxy
            }
        });
        if (response.data.errorId > 0) {
            console.error(`Failed to create task: ${response.data.errorDescription}`);
            return null;
        }
        console.log(`Task created successfully. Task ID: ${response.data.taskId}`);
        return response.data.taskId;
    } catch (error) {
        console.error(`An error occurred while creating the task: ${error}`);
        return null;
    }
}

/**
 * 轮询任务结果。
 * @param {string} taskId - CapSolver返回的任务ID。
 * @returns {Promise<object|null>} - 解决方案对象，如果失败则返回null。
 */
async function getTaskResult(taskId) {
    console.log(`Getting result for task ID ${taskId}...`);
    let solution = null;

    while (!solution) {
        await new Promise(resolve => setTimeout(resolve, 3000)); // 等待3秒

        try {
            const response = await axios.post('https://api.capsolver.com/getTaskResult', {
                clientKey: CAPSOLVER_API_KEY,
                taskId: taskId
            });

            if (response.data.errorId > 0) {
                console.error(`Failed to get result: ${response.data.errorDescription}`);
                return null;
            }

            if (response.data.status === 'ready') {
                console.log('Solution retrieved successfully!');
                solution = response.data.solution;
            } else if (response.data.status === 'processing') {
                console.log('Task is still processing, please wait...');
            } else if (response.data.status === 'failed') {
                console.error(`Task processing failed: ${response.data.errorDescription}`);
                return null;
            }
        } catch (error) {
            console.error(`An error occurred while getting the result: ${error}`);
            return null;
        }
    }
    return solution;
}

/**
 * 执行整个过程的主函数。
 */
async function main() {
    console.log('Starting to solve Cloudflare challenge...');
    
    const taskId = await createCloudflareTask(PAGE_URL, PROXY);
    if (!taskId) {
        console.log('Could not create task, exiting.');
        return;
    }

    const solution = await getTaskResult(taskId);
    if (!solution) {
        console.log('Could not retrieve solution, exiting.');
        return;
    }

    console.log('Solution details obtained:');
    console.log(solution);

    // 现在你可以使用获取的cookies和user-agent来访问目标网站。
    // solution对象包含' url ', ' status ', ' headers ', ' cookies ', ' userAgent '。
    
    // 示例：如何使用获取的cookies和user-agent发起请求
    try {
        const cfCookie = solution.cookies.map(cookie => `${cookie.name}=${cookie.value}`).join('; ');
        
        console.log('\nAccessing the target page with the obtained cookies and user-agent...');
        const pageResponse = await axios.get(PAGE_URL, {
            headers: {
                'User-Agent': solution.userAgent,
                'Cookie': cfCookie
            },
            // 建议为后续请求使用一个启用代理的axios实例。
            proxy: false, 
        });

        console.log(`\nSuccessfully accessed! Page status code: ${pageResponse.status}`);
        // console.log('Page content:', pageResponse.data); // 取消注释以查看页面内容

    } catch (error) {
        console.error(`\nError accessing page with solution: ${error.response ? error.response.status : error.message}`);
    }
}

main();