go 实现多人聊天系统需求和设计

淡淡的烟草味﹌ 2021-07-24 19:14 445阅读 0赞

# 一 需求 #

完成指定用户的登录。

# 二 图解 #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1][]

# 三 用户登录设计步骤和思路 #

**1 完成客户端发送消息长度，服务器端可以正常收到该长度值。**

确定消息 Message 的格式和结构。

**2 完成客户端可以发送消息本身，服务器端可以正常接收到消息，并根据客户端发送的消息(LoginMes), 判断用户的合法性，并返回相应的 LoginResMes。**

a 让客户端发送消息本身。

b 服务器端接受到消息，然后反序列化成对应的消息结构体。

c 服务器端根据反序列化后对应的消息，判断是登录用户是否合法，返回 LoginResMes。

d 客户端解析返回的 LoginResMes，显示对应界面。

e 将读取包的任务封装到了一个函数中 readPkg()。

**3 能够完成登录，并提示响应的信息。**

**4 程序结构的改进。**

前面3步虽然完成了功能，但是没有结构。系统的可读性、扩展性和维护性都不好。因此需要对程序的结构进行改进。

a 先改进服务端。改进方法：先画出程序的框架图，再写代码。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 2][]

b 具体改进步骤。

\[1\]  先把分析出来的文件，创建好，然后放到相应的文件夹。

\[2\] 再根据各个文件，完成的任务不同，将 main.go 的代码剥离到对应的文件中即可。

\[3\] 修改 utils/utils.go

\[4\] 修改 process2/userProcess.go

\[5\] 修改 main/processor.go

\[6\] 修改 main/main.go

5 修改客户端，画出程序的框架图。

\[1\] 画出示意图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 3][]

\[2\] 把各个文件放到对应的文件夹。

\[3\] 将 server/utils.go 拷贝到 client/utils/utils.go。

\[4\] 创建 server/process/userProcess.go

说明：该文件就是在原来的 login.go 做了一个改进，即封装到 UserProcess 结构体。

\[5\] 创建了 server/process/server.go。

\[6\] server/main/main.go 修改。

**6 在 Redis 手动添加测试用户。**

**7 如输入的用户名密码在 Redis 中存在，则登录。否则退出系统，并给出相应的提示信息。**

a 用户不存在，可以重新注册，再登录。

b 密码不正确。

# 四 用户注册的步骤和思路 #

完成注册功能，将用户信息录入到 Redis。

**1 先把 user.go 放入到common/message 文件夹。**

**2 common/message/message.go 新增加两个消息类型。**

**3 在客户端接收用户的输入。**

**4 在client/process/userProcess.go 增加一个 Register方法，完成请求注册。**

**5 在sever/model/userDao.go 增加了一个方法 Register方法。**

# 五 完成登录时能返回当前在线用户列表 #

**1 用户登录后，可以得到当前在线用户列表。**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 4][]

**2 当一个新用户上线后，其他已经登录的用户也能获取最新在线用户列表。**

思路有三个。

思路一

当有一个用户上线后，服务器就马上把维护的onlineUsers map整体推送。

思路二

服务器有自己的策略，每隔一定的时间，把维护的 onlineUsers map 整体推送。

思路三

a 当一个用户A上线，服务器就把A用户的上线信息，推送给所有在线的用户。

b 客户端也需要维护一个 map，map 中记录了他的好友（目前就是所有人）map\[int\]User。

c 客户端和服务器的通讯通道，要依赖 serverProcessMes 协程。

我们采用思路三。

# 六 完成群聊功能思路 #

**1 新增一个消息结构体 SmsMes。**

**2 新增一个 model.CurUser。**

**3 在 smsProcess.go 增加相应的方法  SendGroupMes, 发送一个群聊的消息。**

**4 在服务器端接收到SmsMes 消息。**

**5 在 server/process/smsProcess.go 文件增加群发消息的方法。**

**6 在客户端 还要增加去处理服务器端转发的群发消息SmsMes。**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70]: /images/20210724/42eef146b5104a788a8d0d2d0e1fb6b7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1]: /images/20210724/e69d334e60ab49648d4ed758797a2cb4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 2]: /images/20210724/287721162c894fcd884646d01a0e3ebe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 3]: /images/20210724/d7de9ab1976c44fb81f9104b1cdd9399.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 4]: /images/20210724/97f9e8c41d8f41ddaca37549dc7bb95b.png