[Server] Rework transport architecture and add StreamableHttpTransport

composer.json

@@ -22,8 +22,11 @@
         "ext-fileinfo": "*",
         "opis/json-schema": "^2.4",
         "phpdocumentor/reflection-docblock": "^5.6",
+        "psr/clock": "^1.0",
         "psr/container": "^2.0",
         "psr/event-dispatcher": "^1.0",
+        "psr/http-factory": "^1.1",
+        "psr/http-message": "^2.0",
         "psr/log": "^1.0 || ^2.0 || ^3.0",
         "symfony/finder": "^6.4 || ^7.3",
         "symfony/uid": "^6.4 || ^7.3"
@@ -34,7 +37,10 @@
         "phpunit/phpunit": "^10.5",
         "psr/cache": "^3.0",
         "symfony/console": "^6.4 || ^7.3",
-        "symfony/process": "^6.4 || ^7.3"
+        "symfony/process": "^6.4 || ^7.3",
+        "nyholm/psr7": "^1.8",
+        "nyholm/psr7-server": "^1.1",
+        "laminas/laminas-httphandlerrunner": "^2.12"
     },
     "autoload": {
         "psr-4": {
@@ -51,10 +57,11 @@
             "Mcp\\Example\\DependenciesStdioExample\\": "examples/06-custom-dependencies-stdio/",
             "Mcp\\Example\\ComplexSchemaHttpExample\\": "examples/07-complex-tool-schema-http/",
             "Mcp\\Example\\SchemaShowcaseExample\\": "examples/08-schema-showcase-streamable/",
+            "Mcp\\Example\\HttpTransportExample\\": "examples/10-simple-http-transport/",
             "Mcp\\Tests\\": "tests/"
         }
     },
     "config": {
         "sort-packages": true
     }
-}
+}

examples/01-discovery-stdio-calculator/server.php

@@ -10,20 +10,25 @@
  * file that was distributed with this source code.
  */
 
-require_once dirname(__DIR__).'/bootstrap.php';
+require_once dirname(__DIR__) . '/bootstrap.php';
 chdir(__DIR__);
 
 use Mcp\Server;
 use Mcp\Server\Transport\StdioTransport;
 
 logger()->info('Starting MCP Stdio Calculator Server...');
 
-Server::make()
+$server = Server::make()
     ->setServerInfo('Stdio Calculator', '1.1.0', 'Basic Calculator over STDIO transport.')
     ->setContainer(container())
     ->setLogger(logger())
     ->setDiscovery(__DIR__, ['.'])
-    ->build()
-    ->connect(new StdioTransport(logger: logger()));
+    ->build();
+
+$transport = new StdioTransport(logger: logger());
+
+$server->connect($transport);
+
+$transport->listen();
 
 logger()->info('Server listener stopped gracefully.');

examples/10-simple-http-transport/.gitignore

@@ -0,0 +1 @@
+sessions/

examples/10-simple-http-transport/McpElements.php

