PHP开发玩转MCP〡腾讯地图SSE接入Cursor客户端应用

{
    "mcpServers": {
        "TencentAISearch": {
            "url": "https://mcp.map.qq.com/sse?key=<您的Key>"
        }
    }
}

composer require php-mcp/server

<?php

usePhpMcp\Server\Attributes\McpPrompt;
usePhpMcp\Server\Attributes\McpResource;
usePhpMcp\Server\Attributes\McpResourceTemplate;
usePhpMcp\Server\Attributes\McpTool;

/**
 * A sample class containing methods decorated with MCP attributes for testing discovery.
 */
class SampleMcpElements
{
    /**
     * A sample tool method.
     *
     * @param string $name The name to greet.
     * @return string The greeting message.
     */
    #[McpTool(name: 'tinywanTool', description: '开源技术小栈微信公众号生成简介.')]
    publicfunction tinywanTool(string $name): string
    {
        return'[开源技术小栈]'.$name;
    }

    /**
     * A sample tool method.
     *
     * @param string $name The name to greet.
     * @param int $count The number of times to greet.
     * @return string The greeting message.
     */
    #[McpTool(name: 'greet_user', description: 'Generates a greeting for a user.')]
    publicfunction simpleTool(string $name, int $count = 1): string
    {
        if ($count === null) {
            $count = 1;
        }

        return implode(' ', array_fill(0, $count, "Hello, {$name}!"));
    }

    #[McpTool(description: 'Another tool with no explicit name.')]
    publicfunction anotherTool(
        string $input,
        int $count = 1
    ): array {
        return ['processed' => $input, 'count' => $count];
    }

    /**
     * Generates a simple story prompt.
     *
     * @param  string  $subject  The main subject of the story.
     * @param  string  $genre  The genre (e.g., fantasy, sci-fi).
     */
    #[McpPrompt(name: 'create_story', description: 'Creates a short story premise.')]
    publicfunction storyPrompt(string $subject, string $genre = 'fantasy'): array
    {
        // In a real scenario, this would return the prompt string
        return [
            [
                'role' => 'user',
                'content' => "Write a short {$genre} story about {$subject}.",
            ],
        ];
    }

    #[McpPrompt]
    publicfunction simplePrompt(): array
    {
        return [
            [
                'role' => 'user',
                'content' => 'This is a simple prompt with no arguments.',
            ],
        ];
    }

    #[McpResource(uri: 'config://app/name', name: 'app_name', description: 'The application name.', mimeType: 'text/plain')]
    publicfunction getAppName(): string
    {
        // In a real scenario, this would fetch the config value
        return'My MCP App';
    }

    #[McpResource(uri: 'file://data/users.csv', name: 'users_csv', mimeType: 'text/csv')]
    publicfunction getUserData(): string
    {
        // In a real scenario, this would return file content
        return"id,name\n1,Alice\n2,Bob";
    }

    #[McpResourceTemplate(uriTemplate: 'user://{userId}/profile', name: 'user_profile', mimeType: 'application/json')]
    publicfunction getUserProfileTemplate(string $userId): array
    {
        // In a real scenario, this would fetch user data based on userId
        return ['id' => $userId, 'name' => 'User '.$userId, 'email' => $userId.'@example.com'];
    }
}

<?php
/**
 * @desc reactphp_http.server.php
 * @author Tinywan(ShaoBo Wan)
 */
declare(strict_types=1);

use PhpMcp\Server\Defaults\StreamLogger;
use PhpMcp\Server\Server;
use PhpMcp\Server\Transports\ReactPhpHttpTransportHandler;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use React\Http\HttpServer;
use React\Http\Message\Response;
use React\Promise\Promise;
use React\Socket\SocketServer;
use React\Stream\ThroughStream;

// --- Instructions ---
// 1. cd php-mcp/samples/reactphp
// 2. composer install
// 3. Run: php server.php
// 4. Use an MCP client to connect via HTTP SSE:
//    - SSE Endpoint: http://127.0.0.1:8080/mcp/sse
//    - POST Endpoint will be provided by the server via the 'endpoint' event.
// --- ------------ ---

