MCP笔记02: MCP的核心架构

 1class Protocol<Request, Notification, Result> {
 2    // Handle incoming requests
 3    setRequestHandler<T>(schema: T, handler: (request: T, extra: RequestHandlerExtra) => Promise<Result>): void
 4
 5    // Handle incoming notifications
 6    setNotificationHandler<T>(schema: T, handler: (notification: T) => Promise<void>): void
 7
 8    // Send requests and await responses
 9    request<T>(request: Request, schema: T, options?: RequestOptions): Promise<T>
10
11    // Send one-way notifications
12    notification(notification: Notification): Promise<void>
13}

 1class Session(BaseSession[RequestT, NotificationT, ResultT]):
 2    async def send_request(
 3        self,
 4        request: RequestT,
 5        result_type: type[Result]
 6    ) -> Result:
 7        """Send request and wait for response. Raises McpError if response contains error."""
 8        # Request handling implementation
 9
10    async def send_notification(
11        self,
12        notification: NotificationT
13    ) -> None:
14        """Send one-way notification that doesn't expect response."""
15        # Notification handling implementation
16
17    async def _received_request(
18        self,
19        responder: RequestResponder[ReceiveRequestT, ResultT]
20    ) -> None:
21        """Handle incoming request from other side."""
22        # Request handling implementation
23
24    async def _received_notification(
25        self,
26        notification: ReceiveNotificationT
27    ) -> None:
28        """Handle incoming notification from other side."""
29        # Notification handling implementation