前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >[go] 解决:concurrent write to websocket connection

[go] 解决:concurrent write to websocket connection

作者头像
唯一Chat
发布2021-07-08 10:41:47
2.9K0
发布2021-07-08 10:41:47
举报
文章被收录于专栏:陶士涵的菜地

出现这个问题是因为并发的调用了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同时调用还是有并发问题

代码语言:javascript
复制
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
}
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2021-07-06 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
文件存储
文件存储(Cloud File Storage,CFS)为您提供安全可靠、可扩展的共享文件存储服务。文件存储可与腾讯云服务器、容器服务、批量计算等服务搭配使用,为多个计算节点提供容量和性能可弹性扩展的高性能共享存储。腾讯云文件存储的管理界面简单、易使用,可实现对现有应用的无缝集成;按实际用量付费,为您节约成本,简化 IT 运维工作。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档