[Go WebSocket] 多房间的聊天室自动清理无人房间

Posted HullQin

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了[Go WebSocket] 多房间的聊天室自动清理无人房间相关的知识,希望对你有一定的参考价值。

背景

在专栏《Go WebSocket》里,有一些前置文章:

第一篇文章:《为什么我选用Go重构Python版本的WebSocket服务?》,介绍了我的目标。

第二篇文章:《你的第一个Go WebSocket服务: echo server》,介绍了一下怎么写一个WebSocket server。

第三篇文章:《单房间的聊天室》,介绍了如何实现一个单房间的聊天室。

第四篇文章:《多房间的聊天室(一)思考篇》,介绍了实现一个多房间的聊天室的思路。

第五篇文章:《多房间的聊天室(二)代码实现》,介绍了实现一个多房间的聊天室的代码。

如果你没阅读上面的文章,一定要先看一下,因为这篇文章更复杂,如果你不弄懂上面几篇,这篇可能跟不上节奏噢。

上篇文章我们提到:

今天,我们实现它。

思路

有一个重要的问题需要想清楚:

是在哪个地方执行这个【回收】操作?是哪个goroutine?什么时机?若有多个地方,有没有竞争关系?

回顾一下之前绘制的图:

可以发现:每个客户端连接会常驻2个goroutine:Read和Write。其中Read重要的职责就是unregister,这点我之前在《单房间的聊天室》强调过。

unregister就是把客户端连接从hub中删除掉。这个时候,我们就可以检查一下hub内是否还有其它客户端,若无,则删除。

注意,unregister只是个channel,真正的处理逻辑是写在goroutine中的,是哪个gotoutine负责接收unregister并执行逻辑呢?就是Hub。所以我们需要修改Hub代码。

直接看源码

多房间聊天室案例代码的地址:github.com/HullQin/go-websocket-examples

chat-multi-rooms文件夹中,文章可配套commit记录阅读:

开始开发

我们以《多房间的聊天室(二)代码实现》的代码为基础,做改动。

关注hub goroutine的代码:

func (h *Hub) run() 
   for 
      select 
      case client := <-h.register:
         h.clients[client] = true
      case client := <-h.unregister:
         if _, ok := h.clients[client]; ok 
            delete(h.clients, client)
            close(client.send)
         
      case message := <-h.broadcast:
         for client := range h.clients 
            select 
            case client.send <- message:
            default:
               close(client.send)
               delete(h.clients, client)
            
         
      
   

可以看到case client := <-h.unregister:这段代码,就是处理unregister逻辑的。

这里删除了hub中的对应客户端。删除时,我们检查一下h.clients是否为空即可,若为空,把hubhouse(房间集合)删掉,再结束这个hub goroutine即可。

但是,有个问题,这里我们要在house中删掉,是需要知道key的,key是roomId,最好从hub的属性中获得,目前还不支持,所以还需要给hub增加一个roomId属性,方便做删除。

if len(h.clients) == 0 
   delete(house, h.roomId)
   break

下面,我们增加roomId属性:

type Hub struct 
   // Identity of room.
   roomId string

   // Registered clients.
   clients map[*Client]bool

   // Inbound messages from the clients.
   broadcast chan []byte

   // Register requests from the clients.
   register chan *Client

   // Unregister requests from clients.
   unregister chan *Client


func newHub(roomId string) *Hub 
   return &Hub
      roomId:     roomId,
      broadcast:  make(chan []byte),
      register:   make(chan *Client),
      unregister: make(chan *Client),
      clients:    make(map[*Client]bool),
   

此外,还需要修改main.go,新建hub时,传入roomId

测试一下,大功告成!(可以在delete逻辑增加个日志输出)现在断开连接时,无人房间会自动清除掉!并且下次进入时,也会新建房间,不影响正常使用!

真的没问题了吗?

我又绘制了一个图(以一个房间为例),更加完整:

我用连线,表明了goroutine的启动关系:

  • User连接WebSocket服务器时,会先启动serveWs goroutine
  • serveWs goroutine中,会执行register操作,这一点之前的图中并没画出来。
  • 随后serveWs goroutine启动了Read goroutineWrite goroutine,并结束自己。

这里真的是完美方案不会出错吗?留个悬念,我们下篇文章,继续讲解。

写在最后

我是HullQin,公众号线下聚会游戏的作者(欢迎关注公众号,发送加微信,交个朋友),转发本文前需获得作者HullQin授权。我独立开发了《联机桌游合集》,是个网页,可以很方便的跟朋友联机玩斗地主、五子棋等游戏,不收费没广告。还独立开发了《合成大西瓜重制版》。还开发了《Dice Crush》参加Game Jam 2022。喜欢可以关注我 HullQin 噢~我有空了会分享做游戏的相关技术。

以上是关于[Go WebSocket] 多房间的聊天室自动清理无人房间的主要内容,如果未能解决你的问题,请参考以下文章

Spring WebSocket 多房间聊天

nodejs构建多房间简易聊天室

实现websocket多人聊天,很简单

PHP WebSocket 聊天:私人对话

用于聊天应用程序的多个 websocket 实例

EADDRINUSE 错误,用于在不同路径上打开 websocket 但在 nodejs 中的相同端口