当前位置：首页 > PHP

graphql php实现

2026-02-14 13:44:45PHP

GraphQL PHP 实现方法

安装依赖库

使用 Composer 安装 webonyx/graphql-php，这是最流行的 GraphQL PHP 实现库：

composer require webonyx/graphql-php

定义 Schema

创建 GraphQL Schema，包含类型定义和查询/变更解析器。以下是一个简单示例：

use GraphQL\Type\Definition\ObjectType;
use GraphQL\Type\Definition\Type;
use GraphQL\Type\Schema;

$queryType = new ObjectType([
    'name' => 'Query',
    'fields' => [
        'hello' => [
            'type' => Type::string(),
            'resolve' => function () {
                return 'Hello World!';
            }
        ]
    ]
]);

$schema = new Schema(['query' => $queryType]);

处理请求

通过 PHP 接收 GraphQL 请求并返回响应：

use GraphQL\GraphQL;
use GraphQL\Error\FormattedError;

$rawInput = file_get_contents('php://input');
$input = json_decode($rawInput, true);
$query = $input['query'];

try {
    $result = GraphQL::executeQuery($schema, $query);
    $output = $result->toArray();
} catch (\Exception $e) {
    $output = [
        'errors' => [FormattedError::createFromException($e)]
    ];
}

header('Content-Type: application/json');
echo json_encode($output);

集成框架（可选）

对于 Laravel 等框架，可以使用专用包简化集成：

Laravel 安装指令：

composer require rebing/graphql-laravel

Yii2 安装指令：

composer require yii2tech/graphql

性能优化

启用查询缓存减少解析开销：

use GraphQL\Type\Definition\Config;

Config::enableValidationCache('/tmp/graphql_cache');

高级特性实现

数据加载器

使用 DataLoader 解决 N+1 查询问题：

use GraphQL\Executor\Promise\Adapter\ReactPromiseAdapter;
use GraphQL\Executor\Promise\Promise;

$loader = new \GraphQL\Executor\Promise\Adapter\ReactPromiseAdapter();
$batchLoadFn = function($keys) { /* 批量加载逻辑 */ };
$dataLoader = new \GraphQL\DataLoader($batchLoadFn, $loader);

订阅实现

通过 WebSocket 实现实时订阅：

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\GraphQLSubscriber;

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new GraphQLSubscriber($schema)
        )
    ),
    8080
);
$server->run();

错误处理

自定义错误格式和日志记录：

use GraphQL\Error\Error;

$errorFormatter = function(Error $error) {
    return [
        'message' => $error->getMessage(),
        'locations' => $error->getLocations(),
        'trace' => debug_backtrace()
    ];
};

安全实践

查询复杂度分析

限制查询深度防止复杂查询：

use GraphQL\Validator\Rules\QueryDepth;
use GraphQL\Validator\DocumentValidator;

DocumentValidator::addRule(new QueryDepth(10));

持久化查询

预定义查询防止任意查询执行：

graphql php实现

$persistedQueries = [
    'hash1' => 'query { user(id: 1) { name } }'
];
if (isset($persistedQueries[$input['queryId']])) {
    $query = $persistedQueries[$input['queryId']];
}