रेडिस के साथ एमसीपी विकास में तेजी लाएं:तेज़, लागत प्रभावी समाधान

एमसीपी ट्रांसपोर्ट को समझना

केस 1 का उपयोग करें:रेडिस पब/सब के साथ एसएसई

केस 2 का उपयोग करें:पुन:प्रारंभ करने की क्षमता के लिए इवेंट स्टोर

एमसीपी स्ट्रीम को समझना

रेडिस के साथ इवेंटस्टोर को कार्यान्वित करना

import { Redis } from '@upstash/redis';
import { JSONRPCMessage } from '@modelcontextprotocol/sdk/types.js';
import { EventStore } from '@modelcontextprotocol/sdk/server/streamableHttp.js';
 
export class RedisEventStore implements EventStore {
 private redis: Redis;
 
 constructor(params: ConstructorParameters<typeof Redis>[0]) {
 this.redis = new Redis(params);
 }
 
 /**
 * Stores an event in a Redis Stream
 * Implements EventStore.storeEvent
 */
 async storeEvent(streamId: string, message: JSONRPCMessage): Promise<string> {
 const eventId = await this.redis.xadd(`stream:${streamId}`, '*', {
 message: JSON.stringify(message),
 });
 return eventId;
 }
 
 /**
 * Replays events that occurred after a specific event ID
 * Implements EventStore.replayEventsAfter
 */
 async replayEventsAfter(
 lastEventId: string,
 { send }: { send: (eventId: string, message: JSONRPCMessage) => Promise<void> }
 ): Promise<string> {
 if (!lastEventId) {
 return '';
 }
 
 // Extract the stream ID from the lastEventId
 const streamId = lastEventId.split('-')[0]; // Assuming the stream ID is part of the key
 if (!streamId) {
 return '';
 }
 
 let nextId = lastEventId;
 while (true) {
 // Fetch events from the stream starting AFTER the next ID (exclusive)
 const events = await this.redis.xrange(`stream:${streamId}`, `(${nextId}`, '+', 10);
 
 // Convert the returned object to an array of entries
 const eventEntries = Object.entries(events);
 
 if (eventEntries.length === 0) {
 break; // No more events to replay
 }
 
 for (const [eventId, fields] of eventEntries) {
 // Ensure fields.message exists and parse it
 if (fields && typeof fields === 'object' && 'message' in fields && typeof fields.message === 'string') {
 const message = JSON.parse(fields.message) as JSONRPCMessage;
 await send(eventId, message);
 nextId = eventId; // Update the next ID to the current event ID
 }
 }
 }
 
 return streamId;
 }
}

एक सीमा

केस 3 का उपयोग करें:क्लर्क का MCP OAuth कार्यान्वयन

OAuth के लिए संग्रहण क्यों मायने रखता है

1. OAuth प्रवाह कई समापन बिंदुओं तक फैला है - इनिशियलाइज़ेशन, OAuth कॉलबैक और MCP अनुरोध सभी को साझा मेमोरी के बिना विभिन्न सर्वर रहित फ़ंक्शंस द्वारा नियंत्रित किया जा सकता है
2. MCP कनेक्शन लंबे समय से चल रहे हैं - इन-मेमोरी स्टोरेज पर भरोसा करने से एप्लिकेशन स्केल के रूप में मेमोरी आवश्यकताओं में वृद्धि होगी, और कोई भी सर्वर पुनरारंभ सभी सत्रों को अमान्य कर देगा

रेडिस में क्या संग्रहीत होता है

{
 "value": "XoYQ...",
 "created_at": "2025-10-03T06:27:06.928Z",
 "updated_at": "2025-10-03T06:27:06.928Z"
}

{
 "value": {
 "mcpEndpoint": "http://localhost:3001/mcp",
 "oauthRedirectUrl": "http://localhost:3000/oauth_callback",
 "oauthScopes": "openid profile email",
 "mcpClientName": "Clerk MCP Demo",
 "mcpClientVersion": "0.0.1",
 "oauthClientUri": "http://example.com",
 "oauthPublicClient": false,
 "clientId": "8Yb2...",
 "clientSecret": "64YG..."
 },
 "created_at": "2025-10-03T06:27:06.882Z",
 "updated_at": "2025-10-03T06:27:06.882Z"
}

{
 "value": "dX61...",
 "created_at": "2025-10-03T06:27:03.585Z",
 "updated_at": "2025-10-03T06:27:03.585Z"
}

रेडिस एमसीपी के लिए बिल्कुल सही क्यों है

एमसीपी विशिष्ट विशेषताओं से परे:व्यापक एआई पारिस्थितिकी तंत्र में रेडिस

• एआई एसडीके एकीकरण - वर्सेल एआई एसडीके को बढ़ाने के लिए रेडिस का उपयोग करना
• चैट इतिहास - सतत संदेश इतिहास

निष्कर्ष

• गति और लचीलापन :यह गति, लचीलेपन और सर्वर रहित-अनुकूल वास्तुकला का संयोजन है
• लागत में कमी :कैशिंग क्षमताएं जो महंगी एपीआई कॉल और गणना को कम करती हैं