net/ghttp: stream content might be splitted

[lcm1475]

Go version

go version go1.21.5 darwin/arm64

GoFrame version

v2.6.1

Can this bug be reproduced with the latest release?

Option Yes

What did you do?

gf的流式输出在移动端会断开把一次的数据截断成2次发送，同样的代码放到gin就没问题
而且这个情况web看不出来，打印输出到web页面上是没问题的，移动端才能复现这个问题，Android，ios，Flutter，这些移动端必现，但是Android，ios，Flutter这些接入官方的openai，bing，文心，或者gin都是正常的，只有gf会断开，
把数据缩短好像断开的情况就很少了，但是实际业务中没办法缩短数据，一串json不可能分开发送

What did you see happen?

数据会有断开的情况

What did you expect to see?

希望不要断开

[lcm1475]

func (p *TestController) GetStreamTestV2(r *ghttp.Request) {
	r.Response.Header().Set("Content-Type", "text/event-stream")
	r.Response.Header().Set("Transfer-Encoding", "chunked")
	r.Response.Header().Set("Cache-Control", "no-cache")
	r.Response.Header().Set("Connection", "keep-alive")
	r.Response.Header().Set("X-Accel-Buffering", "no")

	for i := 0; i < 10; i++ {
		time.Sleep(500 * time.Millisecond)
		r.Response.Write("{\"choices\":[{\"message\":{\"content\":\"我是一条示例的数据\"}}],\"req_id\":\"202405161153160000621695B542BC2D9E\"}")
		r.Response.Flush()
	}

	return
}

[lcm1475]

下面是gin的例子 同样输出的内容 gin不会断开

func main() {
	r := gin.Default()
	r.GET("/ping", func(c *gin.Context) {
		atomic.AddInt32(&GlobalVarDemo, 1)
		c.JSON(200, gin.H{
			"gggg": GlobalVarDemo,
		})
	})

	r.GET("/testStream", func(ctx *gin.Context) {
		w := ctx.Writer
		ctx.Writer.Header().Set("Content-Type", "text/event-stream")
		ctx.Writer.Header().Set("Transfer-Encoding", "chunked")
		ctx.Writer.Header().Set("Cache-Control", "no-cache")
		ctx.Writer.Header().Set("Connection", "keep-alive")
		ctx.Writer.Header().Set("X-Accel-Buffering", "no")
		for i := 0; i < 10; i++ {
			time.Sleep(500 * time.Millisecond)
			_, _ = fmt.Fprint(w, "data: %s\n\n", "{\"choices\":[{\"message\":{\"content\":\"我是一条示例的数据\"}}],\"req_id\":\"202405161153160000621695B542BC2D9E\"}")
			w.Flush()
		}
	})
	http.ListenAndServe(":8081", r)
	//r.Run()
}

[hamster1963]

// 发送数据
request.Response.Writefln("data: " + gjson.New(sseData).String() + "\n")
request.Response.Flush()

试试用Writefln，在使用中还没有出现过截断

[Issues-translate-bot]

Bot detected the issue body's language is not English, translate it automatically. 👯👭🏻🧑‍🤝‍🧑👫🧑🏿‍🤝‍🧑🏻👩🏾‍🤝‍👨🏿👬🏿

---

//Send data request.Response.Writefln("data: " + gjson.New(sseData).String() + "\n") request.Response.Flush()
Try using Writefln, no truncation has occurred during use.

[lcm1475]

// 发送数据 request.Response.Writefln("data: " + gjson.New(sseData).String() + "\n") request.Response.Flush() 试试用Writefln，在使用中还没有出现过截断

试过了 不行 截断的情况只有在移动端才能复现

[Issues-translate-bot]

Bot detected the issue body's language is not English, translate it automatically. 👯👭🏻🧑‍🤝‍🧑👫🧑🏿‍🤝‍🧑🏻👩🏾‍🤝‍👨🏿👬🏿

---

// Send data request.Response.Writefln("data: " + gjson.New(sseData).String() + "\n") request.Response.Flush() Try using Writefln, it is not in use yet Truncation occurred

I tried it, but it didn’t work. The truncation situation can only be reproduced on the mobile terminal.

[gqcn]

@lcm1475 请尝试使用文档的v2.4以下版本的方式看是否复现：https://goframe.org/pages/viewpage.action?pageId=84084732

package main

import (
	"fmt"
	"net/http"
	"time"

	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/net/ghttp"
)

func main() {
	s := g.Server()
	s.BindHandler("/", func(r *ghttp.Request) {
		rw := r.Response.RawWriter()
		flusher, ok := rw.(http.Flusher)
		if !ok {
			http.Error(rw, "Streaming unsupported!", http.StatusInternalServerError)
			return
		}
		r.Response.Header().Set("Content-Type", "text/event-stream")
		r.Response.Header().Set("Cache-Control", "no-cache")
		r.Response.Header().Set("Connection", "keep-alive")

		for i := 0; i < 100; i++ {
			_, err := fmt.Fprintf(rw, "data: %d\n", i)
			if err != nil {
				panic(err)
			}
			flusher.Flush()
			time.Sleep(time.Millisecond * 200)
		}
	})
	s.SetPort(8999)
	s.Run()
}