登录
首页 >  Golang >  Go教程

用Golang快速搭建内存CRUD接口

时间:2025-09-06 10:58:54 212浏览 收藏

**用Golang快速搭建内存数据CRUD接口:简洁教程与实例** 想快速掌握如何使用Golang构建RESTful API?本文将带你一步步使用Golang标准库 `net/http`,在内存中实现用户数据的CRUD(增删改查)接口。通过定义结构体和切片模拟数据库,并利用 `sync.Mutex` 保证并发安全,我们搭建一个支持GET、POST、PUT、DELETE方法的API。示例代码简洁易懂,适合Golang初学者和小型项目快速原型开发。请注意,该方案数据存储在内存中,重启后数据将丢失。了解如何用Golang高效处理数据操作,从本文开始!

答案:使用Golang标准库net/http创建RESTful API,通过结构体和切片在内存中实现用户数据的增删改查,配合sync.Mutex保证并发安全,支持GET、POST、PUT、DELETE方法,数据重启后丢失,适合学习和小型项目。

如何用Golang创建一个RESTful API来对内存中的数据进行增删改查

用Golang创建一个RESTful API来操作内存中的数据,可以通过标准库 net/http 实现路由和请求处理,结合结构体和切片存储数据。下面是一个完整、简洁的示例,实现对用户信息的增删改查(CRUD)。

定义数据结构和内存存储

使用一个结构体表示用户,并用切片作为内存数据库,配合互斥锁保证并发安全。

package main

import (
    "encoding/json"
    "log"
    "net/http"
    "strconv"
    "sync"
)

type User struct {
    ID   int    `json:"id"`
    Name string `json:"name"`
    Age  int    `json:"age"`
}

var (
    users  = []User{}
    nextID = 1
    mu     sync.Mutex
)

实现RESTful路由和处理函数

注册不同的HTTP方法对应处理函数,实现对用户的增删改查。

func main() {
    http.HandleFunc("/users", func(w http.ResponseWriter, r *http.Request) {
        switch r.Method {
        case "GET":
            getUsers(w, r)
        case "POST":
            createUser(w, r)
        default:
            http.Error(w, "不支持的请求方法", http.StatusMethodNotAllowed)
        }
    })

    http.HandleFunc("/users/", func(w http.ResponseWriter, r *http.Request) {
        if r.Method == "GET" {
            getUser(w, r)
        } else if r.Method == "PUT" {
            updateUser(w, r)
        } else if r.Method == "DELETE" {
            deleteUser(w, r)
        }
    })

    log.Println("服务启动在 :8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

编写CRUD处理函数

每个函数处理对应的逻辑,包括解析请求、操作数据、返回JSON。

获取所有用户

func getUsers(w http.ResponseWriter, r *http.Request) {
    mu.Lock()
    defer mu.Unlock()

    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(users)
}

创建用户

func createUser(w http.ResponseWriter, r *http.Request) {
    var user User
    if err := json.NewDecoder(r.Body).Decode(&user); err != nil {
        http.Error(w, "请求体格式错误", http.StatusBadRequest)
        return
    }

    mu.Lock()
    defer mu.Unlock()

    user.ID = nextID
    nextID++
    users = append(users, user)

    w.Header().Set("Content-Type", "application/json")
    w.WriteHeader(http.StatusCreated)
    json.NewEncoder(w).Encode(user)
}

根据ID获取单个用户

func getUser(w http.ResponseWriter, r *http.Request) {
    id, err := strconv.Atoi(r.URL.Path[len("/users/"):])
    if err != nil {
        http.Error(w, "无效的用户ID", http.StatusBadRequest)
        return
    }

    mu.Lock()
    defer mu.Unlock()

    for _, user := range users {
        if user.ID == id {
            w.Header().Set("Content-Type", "application/json")
            json.NewEncoder(w).Encode(user)
            return
        }
    }

    http.Error(w, "用户未找到", http.StatusNotFound)
}

更新用户

func updateUser(w http.ResponseWriter, r *http.Request) {
    id, err := strconv.Atoi(r.URL.Path[len("/users/"):])
    if err != nil {
        http.Error(w, "无效的用户ID", http.StatusBadRequest)
        return
    }

    var updatedUser User
    if err := json.NewDecoder(r.Body).Decode(&updatedUser); err != nil {
        http.Error(w, "请求体格式错误", http.StatusBadRequest)
        return
    }

    mu.Lock()
    defer mu.Unlock()

    for i, user := range users {
        if user.ID == id {
            updatedUser.ID = id
            users[i] = updatedUser
            w.Header().Set("Content-Type", "application/json")
            json.NewEncoder(w).Encode(updatedUser)
            return
        }
    }

    http.Error(w, "用户未找到", http.StatusNotFound)
}

删除用户

func deleteUser(w http.ResponseWriter, r *http.Request) {
    id, err := strconv.Atoi(r.URL.Path[len("/users/"):])
    if err != nil {
        http.Error(w, "无效的用户ID", http.StatusBadRequest)
        return
    }

    mu.Lock()
    defer mu.Unlock()

    for i, user := range users {
        if user.ID == id {
            users = append(users[:i], users[i+1:]...)
            w.WriteHeader(http.StatusNoContent)
            return
        }
    }

    http.Error(w, "用户未找到", http.StatusNotFound)
}

基本上就这些。这个例子使用标准库实现了完整的RESTful API,数据保存在内存中,适合学习或小型项目。注意它没有持久化,重启后数据会丢失。实际项目中可扩展为使用数据库或加入验证、日志、中间件等。结构清晰,易于理解和修改。

理论要掌握,实操不能落!以上关于《用Golang快速搭建内存CRUD接口》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注golang学习网公众号吧!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>