如何用Golang实现评论功能_Golang 评论功能开发实践_技术教程

首先设计合理的数据模型支持层级评论，再通过RESTful API实现增删查功能，使用Golang结构体与数据库映射，结合权限校验、防刷、过滤、分页和缓存等优化措施，构建安全可扩展的评论系统。

评论功能是大多数内容型应用的基础模块，比如博客、社交平台或电商平台。用 Golang 实现评论功能时，核心在于设计合理的数据结构、接口逻辑以及保证系统的可扩展性与安全性。下面从数据模型、API 设计、业务逻辑和常见优化点出发，介绍如何在 Golang 项目中实现一个实用的评论系统。

定义评论的数据模型

评论通常需要支持层级结构（如回复评论），因此数据表设计要能表达父子关系。

以数据库为例，使用 PostgreSQL 或 MySQL，可以定义如下字段：

ID：唯一标识
Content：评论内容
AuthorID：用户 ID
TargetType：评论目标类型（如文章、视频）
TargetID：被评论对象的 ID
ParentID：父评论 ID（为空表示顶级评论）
CreatedAt：创建时间

在 Go 结构体中可表示为：

type Comment struct {
    ID         int64     `json:"id"`
    Content    string    `json:"content"`
    AuthorID   int64     `json:"author_id"`
    TargetType string    `json:"target_type"`
    TargetID   int64     `json:"target_id"`
    ParentID   *int64    `json:"parent_id,omitempty"` // 可为空
    CreatedAt  time.Time `json:"created_at"`
}

设计 RESTful API 接口

常见的评论操作包括发布评论、获取评论列表、删除评论等。建议使用标准 HTTP 方法：

POST /comments：提交新评论
GET /comments?target_type=article&target_id=123：获取某资源下的评论树
DELETE /comments/{id}：删除自己的评论

使用 Gorilla Mux 或 Gin 框架可以快速实现路由绑定：

r := mux.NewRouter()
r.HandleFunc("/comments", CreateComment).Methods("POST")
r.HandleFunc("/comments", ListComments).Queries("target_type", "{target_type}", "target_id", "{target_id}")
r.HandleFunc("/comments/{id}", DeleteComment).Methods("DELETE")

处理评论的增删查逻辑

以创建评论为例，需校验参数、权限，并写入数据库：

func CreateComment(w http.ResponseWriter, r *http.Request) {
    var comment Comment
    if err := json.NewDecoder(r.Body).Decode(&comment); err != nil {
        http.Error(w, "invalid JSON", http.StatusBadRequest)
        return
    }

    // 简单校验
    if comment.Content == "" || comment.TargetID == 0 || comment.AuthorID == 0 {
        http.Error(w, "missing required fields", http.StatusBadRequest)
        return
    }

    // 写入数据库（假设 db 是 *sql.DB）
    query := `INSERT INTO comments (content, author_id, target_type, target_id, parent_id, created_at)
              VALUES (?, ?, ?, ?, ?, ?)`
    _, err := db.Exec(query, comment.Content, comment.AuthorID, comment.TargetType,
                      comment.TargetID, comment.ParentID, time.Now())
    if err != nil {
        http.Error(w, "server error", http.StatusInternalServerError)
        return
    }

    w.WriteHeader(http.StatusCreated)
    json.NewEncoder(w).Encode(map[string]string{"status": "created"})
}