// 連接建立過程
@Override
publicMono<Void>connect(Function<Mono<JSONRPCMessage>, Mono<JSONRPCMessage>> handler){
    // 1. 訂閱 SSE 事件流，就像打開收音機(jī)
    sseClient.subscribe(this.baseUri +this.sseEndpoint,newFlowSseClient.SseEventHandler(){
        @Override
        publicvoidonEvent(SseEvent event){
            // 2. 處理 endpoint 事件，獲取消息發(fā)送端點(diǎn)
            if(ENDPOINT_EVENT_TYPE.equals(event.type())){
                String endpoint = event.data();
                messageEndpoint.set(endpoint);
                // 連接建立完成
            }
            // 3. 處理服務(wù)器發(fā)來的消息
            elseif(MESSAGE_EVENT_TYPE.equals(event.type())){
                JSONRPCMessage message =McpSchema.deserializeJsonRpcMessage(objectMapper, event.data());
                handler.apply(Mono.just(message)).subscribe();
            }
        }
    });
    
    returnMono.fromFuture(future);
}

// 客戶端發(fā)送消息
@Override
publicMono<Void>sendMessage(JSONRPCMessage message){
    // 使用 HTTP POST 發(fā)送消息到服務(wù)器提供的端點(diǎn)
    // ...
}

// 處理 SSE 連接請(qǐng)求
privateServerResponsehandleSseConnection(ServerRequest request){
    // 創(chuàng)建會(huì)話，就像給每個(gè)客戶端分配一個(gè)專屬頻道
    String sessionId =UUID.randomUUID().toString();
    
    // 發(fā)送初始 endpoint 事件，告訴客戶端“我在哪”
    sseBuilder.id(sessionId)
        .event(ENDPOINT_EVENT_TYPE)
        .data(this.baseUrl +this.messageEndpoint +"?sessinotallow="+ sessionId);
    
    // 創(chuàng)建會(huì)話傳輸層
    WebMvcMcpSessionTransport sessionTransport =newWebMvcMcpSessionTransport(sessionId, sseBuilder);
    McpServerSession session = sessionFactory.create(sessionTransport);
    this.sessions.put(sessionId, session);
}

// 處理客戶端發(fā)來的消息
privateServerResponsehandleMessage(ServerRequest request){
    // 從請(qǐng)求中獲取會(huì)話 ID，就像找到對(duì)應(yīng)的聊天窗口
    String sessionId = request.param("sessionId").orElse(null);
    
    // 處理客戶端發(fā)來的消息
    // ...
    
    // 通過 SSE 連接發(fā)送響應(yīng)
    // ...
}

// 服務(wù)器向客戶端發(fā)送消息
@Override
publicMono<Void>sendMessage(McpSchema.JSONRPCMessage message){
    returnMono.fromRunnable(()->{
        try{
            String jsonText = objectMapper.writeValueAsString(message);
            sseBuilder.id(sessionId).event(MESSAGE_EVENT_TYPE).data(jsonText);
        }
        catch(Exception e){
            // 錯(cuò)誤處理
        }
    });
}