solon + forest + dify 学习AI聊天SSE通讯前后端交互功能，SseEmitter 使用问题

### 如何复现：

solon + forest + dify

学习AI聊天SSE通讯前后端交互功能

接口代码
```java
package org.noear.solon.examples.dify.controller;

import com.alibaba.fastjson2.JSONObject;
import com.dtflys.forest.http.ForestSSE;
import com.dtflys.forest.sse.SSELinesMode;
import lombok.extern.slf4j.Slf4j;
import org.noear.solon.annotation.Controller;
import org.noear.solon.annotation.Inject;
import org.noear.solon.annotation.Mapping;
import org.noear.solon.examples.dify.client.DifyApiClient;
import org.noear.solon.web.sse.SseEmitter;

import java.io.IOException;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.ConcurrentHashMap;

@Slf4j
@Controller
public class ChatController {

@Inject
    private DifyApiClient difyApiClient;

private final Map<String, SseEmitter> emitters = new ConcurrentHashMap<>();

@Mapping("/chat/stream")
    public SseEmitter chatStream(String prompt, String userId) throws Exception {
        //
        SseEmitter senderEmitter = new SseEmitter(300 * 1000);
        // 设置完成和超时回调
        senderEmitter.onCompletion(() -> {
            log.info("onCompletion: {}", userId);
            emitters.remove(userId);
        });
        senderEmitter.onTimeout(() -> {
            log.info("onTimeout: {}", userId);
            senderEmitter.complete();
            emitters.remove(userId);
        });
        //
        ForestSSE forestSSE = difyApiClient.streamCompletion(
                prompt,
                new JSONObject(),
                userId,
                "streaming"
        );
        forestSSE.setOnOpen(eventSource -> {
            log.info("setOnOpen: \nname={},\nvalue={},\ndata={}", eventSource.name(), eventSource.value(), eventSource.data());
        });
        forestSSE.setOnClose(eventSource -> {
            log.info("setOnClose: \nname={},\nvalue={},\ndata={}", eventSource.name(), eventSource.value(), eventSource.data());
            if(Objects.nonNull(senderEmitter)) {
                senderEmitter.complete();
            }
        });
        forestSSE.setOnMessage(eventSource -> {
            String data = eventSource.data();
            log.info("setOnMessage: \nname={},\nvalue={},\ndata={}", eventSource.name(), eventSource.value(), data);
            if (Objects.isNull(data)) {
                log.info("data is null");
                return;
            }
            try {
                senderEmitter.send(data);
            } catch (IOException e) {
                log.error("Error sending data to client: {}", e.getMessage(), e);
            }
        });
        forestSSE.listen(SSELinesMode.SINGLE_LINE); // 启动监听
        return senderEmitter;
    }
}

```
调用这个方法的时候报空指针异常
senderEmitter.complete();

查看
SseEmitter 源码
```java
   public void complete() {
        try {
            eventHandler.complete();
        } catch (IOException e) {
            log.warn(e.getMessage(), e);
        }
    }
```

eventHandler 是 null

发现初始化 eventHandler 是一个内部方法

```java
    /**
     * 初始化
     */
    protected void initialize(SseEmitterHandler handler) throws Throwable {
        this.eventHandler = handler;

//1.发送初始化之前的事件
        for (SseEvent event : eventCached) {
            eventHandler.send(event);
        }

//2.开始初始化（一般也是发消息）
        if (onInited != null) {
            onInited.accept(this);
        }
    }
```

不知道是 SseEmitter 我使用错误，还是代码有bug。

--- 分割线 ---

另外一个问题，调用 senderEmitter.send(""); 方法后，前端没有实时收到数据，

### 预期结果：

同上

### 实际结果：

同上

### 截图或视频：

### 关联版本：

3.1.2

GVP opensolon/solon

内容风险标识

评论 (1)

GVPopensolon/solon

内容风险标识