V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
The Go Programming Language
http://golang.org/
Go Playground
Go Projects
Revel Web Framework
beego
GeekHub
swqslwl
V2EX  ›  Go

golang 使用 websocket 发送数据给前端,总是会有丢包的情况发生

  •  
  •   swqslwl · 12 天前 · 1283 次点击

    报错有时是 write:broken pipe. 有时是 An established connection was aborted by the software in your host machine. 有时不报错,wrieshark 抓包发现包全部发出去了,但前端就是会丢包。

    上个帖子犯了个低级错误用了共享内存变量,现在改为用 channel 了,想知道是不是还是我后端代码的问题。

    如果有提供很大帮助思路的,小弟可以给予一定的酬谢。

    var dataTmp = make(chan []byte, 9999)
    var t = make(chan []byte, 9999)
    
    var upgrader = websocket.Upgrader{
    	//	ReadBufferSize: 1024,
    	WriteBufferSize: 1024,
    	// 允许所有的 CORS 跨域请求,正式环境可以关闭
    	CheckOrigin: func(r *http.Request) bool {
    		return true
    	},
    }
    
    func init() {
    	http.HandleFunc("/ws", wsHandler)
    	go http.ListenAndServe("173.10.10.100:88", nil)
    }
    
    func wsHandler(resp http.ResponseWriter, req *http.Request) {
    	// 答客户端告知升级连接为 websocket
    	wsSocket, err := upgrader.Upgrade(resp, req, nil)
    	if err != nil {
    		fmt.Println("升级为 websocket 失败", err.Error())
    		return
    	}
    	go wsWriteLoop(wsSocket)
    }
    
    // 发送消息给客户端
    func wsWriteLoop(wsConn *websocket.Conn) {
    	for {
    		select {
    		case terror := <-t:
    			fmt.Println("错误重新发送")
    			fmt.Println(terror)
    			err := wsConn.WriteMessage(websocket.TextMessage, terror)
    			if err != nil {
    				fmt.Println("再次发送", err.Error())
    				t <- terror
    				return
    			}
    
    		case tmp := <-dataTmp:
    			err := wsConn.WriteMessage(websocket.TextMessage, tmp)
    			if err != nil {
    				fmt.Println("发送消息给客户端发生错误", err.Error())
    				t <- tmp
    				return
    			}
    		}
    	}
    }
    
    11 条回复    2020-09-21 10:48:58 +08:00
    xkeyideal
        1
    xkeyideal   12 天前
    既然楼主大大方方的说要给酬劳了,那么就先说说能给多少吧。
    这段代码呢,在某些环境下没有问题,也看不出问题;但其实槽点慢慢,可以给你一份比较完整的 golang websocket 的处理代码,至于能不能解决你说的问题不清楚,你这种问题个人从来没遇到
    bjt
        2
    bjt   12 天前
    楼主怕是想错了,这个不是丢包,就是网络中断。你本地送出去了并不代表对方能收到。
    est
        3
    est   12 天前
    一般的设计不是解决丢包,而是在承认丢包的前提下再多发几遍。。。
    xx6412223
        4
    xx6412223   12 天前
    先把逻辑写正确吧。还所有连接共用一个错误 channel
    sujin190
        5
    sujin190   12 天前
    你手动这两错误本身就是正常的吧,你这个 for 是死循环的,又没有检查 websocket 连接是否断开的情况,如果前端有异常断开了你再写就会返回这个错误啊,前端断开一般会重连,所以你应该断开后数据就保存再 chan 中,重连之后再往新的连接中写,具体是不是这样和为啥断开不行可以抓包仔细看看
    des
        6
    des   12 天前
    你这两个报错,就是网络连接断开了,不是前端丢包的问题
    joesonw
        7
    joesonw   12 天前
    websocket 协议保证了你收到的 frame 就是完整的没拆开的 frame. 如果丢包了肯定不是代码的问题, 而是库的问题(发送端 /接收端)
    wysnylc
        8
    wysnylc   12 天前
    xdeng
        9
    xdeng   12 天前
    9999 就很不程序员了
    suke971219
        10
    suke971219   11 天前
    bluetroy
        11
    bluetroy   8 天前
    基于 tcp 协议的协议是不会丢包的。题主在开始编程工作之前应当好好学习计算机基础知识
    关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   2631 人在线   最高记录 5168   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 19ms · UTC 13:37 · PVG 21:37 · LAX 06:37 · JFK 09:37
    ♥ Do have faith in what you're doing.