add send sse to client in hanlder

Author: litongjava

docs/zh/06_内置组件/02.md

@@ -1,13 +1,15 @@
 # Server-Sent Events (SSE)
 
-#### SSE 简介
+## SSE 简介
 
 Server-Sent Events（SSE）是一种允许服务器主动向客户端发送信息的技术。与 WebSocket 不同，SSE 是单向通信，仅服务器能向客户端发送数据。这使得 SSE 非常适合于需要服务器实时推送数据但客户端不需要发送信息的场景，例如实时通知和更新。
 
-#### tio-boot 中整合 SSE 的步骤
+## tio-boot 中整合 SSE 的步骤
 
 整合 SSE 到 tio-boot 框架中可以让你的应用具备实时数据推送的能力。以下是在 tio-boot 框架中创建一个简单的 SSE 应用的步骤和代码示例：
 
+### Controller 发送 SSE 数据
+
 ##### 步骤 1: 创建 SSE Controller
 
 首先，创建一个名为 `SseController` 的类，并用 `@RequestPath` 注解标记该类和方法。该方法将处理来自 `/sse` 路径的 SSE 请求。
@@ -71,24 +73,24 @@ curl http://localhost/sse
 测试结果应该显示一系列格式化的 SSE 消息：
 
 ```
-id:1
-event:message
-data:This is message 0
+id: 0
+event: message
+data: This is message 0
 
-id:2
-event:message
-data:This is message 1
+id: 1
+event: message
+data: This is message 1
 
-...
+id: 2
+event: message
+data: This is message 2
 ```
 
 每条消息都包含一个唯一的 `id`，事件类型 `event`，以及实际的消息内容 `data`。
 
 #### 完整的 Cotnroller
 
-```
-package com.litongjava.ai.chat.AController;
-
+```java
 import com.litongjava.tio.core.Tio;
 import com.litongjava.tio.http.common.HttpRequest;
 import com.litongjava.tio.http.common.HttpResponse;
@@ -136,6 +138,61 @@ public class SseController {
 
 ```
 
-#### 总结
+### Hanlder 发送 SSE 数据
+
+```java
+import com.litongjava.tio.core.ChannelContext;
+import com.litongjava.tio.core.Tio;
+import com.litongjava.tio.http.common.HttpRequest;
+import com.litongjava.tio.http.common.HttpResponse;
+import com.litongjava.tio.http.server.sse.SsePacket;
+
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class MessageHander {
+
+  public HttpResponse send(HttpRequest httpRequest) {
+
+    ChannelContext channelContext = httpRequest.getChannelContext();
+
+    // 设置sse请求头
+    HttpResponse httpResponse = new HttpResponse(httpRequest).setServerSentEventsHeader();
+
+    // 发送http响应包,告诉客户端保持连接
+    Tio.send(channelContext, httpResponse);
+
+    // 发送数据
+    sendData(channelContext);
+
+    // 告诉处理器不要将消息发送给客户端
+    return new HttpResponse().setSend(false);
+  }
+
+  private void sendData(ChannelContext channelContext) {
+
+    new Thread(() -> {
+      for (int i = 0; i < 10; i++) {
+        String eventName = "message";
+        String data = "This is message " + i;
+        SsePacket ssePacket = new SsePacket().id(i).event(eventName).data(data.getBytes());
+        // 再次向客户端发送消息
+        Tio.send(channelContext, ssePacket);
+        log.info("发送数据:{}", i);
+        try {
+          Thread.sleep(1000);
+        } catch (InterruptedException e) {
+          e.printStackTrace();
+        }
+      }
+      // 手动移除连接
+      Tio.remove(channelContext, "remove sse");
+    }).start();
+  }
+}
+
+```
+
+### 总结
 
-通过上述步骤，你可以在 tio-boot 框架中成功整合 SSE，从而使你的应用能够实时地向客户端推送数据。这种方法的优点在于其简单性和低延迟，非常适用于需要服务器实时更新的场景。
+通过上述步骤，你可以在 tio-boot 框架中成功整合 SSE，从而使你的应用能够实时地向客户端推送数据。这种方法的优点在于其简单性和低延迟，非常适用于需要服务器实时更新的场景。