zoukankan      html  css  js  c++  java
  • [go] 解决:concurrent write to websocket connection

    出现这个问题是因为并发的调用了github.com/gorilla/websocket库的WriteMessage方法

    在websocket连接上有多个groutinue同时调用写方法

    go官方的解释:

    websocket · pkg.go.dev

    并发 
    连接支持一个并发读取器和一个并发写入器。

    应用程序负责确保不超过一个 goroutine 同时调用写入方法(NextWriter、SetWriteDeadline、WriteMessage、WriteJSON、EnableWriteCompression、SetCompressionLevel),并且不超过一个 goroutine 调用读取方法(NextReader、SetReadDeadline、ReadMessage、ReadJSON、SetPongHandler) , SetPingHandler) 并发。

    Close 和 WriteControl 方法可以与所有其他方法可以并发调用。

    每一个请求都是一个groutine,如果有多个groutine同时请求并且要写回数据,就会出现这个错误

    一定要加上锁,并且在业务上避免多个同时调用

    我遇到的问题是,我有两个结构体,但是conn是同一个,虽然每一个在调用时加了锁,只是锁定不同的结构体,所以User和Message同时调用还是有并发问题

    type User struct {
        Conn       *websocket.Conn
        Name       string
        Id         string
        Avator     string
        To_id      string
        Ent_id     string
        Role_id    string
        Mux        sync.Mutex
        UpdateTime time.Time
    }
    type Message struct {
        conn        *websocket.Conn
        context     *gin.Context
        content     []byte
        messageType int
        Mux         sync.Mutex
    }

    开源作品

    GO-FLY,一套可私有化部署的免费开源客服系统,安装过程不超过五分钟(超过你打我 !),基于Golang开发,二进制文件可直接使用无需搭开发环境,下载zip解压即可,仅依赖MySQL数据库,是一个开箱即用的网页在线客服系统,致力于帮助广大开发者/中小站长快速整合私有客服功能
    github地址:go-fly
    官网地址:https://gofly.sopans.com

    赞赏作者

    微信交流

  • 相关阅读:
    Codeforces 1184C1. Heidi and the Turing Test (Easy)题解
    CodeChef Chef and Digit Jumps 题解
    CodeChef Squirrel and chestnut 题解
    Atcoder Beginner Contest 082 C
    Atcoder Beginner Contest 081 C
    Atcoder Beginner Contest 080 C
    Atcoder Beginner Contest 079 C
    Atcoder Beginner Contest 078 C
    Topcoder 10524(SRM451 Div.1 C) BrickPuzzle题解
    广义表是非线性结构
  • 原文地址:https://www.cnblogs.com/taoshihan/p/14975675.html
Copyright © 2011-2022 走看看