用 SseEmitter 的方式返回，前端显示问号怎么解决。

[topcss]

我用的这段代码。 `

@GetMapping("/chat/sse")
@CrossOrigin
public SseEmitter sseEmitter(String prompt) {
   //国内需要代理 国外不需要
   Proxy proxy = Proxys.http("127.0.0.1", 1080);

   ChatGPTStream chatGPTStream = ChatGPTStream.builder()
            .timeout(600)
            .apiKey("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")
            .proxy(proxy)
            .apiHost("https://api.openai.com/")
            .build()
            .init();

    SseEmitter sseEmitter = new SseEmitter(-1L);

    SseStreamListener listener = new SseStreamListener(sseEmitter);
    Message message = Message.of(prompt);

    listener.setOnComplate(msg -> {
        //回答完成，可以做一些事情
    });
    chatGPTStream.streamChatCompletion(Arrays.asList(message), listener);

    return sseEmitter;
}

`

[topcss]

我解决了，重写了这个类。

package com.plexpt.chatgpt.util;

import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

import java.nio.charset.Charset;

public final class SseHelper {
    public static void complete(SseEmitter sseEmitter) {
        try {
            sseEmitter.complete();
        } catch (Exception var2) {
        }

    }

    public static void send(SseEmitter sseEmitter, Object data) {
        try {
            if (data == null) {
                sseEmitter.send("\n");
            } else {
                sseEmitter.send(data.toString().getBytes(Charset.forName("UTF-8")));
            }
        } catch (Exception var3) {
        }

    }

    private SseHelper() {
        throw new UnsupportedOperationException("This is a utility class and cannot be instantiated");
    }
}