require_once __DIR__.'/vendor/autoload.php';
require_once __DIR__.'/SampleMcpElements.php';

// --- MCP Server Setup ---
$logger = new StreamLogger(__DIR__.'/react_server.log', 'debug');

$server = Server::make()
    ->withLogger($logger)
    ->withBasePath(__DIR__)
    ->discover();

$transportHandler = new ReactPhpHttpTransportHandler($server);

// --- ReactPHP HTTP Server Setup ---
$postEndpoint = '/mcp/message';
$sseEndpoint = '/mcp/sse';
$listenAddress = '0.0.0.0:8201';

$http = new HttpServer(function (ServerRequestInterface $request) use ($logger, $transportHandler, $postEndpoint, $sseEndpoint): ResponseInterface|Promise {
    $path = $request->getUri()->getPath();
    $method = $request->getMethod();
    $responseHeaders = ['Access-Control-Allow-Origin' => '*'];

    $logger->info('Received request', ['method' => $method, 'path' => $path]);

    // POST Endpoint Handling
    if ($method === 'POST' && str_starts_with($path, $postEndpoint)) {
        $queryParams = $request->getQueryParams();
        $clientId = $queryParams['clientId'] ?? null;

        if (! $clientId || ! is_string($clientId)) {
            return new Response(400, $responseHeaders, 'Error: Missing or invalid clientId query parameter');
        }
        if (! str_contains($request->getHeaderLine('Content-Type'), 'application/json')) {
            return new Response(415, $responseHeaders, 'Error: Content-Type must be application/json');
        }

        $requestBody = (string) $request->getBody();
        if (empty($requestBody)) {
            return new Response(400, $responseHeaders, 'Error: Empty request body');
        }

        try {
            $transportHandler->handleInput($requestBody, $clientId);

            return new Response(202, $responseHeaders); // Accepted
        } catch (JsonException $e) {
            return new Response(400, $responseHeaders, "Error: Invalid JSON - {$e->getMessage()}");
        } catch (Throwable $e) {
            return new Response(500, $responseHeaders, 'Error: Internal Server Error');
        }
    }

    // SSE Endpoint Handling
    if ($method === 'GET' && $path === $sseEndpoint) {
        $clientId = 'client_'.bin2hex(random_bytes(16));

        $logger->info('ReactPHP SSE connection opening', ['client_id' => $clientId]);

        $stream = new ThroughStream;

        $postEndpointWithClientId = $postEndpoint.'?clientId='.urlencode($clientId);

        $transportHandler->setClientSseStream($clientId, $stream);

        $transportHandler->handleSseConnection($clientId, $postEndpointWithClientId);

        $sseHeaders = [
            'Content-Type' => 'text/event-stream',
            'Cache-Control' => 'no-cache',
            'Connection' => 'keep-alive',
            'X-Accel-Buffering' => 'no',
            'Access-Control-Allow-Origin' => '*',
        ];

        return new Response(200, $sseHeaders, $stream);
    }

    // Fallback 404
    return new Response(404, $responseHeaders, 'Not Found');
});

$socket = new SocketServer($listenAddress);

$logger->info("ReactPHP MCP Server listening on {$listenAddress}");
$logger->info("SSE Endpoint: http://{$listenAddress}{$sseEndpoint}");
$logger->info("POST Endpoint: (Sent via SSE 'endpoint' event)");
echo"ReactPHP MCP Server listening on http://{$listenAddress}\n";

$http->listen($socket);

# php reactphp_http.server.php 
ReactPHP MCP Server listening on http://0.0.0.0:8201

{
  "mcpServers": {
      "mcp-php-server-http": {
         "url": "http://127.0.0.1:8201/mcp/sse"
      }
  }
}

#[McpTool(name: 'greet_user', description: 'Generates a greeting for a user.')]
public function simpleTool(string $name, int $count = 1): string
{
    if ($count === null) {
        $count = 1;
    }

    return implode(' ', array_fill(0, $count, "Hello, {$name}!"));
}