使用说明
Laravel的MCP SDK
一个Laravel包,用于与模型上下文协议(MCP)服务器交互并实现MCP服务器。
安装
您可以通过composer安装该软件包:
composer require ronydebnath/mcp-sdk
该包将自动注册其服务提供商。
您可以通过以下方式发布配置文件:
php artisan vendor:publish --provider="Ronydebnath\MCP\MCPServiceProvider" --tag="config"
这将创建一个 config/mcp.php 配置目录中的文件。
配置
包配置文件包括客户端和服务器功能的设置:
return [
'default' => env('MCP_CONNECTION', 'default'),
'connections' => [
'default' => [
'host' => env('MCP_HOST', 'localhost'),
'port' => env('MCP_PORT', 8000),
'timeout' => env('MCP_TIMEOUT', 30),
'verify' => env('MCP_VERIFY_SSL', true),
],
],
'server' => [
'session_expiry' => env('MCP_SESSION_EXPIRY', 60),
'max_connections' => env('MCP_MAX_CONNECTIONS', 100),
'allowed_origins' => explode(',', env('MCP_ALLOWED_ORIGINS', '*')),
],
'auth' => [
'token_expiry' => env('MCP_TOKEN_EXPIRY', 60),
'token_length' => env('MCP_TOKEN_LENGTH', 32),
],
'memory' => [
'max_size' => env('MCP_MEMORY_MAX_SIZE', 100),
'persist' => env('MCP_MEMORY_PERSIST', false),
'storage_path' => env('MCP_MEMORY_STORAGE_PATH', storage_path('app/mcp/memory')),
],
'message' => [
'default_type' => 'text',
'max_length' => env('MCP_MAX_MESSAGE_LENGTH', 4096),
],
];
使用MCP客户端
使用依赖注入
use Ronydebnath\MCP\Client\MCPClient;
use Ronydebnath\MCP\Types\Message;
use Ronydebnath\MCP\Types\Role;
class YourController
{
public function __construct(private MCPClient $client)
{}
public function handle()
{
$message = new Message(
role: Role::USER,
content: 'Hello, how are you?',
type: 'text'
);
$response = $this->client->send($message);
}
}
使用立面
use Ronydebnath\MCP\Facades\MCP;
use Ronydebnath\MCP\Types\Message;
use Ronydebnath\MCP\Types\Role;
$message = new Message(
role: Role::USER,
content: 'Hello, how are you?',
type: 'text'
);
$response = MCP::send($message);
发送多条消息
use Ronydebnath\MCP\Client\MCPClient;
use Ronydebnath\MCP\Types\Message;
use Ronydebnath\MCP\Types\Role;
$messages = [
new Message(role: Role::USER, content: 'First message', type: 'text'),
new Message(role: Role::USER, content: 'Second message', type: 'text'),
];
$responses = $client->sendMultiple($messages);
使用流媒体
use Ronydebnath\MCP\Client\StreamingMCPClient;
use Ronydebnath\MCP\Types\Message;
use Ronydebnath\MCP\Types\Role;
// Using Dependency Injection
class YourController
{
public function __construct(private StreamingMCPClient $client)
{}
public function handle()
{
$message = new Message(
role: Role::USER,
content: 'Hello, how are you?',
type: 'text'
);
$this->client->stream($message, function ($chunk) {
// Handle each chunk of the response
echo $chunk['content'];
});
}
}
// Using the Facade
MCP::stream($message, function ($chunk) {
echo $chunk['content'];
});
// Streaming multiple messages
$messages = [
new Message(role: Role::USER, content: 'First message', type: 'text'),
new Message(role: Role::USER, content: 'Second message', type: 'text'),
];
$client->streamMultiple($messages, function ($chunk) {
echo $chunk['content'];
});
使用MCP服务器
设置路线
将以下路线添加到您的 routes/api.php:
use Ronydebnath\MCP\Server\MCPServer;
Route::post('/mcp', function (Request $request, MCPServer $server) {
return $server->handle($request);
});
注册消息处理程序
use Ronydebnath\MCP\Server\MCPServer;
use Ronydebnath\MCP\Types\Message;
use Ronydebnath\MCP\Types\Role;
$server->registerHandler('text', function (Message $message) {
return [
'role' => Role::ASSISTANT->value,
'content' => 'This is a response to: ' . $message->content,
'type' => 'text',
];
});
使用身份验证
该软件包包括内置的身份验证支持:
use Ronydebnath\MCP\Server\Auth\AuthMiddleware;
use Ronydebnath\MCP\Server\Auth\AuthProvider;
// Generate a token
$token = $authProvider->generateToken();
// Register the authentication middleware
$server->registerMiddleware(function ($request) use ($authMiddleware) {
return $authMiddleware->handle($request);
});
客户端可以使用以下任一方式进行身份验证:
- Authorization标头中的承载令牌:
Authorization: Bearer your-token-here
- 令牌作为查询参数:
/mcp?token=your-token-here
处理流媒体请求
当客户端设置 Accept: text/event-stream 头球服务器将:
- 创建新会话或使用现有会话
- 发送初始连接消息
- 在响应块可用时对其进行流式传输
- 在连接期间保持会话
内存和上下文管理
该包包括用于维护对话状态的内存和上下文管理:
使用内存
use Ronydebnath\MCP\Shared\Memory;
use Ronydebnath\MCP\Types\Message;
use Ronydebnath\MCP\Types\Role;
$memory = app(Memory::class);
// Add messages to memory
$memory->add(new Message(
role: Role::USER,
content: 'Hello',
type: 'text'
));
// Get messages by role
$userMessages = $memory->getByRole(Role::USER);
// Get messages by type
$textMessages = $memory->getByType('text');
// Clear memory
$memory->clear();
使用上下文
use Ronydebnath\MCP\Shared\Context;
use Ronydebnath\MCP\Types\Message;
use Ronydebnath\MCP\Types\Role;
$context = app(Context::class);
// Set context data
$context->set('user_id', 123);
$context->set('preferences', ['theme' => 'dark']);
// Add messages to context
$context->addMessage(new Message(
role: Role::USER,
content: 'Hello',
type: 'text'
));
// Get context data
$userId = $context->get('user_id');
$messages = $context->getMessages();
// Clear context
$context->clear();
使用进度跟踪
use Ronydebnath\MCP\Shared\Progress;
$progress = app(Progress::class);
// Update progress
$progress->update(50, 'Processing...', ['step' => 'analysis']);
// Increment progress
$progress->increment(10, 'Moving to next step');
// Get progress information
$percentage = $progress->getPercentage();
$status = $progress->getStatus();
$metadata = $progress->getMetadata();
// Check if complete
if ($progress->isComplete()) {
// Handle completion
}
// Reset progress
$progress->reset();
测试
composer test
安全
如果您发现任何与安全相关的问题,请发送电子邮件至hello[at]ronydebnath.com,而不是使用问题跟踪器。
许可证
MIT许可证(MIT)。请看 许可证文件 了解更多信息。
