เร่งการพัฒนา MCP ด้วย Redis:โซลูชันที่รวดเร็วและคุ้มค่า

รูปแบบนี้เปลี่ยน Redis ให้เป็นบัสข้อความได้อย่างมีประสิทธิภาพซึ่งเชื่อมช่องว่างระหว่างฟังก์ชันไร้เซิร์ฟเวอร์ที่แยกออกมา ช่วยให้สามารถทำงานร่วมกันราวกับว่าเป็นส่วนหนึ่งของกระบวนการเดียวกัน แม้ว่า SSE จะเลิกใช้แล้วและหันไปใช้ Streamable HTTP แทน (หมายความว่าการใช้งาน MCP ใหม่ควรใช้การขนส่งสมัยใหม่) สิ่งนี้ยังคงเป็นตัวอย่างที่ดีเยี่ยมของการใช้ Redis สำหรับการประสานงานระหว่างฟังก์ชันไร้เซิร์ฟเวอร์ที่แยกออกมา

ใช้กรณีที่ 2:ที่เก็บกิจกรรมเพื่อการกลับมาทำงานต่อ

หนึ่งในคุณสมบัติที่ทรงพลังที่สุดของการขนส่ง HTTP แบบสตรีมได้ของ MCP คือการรองรับการทำงานต่อ คุณสมบัตินี้ช่วยให้ไคลเอนต์สามารถสตรีมต่อจากที่ค้างไว้ในกรณีที่ขาดการเชื่อมต่อ นี่เป็นสิ่งสำคัญสำหรับแอปพลิเคชันที่ใช้งานจริงซึ่งการหยุดชะงักของเครือข่ายเป็นสิ่งที่หลีกเลี่ยงไม่ได้

ทำความเข้าใจสตรีม MCP

เพื่อทำความเข้าใจว่าเหตุใดความสามารถในการกลับมาทำงานต่อจึงมีความสำคัญ เราต้องเข้าใจว่าสตรีม MCP ประกอบด้วยอะไร การดำเนินการบางอย่าง เช่น การเรียกใช้เครื่องมืออย่างง่าย ส่งคืนการตอบกลับครั้งเดียว แต่เครื่องมือยังสามารถส่งคืนหลายเหตุการณ์ระหว่างการดำเนินการโดยใช้วิธีการเช่น server.sendLoggingMessage การสตรีมแบบหลายเหตุการณ์เหล่านี้เป็นจุดที่ความสามารถในการกลับมาทำงานต่อเป็นสิ่งสำคัญ หากไคลเอนต์ยกเลิกการเชื่อมต่อกลางคัน ก็ควรจะสามารถดำเนินการต่อจากจุดที่ค้างไว้ แทนที่จะเริ่มต้นใหม่

การใช้งาน EventStore ด้วย Redis

MCP SDK กำหนดอินเทอร์เฟซ EventStore ที่ต้องใช้สองวิธี:84 สำหรับการเพิ่มเหตุการณ์และ 96 สำหรับการดึงข้อมูลเหตุการณ์ที่เริ่มต้นจากรหัสเหตุการณ์เฉพาะ SDK มีการใช้งานในหน่วยความจำ แต่สำหรับการใช้งานจริง คุณต้องมีพื้นที่เก็บข้อมูลถาวร

นี่คือการใช้งาน EventStore แบบอิง Redis:

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;
 }
}

การใช้งานนี้ใช้ Redis Streams ซึ่งเหมาะสำหรับกรณีการใช้งานนี้

ข้อจำกัด

มีข้อแม้สำคัญประการหนึ่งที่ควรทราบ:เมื่อเครื่องมือส่งหลายเหตุการณ์ streamId จะถูกตั้งค่าเป็น 109 และค่าคงที่นี้จะยังคงเหมือนเดิมในสตรีมและผู้ใช้ที่แตกต่างกัน ซึ่งหมายความว่าหากผู้ใช้สองคนใช้เครื่องมือเดียวกันที่ส่งหลายเหตุการณ์พร้อมกัน กิจกรรมของพวกเขาอาจปะปนกันในสตรีมเดียวกันได้

