IT技术社区_专业开发者平台_最新编程教程与解决方案 -沐辰社区

PHP项目cURL与HTTP请求

wen PHP项目 94

本文目录导读：

PHP项目cURL与HTTP请求

  1. cURL基础使用
  2. 常用cURL选项
  3. 封装cURL函数
  4. 文件上传
  5. 并发请求
  6. 错误处理和调试
  7. 使用Guzzle替代cURL
  8. 最佳实践

我来详细介绍PHP中cURL和HTTP请求的使用方法。

cURL基础使用

基本GET请求

// 初始化cURL
$ch = curl_init();
// 设置URL
curl_setopt($ch, CURLOPT_URL, "https://api.example.com/data");
// 返回响应而不是直接输出
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
// 执行请求
$response = curl_exec($ch);
// 检查错误
if(curl_errno($ch)) {
    echo 'cURL Error: ' . curl_error($ch);
}
// 关闭cURL
curl_close($ch);

POST请求

$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, "https://api.example.com/submit");
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POST, true);
// POST数据
$data = array(
    'username' => 'john',
    'password' => 'secret123'
);
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data));
$response = curl_exec($ch);
curl_close($ch);

JSON数据POST

$data = array(
    'name' => 'John Doe',
    'email' => 'john@example.com'
);
$jsonData = json_encode($data);
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, "https://api.example.com/users");
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, $jsonData);
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
    'Content-Type: application/json',
    'Content-Length: ' . strlen($jsonData)
));
$response = curl_exec($ch);
curl_close($ch);

常用cURL选项

基本配置

$ch = curl_init();
// 超时设置
curl_setopt($ch, CURLOPT_TIMEOUT, 30); // 30秒超时
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10); // 连接超时
// SSL验证
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
// 跟随重定向
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($ch, CURLOPT_MAXREDIRS, 5);
// 自定义User-Agent
curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36');
// 自定义头部
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
    'Authorization: Bearer your_token_here',
    'Accept: application/json'
));

处理Cookie

// 保存cookie到文件
$cookieFile = tempnam('/tmp', 'cookie');
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, "https://example.com/login");
curl_setopt($ch, CURLOPT_COOKIEJAR, $cookieFile);
curl_setopt($ch, CURLOPT_COOKIEFILE, $cookieFile);
// 登录请求
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, 'username=test&password=123');
$response = curl_exec($ch);
// 后续请求会自动携带cookie
curl_setopt($ch, CURLOPT_URL, "https://example.com/dashboard");
$response = curl_exec($ch);
curl_close($ch);

封装cURL函数

通用HTTP请求函数

class HttpClient {
    public static function get($url, $headers = []) {
        return self::request('GET', $url, null, $headers);
    }
    public static function post($url, $data = [], $headers = []) {
        return self::request('POST', $url, $data, $headers);
    }
    public static function put($url, $data = [], $headers = []) {
        return self::request('PUT', $url, $data, $headers);
    }
    public static function delete($url, $headers = []) {
        return self::request('DELETE', $url, null, $headers);
    }
    private static function request($method, $url, $data = null, $headers = []) {
        $ch = curl_init();
        // 基本设置
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        // 设置请求方法
        switch ($method) {
            case 'POST':
                curl_setopt($ch, CURLOPT_POST, true);
                if ($data) {
                    curl_setopt($ch, CURLOPT_POSTFIELDS, is_array($data) ? http_build_query($data) : $data);
                }
                break;
            case 'PUT':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
                if ($data) {
                    curl_setopt($ch, CURLOPT_POSTFIELDS, is_array($data) ? json_encode($data) : $data);
                }
                break;
            case 'DELETE':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
                break;
        }
        // 设置头部
        if (!empty($headers)) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        }
        // 执行请求
        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error = curl_error($ch);
        curl_close($ch);
        if ($error) {
            return [
                'success' => false,
                'error' => $error,
                'http_code' => $httpCode
            ];
        }
        return [
            'success' => true,
            'data' => $response,
            'http_code' => $httpCode
        ];
    }
}
// 使用示例
$result = HttpClient::get('https://api.example.com/users');
$result = HttpClient::post('https://api.example.com/users', ['name' => 'John'], [
    'Content-Type: application/json'
]);

文件上传

使用cURL上传文件

function uploadFile($url, $filePath, $fieldName = 'file') {
    if (!file_exists($filePath)) {
        return ['success' => false, 'error' => 'File not found'];
    }
    $ch = curl_init();
    // PHP 5.5+ 使用 CURLFile
    $cFile = new CURLFile($filePath, mime_content_type($filePath), basename($filePath));
    $postData = [
        $fieldName => $cFile,
        // 其他字段
        'description' => 'Test upload'
    ];
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    return [
        'success' => $httpCode == 200,
        'data' => $response,
        'http_code' => $httpCode
    ];
}

