Chat App 项目之解析（八）

Chat App 项目介绍与解析（一）-CSDN博客文章浏览阅读340次，点赞7次，收藏3次。Chat App 是一个实时聊天应用程序，旨在为用户提供一个简单、直观的聊天平台。该应用程序不仅支持普通用户的注册和登录，还提供了管理员登录功能，以便管理员可以查看和管理聊天记录。本文将详细介绍index.html文件的实现细节，包括代码解释、实现效果、实现方法以及后续需要实现的功能。https://blog.csdn.net/qq_45519030/article/details/141330140Chat App 项目之解析（二）-CSDN博客文章浏览阅读490次，点赞8次，收藏14次。在前一篇博客中，我们介绍了 Chat App 的主页index.html。本篇将深入探讨用户注册页面，包括其代码解释、实现效果、实现方法以及后续需要实现的功能。https://blog.csdn.net/qq_45519030/article/details/141330781Chat App 项目之解析（三）-CSDN博客文章浏览阅读422次，点赞15次，收藏10次。在前一篇博客中，我们介绍了用户注册页面。本篇将深入探讨用户登录页面login.html，包括其代码解释、实现效果、实现方法以及后续需要实现的功能。login.html。https://blog.csdn.net/qq_45519030/article/details/141331037

https://blog.csdn.net/qq_45519030/article/details/141331411https://blog.csdn.net/qq_45519030/article/details/141331411https://blog.csdn.net/qq_45519030/article/details/141331696https://blog.csdn.net/qq_45519030/article/details/141331696https://blog.csdn.net/qq_45519030/article/details/141331943https://blog.csdn.net/qq_45519030/article/details/141331943https://blog.csdn.net/qq_45519030/article/details/141332107https://blog.csdn.net/qq_45519030/article/details/141332107

项目概述

在前一篇博客中，我们详细介绍了管理员聊天记录页面 admin_chat_records.html。本篇将深入探讨后端服务 server.go，包括其代码解释、实现效果、实现方法以及后续需要实现的功能。

系统架构概述

本系统主要由以下几个部分组成：

1. 用户认证模块：负责用户的注册和登录。
2. WebSocket 通信模块：实现客户端与服务器之间的实时消息传递。
3. 数据库模块：存储用户信息和聊天记录。
4. 管理员接口：提供管理员查看、删除和过滤聊天记录的功能。
5. 用户在线状态管理：实时显示用户的在线状态。
6. 消息加密与解密：确保消息在传输过程中的安全性。
7. 用户权限控制：实现更复杂的用户权限管理。

核心功能实现

用户认证模块

用户认证模块主要包括用户注册和登录功能。用户注册时，系统会检查邮箱和密码的合法性，并将用户信息存储到数据库中。用户登录时，系统会验证用户的邮箱和密码是否匹配。

  

功能介绍

• 用户注册：接收用户提交的邮箱和密码，验证其合法性后，将用户信息存储到数据库中。
• 用户登录：接收用户提交的邮箱和密码，验证其是否匹配数据库中的记录。

示例代码：用户注册处理函数

package mainimport ("database/sql""fmt""log""net/http""github.com/go-sql-driver/mysql"
)var db *sql.DBfunc init() {var err errordb, err = sql.Open("mysql", "yonghuming:password@tcp(localhost:1234)/database")if err != nil {log.Fatal(err)}
}func registerHandler(w http.ResponseWriter, r *http.Request) {if r.Method != http.MethodPost {http.Error(w, "Method Not Allowed", http.StatusMethodNotAllowed)return}email := r.FormValue("email")password := r.FormValue("password")if err != nil {log.Println("Error registering user:", err)http.Error(w, "Registration failed", http.StatusInternalServerError)return}log.Printf("Registered user: %s\n", email)fmt.Fprintf(w, "Registered successfully")
}

代码解释：

• registerHandler 函数处理用户注册请求，首先检查请求方法是否为 POST。
• 从请求表单中获取邮箱和密码，并进行简单的验证。
• 使用 db.Exec 方法将用户信息插入到数据库中。
• 如果插入成功，返回注册成功的响应。