ฉันได้เปิดประเด็นเกี่ยวกับเรื่องนี้ในพื้นที่เก็บข้อมูลอย่างเป็นทางการแล้ว เราอาจจำเป็นต้องปรับเปลี่ยนการใช้งาน และเราจะอัปเดตโพสต์นี้ตามความเหมาะสม หากจำเป็น

ใช้กรณีที่ 3:การใช้ MCP OAuth ของพนักงาน

ข้อกำหนด MCP รวมถึงการสนับสนุนการตรวจสอบสิทธิ์และการอนุญาต ทำให้เซิร์ฟเวอร์ MCP สามารถตรวจสอบสิทธิ์ไคลเอ็นต์ได้อย่างปลอดภัยและควบคุมการเข้าถึงทรัพยากร ข้อมูลจำเพาะรองรับรูปแบบการรับรองความถูกต้องหลายรูปแบบ รวมถึง OAuth 2.0 ซึ่งมีประโยชน์อย่างยิ่งสำหรับการผสานรวมกับผู้ให้บริการข้อมูลประจำตัวที่มีอยู่ และเปิดใช้งานการเข้าถึงเครื่องมือและข้อมูลตามขอบเขตผู้ใช้

เสมียนได้สร้างไคลเอนต์ OAuth ที่ครอบคลุมสำหรับ MCP โดยการใช้อินเทอร์เฟซ OAuthClientProvider จาก MCP SDK การใช้งานนี้แสดงให้เห็นถึงกรณีการใช้งานที่สำคัญอีกกรณีหนึ่งสำหรับ Redis ในแอปพลิเคชัน MCP หากคุณต้องการเริ่มต้นใช้งานเครื่องมือ MCP ลองดูพื้นที่เก็บข้อมูลสาธิตซึ่งเป็นจุดเริ่มต้นที่ดี

เหตุใดพื้นที่เก็บข้อมูลจึงมีความสำคัญสำหรับ OAuth

ดังที่เสมียนอธิบายไว้ใน 115 พื้นที่เก็บข้อมูล พื้นที่เก็บข้อมูลถาวรเป็นสิ่งจำเป็นสำหรับการใช้งาน MCP OAuth ด้วยเหตุผลสำคัญสองประการ:

1. ขั้นตอน OAuth ครอบคลุมปลายทางหลายจุด - การเริ่มต้น, การโทรกลับ OAuth และคำขอ MCP ทั้งหมดสามารถจัดการได้โดยฟังก์ชันไร้เซิร์ฟเวอร์ที่แตกต่างกันโดยไม่ต้องใช้หน่วยความจำร่วมกัน
2. การเชื่อมต่อ MCP ใช้เวลานาน - การใช้ที่เก็บข้อมูลในหน่วยความจำจะขยายความต้องการหน่วยความจำเมื่อแอปพลิเคชันปรับขนาด และการรีสตาร์ทเซิร์ฟเวอร์ใดๆ จะทำให้เซสชันทั้งหมดไม่ถูกต้อง

สิ่งที่ถูกเก็บไว้ใน Redis

ร้านค้า Redis ของเสมียนจัดการข้อมูลสามประเภท โดยแต่ละประเภทมีวัตถุประสงค์เฉพาะในโฟลว์ OAuth:

ผู้ตรวจสอบ PKCE (129 )สิ่งเหล่านี้จะถูกเก็บไว้เมื่อเริ่มต้นโฟลว์ OAuth และอ่านอีกครั้งหลังจากที่ผู้ใช้ให้สิทธิ์การเข้าถึง เป็นส่วนหนึ่งของโฟลว์ PKCE (Proof Key for Code Exchange) ซึ่งให้ความปลอดภัยเพิ่มเติมสำหรับ OAuth ในไคลเอ็นต์สาธารณะโดยทำให้แน่ใจว่าแอปพลิเคชันที่เริ่มโฟลว์นั้นเป็นแอปพลิเคชันเดียวกับที่ทำให้เสร็จสมบูรณ์ (ตามที่กำหนดไว้ใน RFC 7636)

{
 "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"
}