Golang实现OpenAI流式处理的技术探讨

Golang实现OpenAI流式处理的技术探讨 大家好，请帮帮忙。 我正在使用OpenAI构建一个聊天机器人，并且想使用流式传输。问题是当OpenAI响应并添加一个单词时，Go会添加一行。结果在我的终端中，我得到了这个：

Stream response: 
Hello
Hello!
Hello! How
Hello! How can
Hello! How can I
Hello! How can I assist
Hello! How can I assist you
Hello! How can I assist you today
Hello! How can I assist you today

Stream finished

这是我的代码

// With Streaming Response --- SSE
func ChatWithBot() gin.HandlerFunc {

	return func(c *gin.Context) {

		var message MessageRequest

		// Getting the response from user
		err := c.BindJSON(&message)

		if err != nil {
			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
			return

		}

		userMessage := message.Message

		// Setting the modal

		OpenAI_API_Key := os.Getenv("OPENAI_API_KEY")

		openAiClient := openai.NewClient(OpenAI_API_Key)

		ctx := context.Background()

		reqToOpenAI := openai.ChatCompletionRequest{
			Model:     openai.GPT3Dot5Turbo,
			MaxTokens: 8,
			Messages: []openai.ChatCompletionMessage{
				{
					Role:    openai.ChatMessageRoleUser,
					Content: userMessage,
				},
			},
			Stream: true,
		}

		stream, err := openAiClient.CreateChatCompletionStream(ctx, reqToOpenAI)

		if err != nil {
			fmt.Printf("Error creating completion")
			c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
			return
		}

		defer stream.Close()

		// w := c.Writer
		// w.Header().Set("Content-Type", "text/plain; charset=utf-8")
		// c.Header("Cache-Control", "no-cache")
		// c.Header("Connection", "keep-alive")

		fmt.Printf("Stream response: ")

		full := ""

		for {
			response, err := stream.Recv()
			if errors.Is(err, io.EOF) {
				fmt.Println("\nStream finished")
				break

			}

			if err != nil {
				fmt.Printf("\nStream error: %v\n", err)
				return
			}

			openAIReply := response.Choices[0].Delta.Content

			// Send each new reply as a separate SSE message

			// Remove any newline characters from the response
			openAIReply = strings.ReplaceAll(openAIReply, "\n", "")

			full += openAIReply

			fmt.Println(full)

			c.Writer.Write([]byte(full))
			c.Writer.(http.Flusher).Flush()
		}



}

而在前端我得到了这个

作为参考，这是我试图重写的JS代码

async function main() {
    let full = "";

    const completion = await openai.chat.completions.create({
        message: [{ role: "user", content: "Recipes for chicken fry" }],
        model: "gpt-3.5-turbo",
        stream: true,
    });

    for await (const part of completion) {
        let text = part.choices[0].delta.content;
        full += text;

        console.clear();

        console.log(full);
    }
}

谢谢