开发一个简单的留言回复系统，核心在于接收用户提交的留言、保存数据并支持对他人留言进行回复。Golang凭借简洁的标准库和高效的并发模型，非常适合用来快速搭建这类小型服务。下面我们从项目结构出发，逐步实现一个可运行的demo。
一、项目准备与路由设计
这个系统不需要引入庞大的Web框架，使用标准库net/http处理请求，再配合gorilla_mux做路径变量解析即可。首先初始化模块并安装路由包：
go mod init message_reply go get github.com/gorilla/mux
路由层负责区分留言列表、发布留言和回复留言三类接口。使用mux.Router可以清晰地将URL与处理函数绑定，避免手写字符串匹配带来的维护成本。同时，所有写操作必须考虑并发安全，这是后续数据层设计的重点。
1.1 基础路由代码
下面是一段路由注册示例，展示了如何用子路由隔离API版本，并将不同HTTP方法映射到对应函数：
package main
import (
"github.com/gorilla/mux"
"net/http"
)
func main() {
r := mux.NewRouter()
api := r.PathPrefix("/api/v1").Subrouter()
api.HandleFunc("/messages", listMessages).Methods("GET")
api.HandleFunc("/messages", createMessage).Methods("POST")
api.HandleFunc("/messages/{id}/replies", createReply).Methods("POST")
http.ListenAndServe(":8080", r)
}
这段代码把业务接口集中在/api/v1下，便于以后扩展。注意mux的{id}占位符让我们在回复时可以直接拿到目标留言编号，而不用自己解析查询参数。
二、数据结构与并发安全存储
留言和回复可以用嵌套结构体表达。一个常见误区是直接使用全局map并在多个goroutine中同时写入，这会触发Golang的并发写检测并导致程序崩溃。正确做法是用sync.Mutex保护map。
2.1 定义结构与存储对象
我们定义Message包含内容和回复列表，Store持有map与锁。这样每次修改都通过方法加锁，调用方无需关心同步细节。
package main
import (
"sync"
"time"
)
type Reply struct {
Content string
CreatedAt time.Time
}
type Message struct {
ID int
Content string
CreatedAt time.Time
Replies []Reply
}
type Store struct {
mu sync.Mutex
items map[int]*Message
nextID int
}
func NewStore() *Store {
return &Store{
items: make(map[int]*Message),
nextID: 1,
}
}
func (s *Store) AddMessage(content string) int {
s.mu.Lock()
defer s.mu.Unlock()
id := s.nextID
s.items[id] = &Message{
ID: id,
Content: content,
CreatedAt: time.Now(),
}
s.nextID++
return id
}
func (s *Store) AddReply(msgID int, content string) bool {
s.mu.Lock()
defer s.mu.Unlock()
m, ok := s.items[msgID]
if !ok {
return false
}
m.Replies = append(m.Replies, Reply{
Content: content,
CreatedAt: time.Now(),
})
return true
}
func (s *Store) List() []*Message {
s.mu.Lock()
defer s.mu.Unlock()
result := make([]*Message, 0, len(s.items))
for _, m := range s.items {
result = append(result, m)
}
return result
}
上述实现中，AddReply在锁内检查留言是否存在，避免返回成功却没写入的情况。这种封装让上层HTTP处理更简洁，也隔离了并发风险。
2.2 为什么不能用裸map
如果去掉sync.Mutex，在压测下同时发起留言和回复请求，Golang运行时会抛出fatal error: concurrent map writes。因为map本身不是线程安全的，多个goroutine同时扩容或赋值会破坏内部哈希结构。用锁虽有一定性能损耗，但对这种低频留言系统完全够用。
三、HTTP处理函数与JSON交互
前后端通过JSON交换数据最直观。Golang标准库的encoding/json可以方便地序列化结构体，配合json.NewDecoder解析请求体。
3.1 实现三个接口
下面补全main中的处理函数，使用前面定义的Store实例。注意设置响应头Content-Type为application/json，否则浏览器可能误判。
package main
import (
"encoding/json"
"net/http"
)
var store = NewStore()
func listMessages(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(store.List())
}
func createMessage(w http.ResponseWriter, r *http.Request) {
var body struct {
Content string `json:"content"`
}
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
http.Error(w, "bad request", http.StatusBadRequest)
return
}
id := store.AddMessage(body.Content)
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(map[string]int{"id": id})
}
func createReply(w http.ResponseWriter, r *http.Request) {
vars := mux.Vars(r)
var body struct {
Content string `json:"content"`
}
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
http.Error(w, "bad request", http.StatusBadRequest)
return
}
msgID := 0
fmt.Sscanf(vars["id"], "%d", &msgID)
if !store.AddReply(msgID, body.Content) {
http.Error(w, "message not found", http.StatusNotFound)
return
}
w.WriteHeader(http.StatusCreated)
}
这里createReply用mux.Vars取路径中的ID并转为整数。若留言不存在则返回404，符合REST风格。整个流程没有依赖数据库，重启即清空，适合演示与内部工具。
3.2 用curl验证功能
启动服务后，可以用命令行快速测试：先发留言，再对返回ID回复，最后列出来确认。这种闭环验证比写前端页更快定位后端问题。
curl -X POST http://127.0.0.1:8080/api/v1/messages -d '{"content":"你好"}'
curl -X POST http://127.0.0.1:8080/api/v1/messages/1/replies -d '{"content":"回复你"}'
curl http://127.0.0.1:8080/api/v1/messages
观察第三次请求，应能看见留言下带了回复内容。若想持久化，只需把Store换成操作SQLite或BoltDB的实现，上层接口不变。
四、小结与扩展思路
通过这个小系统，我们实践了Golang的路由控制、并发安全容器和JSON接口开发。它没有多余抽象，却覆盖了Web服务最常见的增、查、关联写场景。
后续可加入用户身份、分页查询或用channel解耦存储。也可以把Store接口抽象出来，方便单元测试时替换为内存假实现。掌握这些基础后，再去看大型框架的源码就不会无从下手。
Golang留言回复系统gorilla_mux修改时间：2026-08-01 22:48:39