超文本传输协议（英文：HyperText Transfer Protocol，缩写：HTTP）是一种用于分布式、协作式和超媒体信息系统的应用层协议。
就是常用的浏览器和服务器通信协议. 将tcp进行封装后的一种应用层协议.
HTTP协议定义Web客户端如何从Web服务器请求Web页面，以及服务器如何把Web页面传送给客户端。HTTP协议采用了请求/响应模型。客户端向服务器发送一个请求报文，请求报文包含请求的方法、URL、协议版本、请求头部和请求数据。服务器以一个状态行作为响应，响应的内容包括协议的版本、成功或者错误代码、服务器信息、响应头部和响应数据。
以下是 HTTP 请求/响应的步骤：
例如：在浏览器地址栏键入URL，按下回车之后会经历以下流程：
HTTP/1.1协议中共定义了八种方法来以不同方式操作指定的资源：
GET
向指定的资源发出“显示”请求。使用GET方法应该只用在读取数据，而不应当被用于产生“副作用”的操作中，例如在Web Application中。其中一个原因是GET可能会被网络蜘蛛等随意访问。
HEAD
与GET方法一样，都是向服务器发出指定资源的请求。只不过服务器将不传回资源的本文部分。它的好处在于，使用这个方法可以在不必传输全部内容的情况下，就可以获取其中“关于该资源的信息”（元信息或称元数据）。
POST
向指定资源提交数据，请求服务器进行处理（例如提交表单或者上传文件）。数据被包含在请求本文中。这个请求可能会创建新的资源或修改现有资源，或二者皆有。
PUT
向指定资源位置上传其最新内容。
DELETE
请求服务器删除Request-URI所标识的资源。
TRACE
回显服务器收到的请求，主要用于测试或诊断。
OPTIONS
这个方法可使服务器传回该资源所支持的所有HTTP请求方法。用’*'来代替资源名称，向Web服务器发送OPTIONS请求，可以测试服务器功能是否正常运作。
CONNECT
HTTP/1.1协议中预留给能够将连接改为管道方式的代理服务器。通常用于SSL加密服务器的链接（经由非加密的HTTP代理服务器）。
路由是处理url和函数关系的程序,配置一系列的url访问规则,提供对应url访问的模板.在go的原生net/http包中,浏览器发起http请求(post,get等请求),到服务器中,服务器根据发送的url查找对应的出来程序,此查找程序为路程转发程序.
所有HTTP响应的第一行都是状态行，依次是当前HTTP版本号，3位数字组成的状态代码，以及描述状态的短语，彼此由空格分隔。
状态代码的第一个数字代表当前响应的类型：
有些是已经定义好的,比如200, 404等常见状态码,开发者也可以自行定义.
package main
import (
"fmt"
"net/http"
)
func IndexHandler(w http.ResponseWriter, r *http.Request) {
fmt.Fprintln(w, "hello world")
}
func main() {
http.HandleFunc("/", IndexHandler)
http.ListenAndServe("127.0.0.0:8000", nil)
}
123456789101112131415上述代码中分析请求格式如下图所示:
可以看到上图,请求头,响应头,请求方法为GET, 响应状态码为200.
Content-Type: 传输的媒体类型.
Content-Length: HTTP消息长度.
等字段内容庞大,后续专门开一贴介绍.
一个简单的登录页面,用户登录时填写的账号密码从数据库中读出,并做对比
index.html: 主页显示内容
index
欢迎访问golang搭建的HttpServer
12345678910login.html: 登录页面
用户登录
12345678910111213141516success.html: 登录成功页面
首页
欢迎访问golang搭建的HttpServer
12345678910main.go: 服务器主程序
package main
import (
"database/sql"
"encoding/json"
"fmt"
_ "github.com/go-sql-driver/mysql"
"html/template"
"io/ioutil"
"net/http"
"strconv"
)
//数据库操作可以面向接口来设计，我这里只是简单写一下哈
var Db *sql.DB
func init() { //初始化db实例
var err error
dsn := "root:000000@tcp(127.0.0.1:3306)/test"
Db, err = sql.Open("mysql", dsn)
if err != nil {
fmt.Printf("init db instance falied:%v
", err)
return
}
}
type User struct {
Id int `db:"id",json:"id"`
Username string `db:"username",json:"username"` //sql.NullString
Password string `db:"password",json:"password"` //sql.NullString
Age int `db:"age",json:"age"` //sql.NullInt64
Sex string `db:"sex",json:"sex"` //sql.NullString
Phone string `db:"phone",json:"phone"` //sql.NullString
}
/**
*添加用户
*/
func addUser(user *User) int64 {
sqlStr := "INSERT INTO user_tb(username,password,age,sex,phone) VALUES(?,?,?,?,?)"
stmt, err := Db.Prepare(sqlStr)
if err != nil {
fmt.Printf("Prepare insert sql failed:%v
", err)
return -1
}
defer closeStmt(stmt)
result, err := stmt.Exec(user.Username, user.Password, user.Age, user.Sex, user.Phone)
if err != nil {
fmt.Printf("exec sql failed:%v
", err)
return -1
}
lastId, err := result.LastInsertId()
if err != nil {
fmt.Printf("get lastId failed:%v
", err)
return -1
}
return lastId
}
//更新用户
func updateUser(u User) int64 {
updateSql := "UPDATE user_tb SET username=?,password=?,age=?,sex=?,phone=? where id=?"
stmt, err := Db.Prepare(updateSql)
if err != nil {
fmt.Printf("Prepare update sql failed:%v
", err)
return -1
}
defer closeStmt(stmt)
result, err := stmt.Exec(u.Username, u.Password, u.Age, u.Sex, u.Phone, u.Id)
if err != nil {
fmt.Printf("exec sql failed:%v
", err)
return -1
}
affectedId, err := result.RowsAffected()
if err != nil {
fmt.Printf("get affected id failed:%v
", err)
return -1
}
return affectedId
}
//根据id删除用户对象
func delUser(id int) int64 {
delSql := "DELETE FROM user_tb WHERE id=?"
result, err := Db.Exec(delSql, id)
if err != nil {
fmt.Printf("exec del failed:%v
", err)
return -1
}
affectedId, err := result.RowsAffected()
if err != nil {
fmt.Printf("get affected id failed:%v
", err)
return -1
}
return affectedId
}
//根据用户名查询用户对象
func findUserByUsername(username string) (err error, user User) {
sqlStr := "SELECT * FROM user_tb WHERE username=?"
row := Db.QueryRow(sqlStr, username)
err = row.Scan(&user.Id, &user.Username, &user.Password, &user.Age, &user.Sex, &user.Phone)
if err != nil {
return
}
return
}
//根据ID查询用户对象
func findUserById(id int) (err error, user User) {
sqlStr := "SELECT * FROM user_tb WHERE id=?"
stmt, err := Db.Prepare(sqlStr)
defer closeStmt(stmt)
row := stmt.QueryRow(id)
err = row.Scan(&user.Id, &user.Username, &user.Password, &user.Age, &user.Sex, &user.Phone)
if err != nil {
return
}
return
}
//根据用户名和密码查询用户对象
func findUserByUsernameAndPassword(username string, password string) (err error, user User) {
sqlStr := "SELECT * FROM user_tb WHERE username=? AND password=?"
row := Db.QueryRow(sqlStr, username, password)
err = row.Scan(&user.Id, &user.Username, &user.Password, &user.Age, &user.Sex, &user.Phone)
if err != nil {
return
}
return
}
//获取所有用户对象集
func findAllUsers() (err error, users []*User) {
sqlStr := "SELECT * FROM user_tb"
rows, err := Db.Query(sqlStr)
if err != nil {
fmt.Print("mysql is nul!
")
return
}
defer closeRow(rows) //延迟调用
for rows.Next() {
var u User
err = rows.Scan(&u.Id, &u.Username, &u.Password, &u.Age, &u.Sex, &u.Phone)
fmt.Println(u.Id)
fmt.Println(u.Username)
//err = rows.Scan(&u.Id, &u.Username, &u.Password)
if err != nil {
fmt.Printf("err is nil
")
return
}
users = append(users, &u)
}
return
}
//关闭stmt连接
func closeStmt(stmt *sql.Stmt) {
if stmt != nil {
fmt.Printf("close stmt connection
")
stmt.Close()
}
}
//关闭row连接
func closeRow(rows *sql.Rows) {
if rows != nil {
fmt.Printf("close rows connection
")
rows.Close()
}
}
//处理http请求方法
var contentPath = "./static/"
func indexPage(w http.ResponseWriter, r *http.Request) {
t, err := template.ParseFiles(contentPath + "index.html")
if err != nil {
fmt.Fprintf(w, "load index.html failed:%v
", err)
return
}
t.Execute(w, nil)
}
func login(w http.ResponseWriter, r *http.Request) {
t, err := template.ParseFiles(contentPath + "login.html")
if err != nil {
fmt.Fprintf(w, "load login.html failed:%v
", err)
return
}
t.Execute(w, nil)
}
//处理登录请求
func loginForm(w http.ResponseWriter, r *http.Request) {
method := r.Method
if method == "POST" {
r.ParseForm()
//获取表单的中数据
usernmae := r.FormValue("username")
password := r.FormValue("password")
err, user := findUserByUsernameAndPassword(usernmae, password)
if err != nil {
fmt.Printf("find user failed:%v
", err)
t, err := template.ParseFiles(contentPath + "login.html")
if err != nil {
fmt.Fprintf(w, "load login.html failed:%v", err)
return
}
t.Execute(w, "用户名或密码不正确,请确认")
return
}
t, err := template.ParseFiles(contentPath + "success.html")
if err != nil {
fmt.Fprintf(w, "load success.html failed:%v", err)
return
}
t.Execute(w, user)
}
}
//处理更新请求
func update(w http.ResponseWriter, r *http.Request) {
r.Header.Add("Content-Type", "application/json")
boday, err := ioutil.ReadAll(r.Body)
if err != nil {
fmt.Fprintf(w, "read body failed:%v", err)
return
}
var user User
err = json.Unmarshal(boday,&user)
if err != nil {
fmt.Fprintf(w,"{"error":"%v"}",err)
return
}
fmt.Printf("%#v
", user)
rowId := updateUser(user)
fmt.Fprintf(w, "{"status":"ok","affectedId":"%d"}",rowId)
}
//处理添加用户请求
func add(w http.ResponseWriter, r *http.Request) {
r.Header.Add("Content-Type", "application/json")
boday, err := ioutil.ReadAll(r.Body) //读取body消息体
if err != nil {
fmt.Fprintf(w, "read body failed:%v", err)
return
}
var user User
err = json.Unmarshal(boday,&user) //反序列化成user对象
if err != nil {
fmt.Fprintf(w,"{"error":"%v"}",err)
return
}
fmt.Printf("%#v
", user)
rowId := addUser(&user)
fmt.Fprintf(w, "{"status":"ok","rowId":"%d"}",rowId)
}
//处理查询请求
func findById(w http.ResponseWriter, r *http.Request){
idStr := r.URL.Query().Get("id")
id,err := strconv.Atoi(idStr)
if err != nil {
fmt.Fprintf(w,"parse id string to int failed:%v",err)
return
}
err,user := findUserById(id)
if err != nil {
fmt.Fprintf(w,"get user by %d failed:%v",id,err)
return
}
data,err := json.Marshal(&user) //将user struct序列化成字节数组
if err != nil {
fmt.Fprintf(w,"parse user data struct failed:%v",err)
return
}
fmt.Fprintf(w,string(data))
}
//处理查询请求
func findAll(w http.ResponseWriter, r *http.Request){
err,user := findAllUsers()
if err != nil {
fmt.Fprintf(w,"get user failed:%v",err)
return
}
data,err := json.Marshal(&user) //将user struct序列化成字节数组
if err != nil {
fmt.Fprintf(w,"parse user data struct failed:%v",err)
return
}
fmt.Fprintf(w,string(data))
}
func main() {
//添加路由
http.HandleFunc("/", indexPage)
http.HandleFunc("/index", indexPage)
http.HandleFunc("/login", login)
http.HandleFunc("/loginForm", loginForm)
http.HandleFunc("/add", add)
http.HandleFunc("/update", update)
http.HandleFunc("/findById",findById)
http.HandleFunc("/findAll",findAll)
//启动服务端口监听
err := http.ListenAndServe(":9090", nil)
if err != nil {
fmt.Printf("Listen 9090 port failed:%v
", err)
return
}
}页面更新：2024-04-13
本站资料均由网友自行发布提供，仅用于学习交流。如有版权问题，请与我联系，QQ：4156828
© CopyRight 2020-2024 All Rights Reserved. Powered By 71396.com 闽ICP备11008920号-4
闽公网安备35020302034903号
