add handler threadpool sse

Author: litongjava

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

@@ -193,6 +193,146 @@ public class MessageHander {
 
 ```
 
+### handler 配合线程池,读取音频文件并发送
+
+实现了一个 SSE 服务端，用于从资源文件中读取音频数据，并将其作为 Base64 编码的二进制数据块发送给客户端。它使用了一个线程池来异步处理数据传输，并在应用程序关闭时正确关闭线程池。
+
+```
+import java.util.concurrent.ExecutorService;
+
+import com.litongjava.jfinal.aop.annotation.AConfiguration;
+import com.litongjava.jfinal.aop.annotation.AInitialization;
+import com.litongjava.tio.boot.server.TioBootServer;
+import com.litongjava.tio.utils.thread.ThreadUtils;
+
+@AConfiguration
+public class ExecutorServiceConfig {
+
+  @AInitialization
+  public void config() {
+    // 创建包含10个线程的线程池
+    ExecutorService executor = ThreadUtils.newFixedThreadPool(10);
+
+    // 项目关闭时，关闭线程池
+    TioBootServer.me().addDestroyMethod(() -> {
+      if (executor != null && !executor.isShutdown()) {
+        executor.shutdown();
+      }
+    });
+
+  }
+}
+```
+
+```
+import java.io.InputStream;
+import java.util.Arrays;
+import java.util.Base64;
+
+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 com.litongjava.tio.utils.hutool.ResourceUtil;
+import com.litongjava.tio.utils.thread.ThreadUtils;
+
+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) {
+    // 读取音频文件,准备音频流
+    InputStream inputStream = ResourceUtil.getResourceAsStream("audio/01.mp3");
+
+    ThreadUtils.getFixedThreadPool().submit(() -> {
+      // 手动移除连接
+      String eventName = "data";
+
+      try {
+        // 从InputStream读取数据并转换为字符串
+        byte[] buffer = new byte[1024 * 10];
+        int bytesRead;
+        int id = 0;
+        while ((bytesRead = inputStream.read(buffer)) != -1) {
+          // 创建SsePacket并发送
+          byte[] binaryData = Arrays.copyOf(buffer, bytesRead);
+          String base64Data = Base64.getEncoder().encodeToString(binaryData);
+          SsePacket ssePacket = new SsePacket().id(id).event(eventName).data(base64Data.getBytes());
+          Tio.send(channelContext, ssePacket);
+          id++;
+          log.info("id:{}", id);
+        }
+      } catch (Exception e) {
+        log.error("Error sending data: {}", e.getMessage());
+      } finally {
+        try {
+          inputStream.close();
+        } catch (Exception e) {
+          log.error("Error closing input stream: {}", e.getMessage());
+        }
+        Tio.remove(channelContext, "remove sse");
+      }
+    });
+  }
+}
+```
+
+代码包含两个 Java 类: `ExecutorServiceConfig` 和 `MessageHander`。以下是每个类的文档说明:
+
+**ExecutorServiceConfig**
+
+这个类用于配置和管理线程池。它使用了 JFinal AOP 注解进行配置。
+
+- `@AConfiguration`: 这个注解表示该类是一个配置类。
+- `config()` 方法:
+  - 使用 `ThreadUtils.newFixedThreadPool(10)` 创建了一个包含 10 个线程的线程池。
+  - 注册了一个 `DestroyMethod`，在应用程序关闭时关闭线程池。
+
+**MessageHander**
+
+这个类负责处理和发送音频数据。它实现了服务器发送事件 (Server-Sent Events, SSE) 的功能。
+
+- `@Slf4j`: 这个注解自动配置了一个 slf4j 日志记录器。
+- `send(HttpRequest httpRequest)` 方法:
+  - 从 `HttpRequest` 对象中获取 `ChannelContext`。
+  - 设置 SSE 响应头。
+  - 发送 HTTP 响应包以保持连接。
+  - 调用 `sendData` 方法发送数据。
+  - 返回一个新的 `HttpResponse` 对象，并设置 `setSend(false)` 以避免重复发送响应。
+- `sendData(ChannelContext channelContext)` 方法:
+  - 从资源文件中读取音频文件。
+  - 在线程池中执行以下操作:
+    - 初始化一个 10KB 的缓冲区。
+    - 从输入流中循环读取数据。
+    - 为每个读取的数据块:
+      - 创建一个新的字节数组，仅包含实际读取的字节数。
+      - 使用 Base64 编码器将字节数组编码为字符串。
+      - 创建一个新的 `SsePacket` 对象，包含 ID、事件名称和编码后的数据。
+      - 使用 `Tio.send` 发送 `SsePacket` 对象。
+      - 增加 ID 计数器。
+      - 记录日志信息。
+    - 在循环结束时关闭输入流。
+    - 移除 `ChannelContext` 连接。
+
 ### 总结
 
 通过上述步骤，你可以在 tio-boot 框架中成功整合 SSE，从而使你的应用能够实时地向客户端推送数据。这种方法的优点在于其简单性和低延迟，非常适用于需要服务器实时更新的场景。