并发请求

使用curl_multi进行并发

function multiRequest($urls) {
    $multi = curl_multi_init();
    $channels = [];
    // 创建多个cURL句柄
    foreach ($urls as $key => $url) {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_multi_add_handle($multi, $ch);
        $channels[$key] = $ch;
    }
    // 执行所有请求
    $active = null;
    do {
        $mrc = curl_multi_exec($multi, $active);
    } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    while ($active && $mrc == CURLM_OK) {
        if (curl_multi_select($multi) == -1) {
            usleep(100);
        }
        do {
            $mrc = curl_multi_exec($multi, $active);
        } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    }
    // 获取结果
    $results = [];
    foreach ($channels as $key => $ch) {
        $results[$key] = curl_multi_getcontent($ch);
        curl_multi_remove_handle($multi, $ch);
    }
    curl_multi_close($multi);
    return $results;
}
// 使用示例
$urls = [
    'google' => 'https://www.google.com',
    'github' => 'https://www.github.com',
    'php' => 'https://www.php.net'
];
$results = multiRequest($urls);

错误处理和调试

完整的错误处理

function safeCurlRequest($url, $options = []) {
    $defaults = [
        CURLOPT_URL => $url,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_TIMEOUT => 30,
        CURLOPT_CONNECTTIMEOUT => 10,
        CURLOPT_FOLLOWLOCATION => true,
        CURLOPT_MAXREDIRS => 5,
        CURLOPT_SSL_VERIFYPEER => true,
        CURLOPT_VERBOSE => true // 启用详细输出用于调试
    ];
    $ch = curl_init();
    curl_setopt_array($ch, $defaults + $options);
    // 收集调试信息
    $verbose = fopen('php://temp', 'w+');
    curl_setopt($ch, CURLOPT_STDERR, $verbose);
    $response = curl_exec($ch);
    // 错误检查
    $error = curl_error($ch);
    $errno = curl_errno($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    // 获取调试信息
    rewind($verbose);
    $verboseLog = stream_get_contents($verbose);
    curl_close($ch);
    if ($error) {
        return [
            'success' => false,
            'error' => $error,
            'errno' => $errno,
            'http_code' => $httpCode,
            'verbose' => $verboseLog
        ];
    }
    return [
        'success' => true,
        'data' => $response,
        'http_code' => $httpCode,
        'info' => curl_getinfo($ch)
    ];
}

使用Guzzle替代cURL

GuzzleHTTP库示例

// 安装: composer require guzzlehttp/guzzle
use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;
$client = new Client([
    'base_uri' => 'https://api.example.com',
    'timeout' => 30,
    'headers' => [
        'Accept' => 'application/json',
        'User-Agent' => 'MyApp/1.0'
    ]
]);
// GET请求
try {
    $response = $client->get('/users', [
        'query' => ['page' => 1, 'limit' => 10]
    ]);
    $body = $response->getBody();
    $data = json_decode($body, true);
} catch (RequestException $e) {
    if ($e->hasResponse()) {
        $statusCode = $e->getResponse()->getStatusCode();
        $errorBody = $e->getResponse()->getBody();
    }
}
// POST请求
$response = $client->post('/users', [
    'json' => [
        'name' => 'John',
        'email' => 'john@example.com'
    ]
]);
// 并发请求
$promises = [
    'users' => $client->getAsync('/users'),
    'posts' => $client->getAsync('/posts'),
];
$results = GuzzleHttp\Promise\Utils::unwrap($promises);

最佳实践

  1. 使用try-catch：始终包含错误处理
  2. 设置超时：避免请求挂起
  3. 验证SSL：生产环境保持启用
  4. 重用cURL句柄：提高性能
  5. 记录日志：便于调试
  6. 使用连接池：大量请求时复用连接

选择cURL还是Guzzle取决于项目需求：

  • cURL：更底层，控制更精细
  • Guzzle：更现代，功能更丰富，适合复杂场景

版权声明：NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 NBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 CBA直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 足球直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播 英超直播

上一篇PHP项目Swoole服务器与协程

下一篇PHP项目流式HTTP与回调

相关文章

抱歉，评论功能暂时关闭!

友情链接攻略窝 · 礼包窝 · 配置窝 · 换算窝 · 算法窝 · 查文窝 · 手册窝 · 问答窝 · 全文搜 · 手册库
相关站点礼包窝 · 查文窝