PHP MCP 客户端 v1.0.0 发布！

composer require php-mcp/client

<?php 
require'vendor/autoload.php';

usePhpMcp\Client\Client;
usePhpMcp\Client\Enum\TransportType;
usePhpMcp\Client\Model\CapabilitiesasClientCapabilities;
usePhpMcp\Client\ServerConfig;
usePhpMcp\Client\Exception\McpClientException;

$clientCapabilities = ClientCapabilities::forClient(); // 默认客户端功能
$userHome = $_SERVER['HOME'] ?? $_SERVER['USERPROFILE'] ?? getcwd();
$fsServerConfig = new ServerConfig(
    name: 'local_filesystem',
    transport: TransportType::Stdio,
    timeout: 15,
    command: 'npx',
    args: [
        '-y',
        '@modelcontextprotocol/server-filesystem',
        $userHome . '/Documents',
    ],
    workingDir: $userHome
);

$fsClient = Client::make()
    ->withClientInfo('MyFileSystemApp', '1.0')
    ->withCapabilities($clientCapabilities)
    // ->withLogger(new MyPsrLogger()) // 可选
    ->withServerConfig($fsServerConfig)
    ->build();

try {
    // 初始化连接（阻塞）
    $fsClient->initialize();

    // 同步交互
    $tools = $fsClient->listTools(); // 阻塞调用
    foreach ($tools as $tool) {
        echo"- Tool: {$tool->name}\n";
    }

    //... 调用其他方法，如 $fsClient->callTool(...)...

} catch (McpClientException $e) {
    echo"[MCP ERROR] ". get_class($e). ": ". $e->getMessage(). "\n";
    // 检查 $e->getPrevious() 获取底层传输/进程错误
} catch (\Throwable $e) {
    echo"[UNEXPECTED ERROR] ". $e->getMessage(). "\n";
} finally {
    // 断开连接（阻塞）
    if (isset($fsClient)) {
        $fsClient->disconnect();
    }
}

use PhpMcp\Client\Model\Capabilities as ClientCapabilities;

// 客户端支持从服务器采样请求
$clientCapabilities = ClientCapabilities::forClient(supportsSampling: true);

// 客户端不支持从服务器采样请求
$clientCapabilities = ClientCapabilities::forClient(supportsSampling: false);

// 待办事项：如果需要，添加对声明“roots”功能的支持

use PhpMcp\Client\Enum\TransportType;
usePhpMcp\Client\ServerConfig;

// 示例：Stdio服务器
$stdioConfig = new ServerConfig(
    name: 'local_file_server',       // 必需：此配置的唯一ID
    transport: TransportType::Stdio, // 必需：传输类型
    timeout: 15.0,                   // 可选：请求超时时间（秒）
    command: 'npx',                  // Stdio必需：可执行文件
    args: [                          // Stdio可选：参数数组
        '-y',
        '@modelcontextprotocol/server-filesystem',
        '/path/to/project'
    ],
    workingDir: '/path/to/project',  // Stdio可选：工作目录
    env: ['DEBUG' =>'mcp*']         // Stdio可选：环境变量
);

// 示例：HTTP服务器
$httpConfig = new ServerConfig(
    name:'remote_web_agent',        // 必需：唯一ID
    transport: TransportType::Http,  // 必需：传输类型
    timeout: 45.0,                   // 可选：请求超时时间
    url: 'http://localhost:8080/sse',// Http必需：SSE URL
    headers: [                       // Http可选：认证/自定义头
        'Authorization' => 'Bearer xyz789'
    ],
);

use PhpMcp\Client\ServerConfig;
usePhpMcp\Client\Exception\ConfigurationException;

$jsonConfig = '{
    "mcpServers": {
        "stdio_files": {
            "command": "php",
            "args": ["/app/mcp/file_server.php"],
            "timeout": 10
        },
        "http_api": {
            "url": "https://api.example.com/mcp/sse",
            "transport": "http",
            "headers": {"X-API-Key": "secret"}
        }
    }
}';

$decodedConfig = json_decode($jsonConfig, true)['mcpServers']?? [];

$serverConfigs = [];
foreach ($decodedConfig as $name => $data) {
    try {
        $serverConfigs[$name] = ServerConfig::fromArray($name, $data);
    } catch (ConfigurationException $e) {
        echo"Error parsing config for '{$name}': {$e->getMessage()}\n";
    }
}

// 现在 $serverConfigs['stdio_files'] 和 $serverConfigs['http_api'] 包含ServerConfig对象。

use PhpMcp\Client\Client;
//... 其他用于Config、Logger等的use语句...
$client = Client::make()
    ->withClientInfo($clientName, $clientVersion) // 必需
    ->withCapabilities($clientCapabilities)       // 可选（提供默认值）
    ->withServerConfig($stdioConfig)              // 必需：服务器配置
    ->withLogger($myLogger)                       // 可选
    ->withCache($myCache, 3600)                   // 可选（缓存 + 生存时间）
    ->withEventDispatcher($myDispatcher)          // 可选
    ->withIdGenerator($myIdGenerator)             // 可选
    ->withLoop($myEventLoop)                      // 可选（默认为Loop::get()）
    ->build();

// 同步（阻塞）
try {
    $client->initialize(); // 连接、执行握手操作，等待直到准备就绪
    echo"Connection Ready!";
} catch (Throwable $e) {
    echo"Initialization failed: ". $e->getMessage();
    // 处理错误... 客户端可能处于错误状态
}

// 异步（基于Promise）
$client->initializeAsync()->then(
    function(Client $readyClient) { /* 准备就绪 */ },
    function(Throwable $error) { /* 处理初始化失败 */ }
);
// 需要运行事件循环 ($client->getLoop()->run())

try {
    if ($client->isReady()) { // 检查状态
        $tools = $client->listTools();
        $result = $client->callTool('myTool', ['param' => 'value']);
    }
} catch (Throwable $e) { /* 处理错误 */ }

use functionReact\Promise\all;

if ($client->isReady()) {
    $p1 = $client->listToolsAsync();
    $p2 = $client->readResourceAsync('config://settings');

    all([$p1, $p2])->then(
        function(array $results) {
            [$tools, $readResult] = $results;
            // 处理异步结果...
        },
        function(Throwable $error) {
            // 处理异步错误...
        }
    );
    // $client->getLoop()->run(); // 需要运行循环
}

// 同步
$client->disconnect(); // 阻塞直到连接关闭或超时

// 异步
$client->disconnectAsync()->then(function() { echo "Disconnected async"; });
// $loop->run();