diff --git a/src/utils/querySSE.ts b/src/utils/querySSE.ts
index 1ea53d6..8097c5a 100644
--- a/src/utils/querySSE.ts
+++ b/src/utils/querySSE.ts
@@ -70,15 +70,14 @@ export default async (config: SSEConfig, url: string = DEFAULT_SSE_URL): Promise
       }
     },
     onerror(error: Error) {
-      //   console.error('SSE error:', error);
+      // 请求失败时主动关闭SSE连接
+      abortController.abort();
       handleError?.(error);
     },
     onclose() {
-      //   console.log('SSE connection closed');
       handleClose?.();
     },
     async onopen(response: Response) {
-      //   console.log('onopen', response);
       handleOpen?.(response);
     },
   });