03_GoLang语言正式课_Go网络编程_并发聊天室——go特性高并发核心的使用

2021-10-19

字数统计: 1.3k字 | 阅读时长≈ 4分

融合练习，综合复习

模块概述
广播用户上线
广播用户消息
展示在线用户
修改用户名
用户退出
超时处理

01、模块概述

主go程（服务器）
- 负责监听、接收用户（客户端）连接请求，建立通信关系。同时启动相应的go程处理任务。
处理用户连接的go程1：HandleConnect
- 负责新上线用户的存储，用户消息读取、发送，用户改名、下线处理及超时处理。
- 为了提高效率，同时给一个用户维护多个协程来并发处理上述任务。
用户消息广播的go程2：Manager
- 负责在线用户遍历，用户消息广播发送。需要与HandleConnect go程及用户子go程协作完成。
go程间应用数据及通信
- Map:存储所有登陆聊天室的用户信息，key:用户的ip+port. Value:Client结构体。
- Client结构体：包含成员：用户名Name，网络地址Addr(ip+port),发送消息的通道C（channel）
- 通道message：协调并发go程间消息的传递。
开发思想：不是使用串行，而是使用并行开发

![03-聊天室模块简析[00_13_21][20210903-144711].png](resources/ECBE2D641C2E812A3A44CC01040EBE90.png =1088x648)

1、全局位置定义用户结构体类型Client, 存储登陆用户信息

type Client struct{
  C chan string
  Name string
  Addr string
}

2、定义全局通道Message处理消息

3、定义全局Map存储所有在线用户信息。 key为用户网络地址。Value为用户结构体。

核心——代码逻辑

主go程，监听客户端连接请求，当有新的客户端连接，创建新go程HandleConnect处理用户连接。
HandleConnect go程，获取用户网络地址（ip+port），创建新用户结构体。新用户的Name和Addr初值都是用户网络地址（ip+port）。将用户结构体存入map中。并创建WriteMsgToClient go程，专门负责给当前用户发送消息。组织新用户上线广播消息内容，写入全局通道Message中。
WriteMsgToClient go程，读取用户结构体C中的数据，没有则阻塞等待，有数据写出给登陆用户。
Manager go程，给map分配空间。循环读取message通道中是否有数据。没有，阻塞等待。有则解除阻塞，将message通道中读到的数据写到用户结构体的C通道中。

01、广播用户上线：

**
**

1. 主go程中，创建监听套接字。记得defer

2. for 循环监听客户端连接请求。Accept()

3. 有一个客户端连接，创建新 go 程处理客户端数据 HandlerConnet(conn) defer

4. 定义全局结构体类型 C 、Name、Addr

5. 创建全局map、channel

6. 实现HandlerConnet，获取客户端IP+port —— RemoteAddr()。初始化新用户结构体信息。 name == Addr

7. 创建 Manager 实现管理go程。 —— Accept() 之前。

8. 实现 Manager 。初始化在线用户 map。循环读取全局 channel，如果无数据，阻塞。如果有数据，遍历在线用户 map ，将数据写到用户的 C 里

9. 将新用户添加到在线用户 map 中。 Key == IP+port value= 新用户结构体

10. 创建 WriteMsgToClient go程，专门给当前用户写数据。 —— 来源于用户自带的 C 中

11. 实现 WriteMsgToClient（clnt，conn）。遍历自带的 C ，读数据，conn.Write 到客户端。

12. HandlerConnet中，结束位置，组织用户上线信息，将用户上线信息写到全局 channel —— Manager 的读就被激活（原来一直阻塞）

13. HandlerConnet中，结尾加 for { ；}

02、广播用户消息：

1. 封装函数 MakeMsg() 来处理广播、用户消息

2. HandlerConnet中, 创建匿名go程，读取用户socket上发送来的聊天内容。写到全局 channel

3. for 循环 conn.Read n == 0 err != nil

4. 写给全局 message —— 后续的事，原来广播用户上线模块完成。（Manager、WriteMsgToClient）

03、查询在线用户：

1. 将读取到的用户消息 msg 结尾的 “\n”去掉。

2. 判断是否是“who”命令

3. 如果是，遍历在线用户列表，组织显示信息。写到 socket 中。

4. 如果不是。写给全局 message

****

04、修改用户名：

1. 将读取到的用户消息 msg 判断是否包含 “rename|”

2. 提取“|”后面的字符串。存入到Client的Name成员中

3. 更新在线用户列表。onlineMap。 key —— IP + prot

4. 提示用户更新完成。conn.Write

05、用户退出：

1. 在用户成功登陆之后，创建监听用户退出的 channel —— isQuit

2. 当 conn.Read == 0 , isQuit <- true

3. 在 HandlerConnet 结尾 for 中，添加 select 监听 <-isQuit

4. 条件满足。将用户从在线列表移除。组织用户下线消息，写入 message （广播）

06、超时处理：

1. 在 select 中监听定时器。（time.After()）计时到达。将用户从在线列表移除。组织用户下线消息，写入 message （广播）

2. 创建监听用户活跃的 channel —— hasData

3. 只用户执行：聊天、改名、who 任意一个操作，hasData<- true

4. 在 select 中添加监听 <-hasData。条件满足，不做任何事情。目的是重置计时器。

****

本文作者： 梁俊可
本文链接： http://ljk3d.com/2021/10/19/goLangNote/goLangAdvance/03_GoLang语言正式课_Go网络编程_并发聊天室——go特性高并发核心的使用/
版权声明： 梁俊可工作室