当前位置：首页 > news >正文

go构建web服务

news 2026/5/12 18:55:19

构建最简单的HTTP服务

创建HTTP服务仅需几行代码，利用标准库net/http包实现核心功能。建立一个监听8080端口的服务，对所有请求返回"hello, world"响应。

mkdir simple-http-server cd simple-http-server go mod init simple-http-server

在main.go中写入以下代码：

packagemainimport"net/http"funcmain(){http.HandleFunc("/",func(w http.ResponseWriter,r*http.Request){w.Write([]byte("hello, world"))})http.ListenAndServe(":8080",nil)}

http.HandleFunc注册路由处理函数，http.ListenAndServe启动服务监听。通过curl测试服务：

curl localhost:8080/

图书管理API服务架构

项目采用模块化设计，分为HTTP服务器和图书存储两大模块。API遵循RESTful风格，支持图书CRUD操作，数据交互使用JSON格式。

创建项目基础结构：

mkdir bookstore cd bookstore go mod init bookstore

项目目录布局：

├── cmd/ │ └── bookstore/ │ └── main.go ├── internal/ │ └── store/ │ └── memstore.go ├── server/ │ ├── middleware/ │ │ └── middleware.go │ └── server.go └── store/ ├── factory/ │ └── factory.go └── store.go

核心模块实现

数据存储模块
通过工厂模式创建存储实例，支持多种存储后端。定义通用接口：

typeBookStoreinterface{Create(*Book)errorUpdate(*Book)errorGet(string)(*Book,error)GetAll()([]*Book,error)Delete(string)error}

内存存储实现示例：

typememStorestruct{sync.RWMutex booksmap[string]*Book}

HTTP服务器模块
封装路由注册和中间件处理：

funcNewBookStoreServer(addrstring,s store.BookStore)*BookStoreServer{srv:=&BookStoreServer{addr:addr,store:s,}router:=mux.NewRouter()router.Use(loggingMiddleware)router.HandleFunc("/book",srv.createBook).Methods("POST")router.HandleFunc("/book/{id}",srv.updateBook).Methods("PUT")returnsrv}

主程序流程
初始化存储和服务器实例，优雅处理服务启停：

funcmain(){s,err:=factory.New("mem")srv:=server.NewBookStoreServer(":8080",s)errChan:=make(chanerror)gofunc(){errChan<-srv.ListenAndServe()}()quit:=make(chanos.Signal,1)signal.Notify(quit,syscall.SIGINT,syscall.SIGTERM)select{caseerr:=<-errChan:log.Printf("Server error: %v",err)case<-quit:ctx,cancel:=context.WithTimeout(context.Background(),5*time.Second)defercancel()srv.Shutdown(ctx)}}

关键实现细节

使用gorilla/mux实现路由匹配
中间件处理日志记录和异常恢复
内存存储使用读写锁保证并发安全
响应编码统一采用JSON格式
实现优雅停机机制

示例API请求：

POST /book Content-Type: application/json {"id":"978-3-16-148410-0","name":"Go语言设计模式","authors":["张三"],"press":"人民邮电出版社"}

响应处理逻辑：

func(bs*BookStoreServer)createBook(w http.ResponseWriter,req*http.Request){varbook store.Bookiferr:=json.NewDecoder(req.Body).Decode(&book);err!=nil{http.Error(w,err.Error(),http.StatusBadRequest)return}iferr:=bs.store.Create(&book);err!=nil{http.Error(w,err.Error(),http.StatusInternalServerError)return}w.WriteHeader(http.StatusCreated)}