PHP gRPC 客户端中的 JWT 认证实践指南

<?php

namespace App\Grpc; // 根据您的实际命名空间调整

use Grpc\ChannelCredentials;
use Grpc\STATUS_OK;
// 假设 MyServiceClient 是由 .proto 文件生成的客户端类
// 假设 MyMethodRequest 是请求消息类

// 引入您的 gRPC 客户端和服务端生成的类
// require_once __DIR__ . '/vendor/autoload.php';
// require_once __DIR__ . '/Generated/MyService/MyServiceClient.php';
// require_once __DIR__ . '/Generated/MyService/MyMethodRequest.php';

// 假设 gRPC 服务的地址和端口
$host = 'localhost';
$port = 50051;

// 假设这是您从认证服务器获取到的 JWT 字符串
// 在实际应用中，您需要一个机制来获取和管理这个令牌
$token = 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiIxMjM0NTY3ODkwIiwibmFtZSI6IkpvaG4gRG9lIiwiaWF0IjoxNTE2MjM5MDIyfQ.SflKxwRJSMeKKF2QT4fwpMeJf36POk6yJV_adQssw5c';

try {
    // 创建 gRPC 客户端实例
    $myServiceClient = new MyServiceClient(
        "$host:$port",
        [
            // 注意：在生产环境中，强烈建议使用 ChannelCredentials::createSsl()
            // 以建立安全的 TLS 连接来保护敏感的 JWT 令牌。
            'credentials' => ChannelCredentials::createInsecure(), // 仅用于开发测试，不推荐用于生产
            'update_metadata' => function ($metaData) use ($token) {
                // 正确设置 Authorization 请求头
                // JWT 令牌应以 'Bearer ' 前缀的形式添加到 Authorization 头中
                $metaData['Authorization'] = ['Bearer ' . $token];
                return $metaData;
            },
        ]
    );

    // 创建请求消息
    $request = new MyMethodRequest();
    $request->setMessage('Hello gRPC with JWT!');

    // 发起 gRPC 调用
    // $unaryCall 是一个 UnaryCall 对象，用于异步调用
    $unaryCall = $myServiceClient->MyMethod($request);

    // 等待 gRPC 调用的结果
    list($response, $status) = $unaryCall->wait();

    // 检查调用状态
    if ($status->code === STATUS_OK) {
        echo "gRPC 请求成功！" . PHP_EOL;
        echo "服务器响应: " . $response->getMessage() . PHP_EOL;
    } else {
        echo "gRPC 请求失败！" . PHP_EOL;
        echo "错误详情: " . $status->details . " (错误码: " . $status->code . ")" . PHP_EOL;
        // 根据错误码进行更细致的错误处理，例如处理 UNAUTHENTICATED (16) 错误
        if ($status->code === \Grpc\STATUS_UNAUTHENTICATED) {
            echo "认证失败，请检查 JWT 令牌是否有效或已过期。" . PHP_EOL;
        }
    }

} catch (\Exception $e) {
    echo "发生异常: " . $e->getMessage() . PHP_EOL;
}