@@ -0,0 +1,101 @@
+<?php
+
+namespace Mcp\Example\HttpTransportExample;
+
+use Mcp\Capability\Attribute\McpPrompt;
+use Mcp\Capability\Attribute\McpResource;
+use Mcp\Capability\Attribute\McpTool;
+
+class McpElements
+{
+    public function __construct() {}
+
+    /**
+     * Get the current server time
+     */
+    #[McpTool(name: 'current_time')]
+    public function getCurrentTime(string $format = 'Y-m-d H:i:s'): string
+    {
+        try {
+            return date($format);
+        } catch (\Exception $e) {
+            return date('Y-m-d H:i:s'); // fallback
+        }
+    }
+
+    /**
+     * Calculate simple math operations
+     */
+    #[McpTool(name: 'calculate')]
+    public function calculate(float $a, float $b, string $operation): float|string
+    {
+        return match (strtolower($operation)) {
+            'add', '+' => $a + $b,
+            'subtract', '-' => $a - $b,
+            'multiply', '*' => $a * $b,
+            'divide', '/' => $b != 0 ? $a / $b : 'Error: Division by zero',
+            default => 'Error: Unknown operation. Use: add, subtract, multiply, divide'
+        };
+    }
+
+    /**
+     * Server information resource
+     */
+    #[McpResource(
+        uri: 'info://server/status',
+        name: 'server_status',
+        description: 'Current server status and information',
+        mimeType: 'application/json'
+    )]
+    public function getServerStatus(): array
+    {
+        return [
+            'status' => 'running',
+            'timestamp' => time(),
+            'version' => '1.0.0',
+            'transport' => 'HTTP',
+            'uptime' => time() - $_SERVER['REQUEST_TIME']
+        ];
+    }
+
+    /**
+     * Configuration resource
+     */
+    #[McpResource(
+        uri: 'config://app/settings',
+        name: 'app_config',
+        description: 'Application configuration settings',
+        mimeType: 'application/json'
+    )]
+    public function getAppConfig(): array
+    {
+        return [
+            'debug' => $_SERVER['DEBUG'] ?? false,
+            'environment' => $_SERVER['APP_ENV'] ?? 'production',
+            'timezone' => date_default_timezone_get(),
+            'locale' => 'en_US'
+        ];
+    }
+
+    /**
+     * Greeting prompt
+     */
+    #[McpPrompt(
+        name: 'greet',
+        description: 'Generate a personalized greeting message'
+    )]
+    public function greetPrompt(string $firstName = 'World', string $timeOfDay = 'day'): array
+    {
+        $greeting = match (strtolower($timeOfDay)) {
+            'morning' => 'Good morning',
+            'afternoon' => 'Good afternoon',
+            'evening', 'night' => 'Good evening',
+            default => 'Hello'
+        };
+
+        return [
+            'role' => 'user',
+            'content' => "# {$greeting}, {$firstName}!\n\nWelcome to our MCP HTTP Server example. This demonstrates how to use the Model Context Protocol over HTTP transport."
+        ];
+    }
+}

examples/10-simple-http-transport/README.md

@@ -0,0 +1,24 @@
+# HTTP MCP Server Example
+
+This example demonstrates how to use the MCP SDK with HTTP transport using the StreamableHttpTransport. It provides a complete HTTP-based MCP server that can handle JSON-RPC requests over HTTP POST.
+
+## Usage
+
+**Step 1: Start the HTTP server**
+
+```bash
+cd examples/10-simple-http-transport
+php -S localhost:8000 server.php
+```
+
+**Step 2: Connect with MCP Inspector**
+
+```bash
+npx @modelcontextprotocol/inspector http://localhost:8000
+```
+
+## Available Features
+
+- **Tools**: `current_time`, `calculate`
+- **Resources**: `info://server/status`, `config://app/settings`
+- **Prompts**: `greet`

examples/10-simple-http-transport/server.php

@@ -0,0 +1,31 @@
+<?php
+
+require_once dirname(__DIR__) . '/bootstrap.php';
+chdir(__DIR__);
+
+use Mcp\Server;
+use Mcp\Server\Transport\StreamableHttpTransport;
+use Nyholm\Psr7\Factory\Psr17Factory;
+use Nyholm\Psr7Server\ServerRequestCreator;
+use Laminas\HttpHandlerRunner\Emitter\SapiEmitter;
+use Mcp\Server\Session\FileSessionStore;
+
+$psr17Factory = new Psr17Factory();
+$creator = new ServerRequestCreator($psr17Factory, $psr17Factory, $psr17Factory, $psr17Factory);
+
+$request = $creator->fromGlobals();
+
+$server = Server::make()
+    ->setServerInfo('HTTP MCP Server', '1.0.0', 'MCP Server over HTTP transport')
+    ->setContainer(container())
+    ->setSession(new FileSessionStore(__DIR__ . '/sessions'))
+    ->setDiscovery(__DIR__, ['.'])
+    ->build();
+
+$transport = new StreamableHttpTransport($request, $psr17Factory, $psr17Factory);
+
+$server->connect($transport);
+
+$response = $transport->listen();
+
+(new SapiEmitter())->emit($response);