WebSocket 通信模块

WebSocket 通信模块负责实现客户端与服务器之间的实时消息传递。服务器使用 gorilla/websocket 库来升级 HTTP 连接为 WebSocket 连接，并维护一个连接池来管理所有活跃的 WebSocket 连接。当服务器接收到客户端发送的消息时，会将消息存储到数据库中，并广播给所有连接的客户端。

功能介绍

• WebSocket 连接管理：管理所有活跃的 WebSocket 连接。
• 消息处理：接收客户端发送的消息，存储到数据库中，并广播给所有连接的客户端。

示例代码：WebSocket 消息处理函数

package mainimport ("encoding/json""log""net/http""sync""github.com/gorilla/websocket"
)var upgrader = websocket.Upgrader{}func messageHandler(w http.ResponseWriter, r *http.Request) {if err != nil {log.Println("Error upgrading connection:", err)return}defer conn.Close()for {_, message, err := conn.ReadMessage()if err != nil {log.Println("Error reading message:", err)break}var msg struct {Email   string `json:"email"`Message string `json:"message"`}log.Printf("Received message from %s: %s\n")if err != nil {log.Println("Error inserting message:", err)}for conn := range connections {if err := conn.WriteJSON(msg); err != nil {continue}}}
}

代码解释：

• messageHandler 函数处理 WebSocket 消息，首先升级 HTTP 连接为 WebSocket 连接。
• 使用 connMutex 互斥锁管理连接池，确保并发安全。
• 循环读取客户端发送的消息，解析 JSON 格式的消息。
• 将消息存储到数据库中，并广播给所有连接的客户端。

数据库模块

数据库模块使用 MySQL 作为后端存储，存储用户信息和聊天记录。系统使用 database/sql 包来与 MySQL 数据库进行交互，并定义了用户和聊天记录的数据结构。

功能介绍

• 数据库连接：初始化并管理与 MySQL 数据库的连接。
• 数据存储：存储用户信息和聊天记录。

示例代码：初始化数据库连接

package mainimport ("database/sql""log""github.com/go-sql-driver/mysql"
)var db *sql.DBfunc init() {var err errorif err != nil {log.Fatal(err)}
}

代码解释：

• init 函数在程序启动时初始化数据库连接。
• 使用 sql.Open 方法连接到 MySQL 数据库。

管理员接口

管理员接口提供了查看、删除和过滤聊天记录的功能。管理员可以通过这些接口查看所有的聊天记录，删除指定的聊天记录，或者根据发送者邮箱、消息内容和时间范围来过滤聊天记录。

功能介绍

• 查看聊天记录：获取并返回所有的聊天记录。
• 删除聊天记录：根据记录 ID 删除指定的聊天记录。
• 过滤聊天记录：根据发送者邮箱、消息内容和时间范围过滤聊天记录。

示例代码：获取所有聊天记录

package mainimport ("encoding/json""log""net/http"
)func adminChatRecordsHandler(w http.ResponseWriter, r *http.Request) {if r.Method == "GET" {log.Println("Received request for chat records")if err != nil {log.Println("Database error:", err)return}defer rows.Close()var records []struct {ID        int    `json:"id"`Message   string `json:"message"`}for rows.Next() {var record struct {ID        int    `json:"id"`Message   string `json:"message"`}if err != nil {log.Println("Database error:", err)http.Error(w, "Database error", http.StatusInternalServerError)return}}jsonData, err := json.Marshal(records)if err != nil {log.Println("Error marshalling records:", err)http.Error(w, "Internal server error", http.StatusInternalServerError)return}log.Println("Returning chat records:", string(jsonData))w.Write(jsonData)}
}

代码解释：

• adminChatRecordsHandler 函数处理获取所有聊天记录的请求。
• 使用 db.Query 方法从数据库中查询所有的聊天记录。
• 将查询结果转换为 JSON 格式，并返回给客户端。

后续精彩内容请看下一篇！

 https://blog.csdn.net/qq_45519030/article/details/141334094https://blog.csdn.net/qq_45519030/article/details/141334094