Golang网络请求
2018-02-12 本文已影响127人
牛牛技术
说明
本文主要分为服务器和客户端
服务器
服务器监听http请求类型主要常用到以下几种方式:
- 解析get的form表单
- 解析post的方式解析json对象
- 解析以表单的方式解析postform数据
解析get的form表单
func GetService(w http.ResponseWriter, r *http.Request) {
//解析get的form表单
r.ParseForm()
fmt.Println(r.Form["name"])
fmt.Println(r.Form["sex"])
fmt.Println(strings.Join(r.Form["name"], "-"))
fmt.Println(strings.Join(r.Form["sex"], "-"))
for k, v := range r.Form {
fmt.Println(k, "=>", v, strings.Join(v, "-"))
}
//将数据回传到客户端
fmt.Fprint(w, "It works")
}
解析post的方式解析json对象
func PostService(w http.ResponseWriter, r *http.Request){
//读取body
body , err := ioutil.ReadAll(r.Body)
if err != nil {
fmt.Println("read fail")
return
}
//解析body成string
bodyStr := string(body)
fmt.Println("bodyStr", bodyStr)
//反序列化,解析body到struct
var user User
err1 := json.Unmarshal(body, &user)
if err1 != nil{
fmt.Println("unmarshal fail")
return
}
fmt.Println("user", user.Name, user.Sex)
//返回数据
fmt.Fprint(w, "Post is works")
}
解析以表单的方式提交postform数据
func PostFormService(w http.ResponseWriter, r *http.Request) {
//读取body表单
r.ParseForm()
fmt.Println(r.Form["name"])
fmt.Println(r.Form["sex"])
fmt.Println(strings.Join(r.Form["name"], "-"))
fmt.Println(strings.Join(r.Form["sex"], "-"))
for k, v := range r.Form {
fmt.Println(k, "=>", v, strings.Join(v, "-"))
}
//返回数据
fmt.Fprint(w, "Post is works")
}
服务端用到的结构体
type User struct {
Name string `json:"name"`
Sex string `json:"sex"`
}
开启服务器的方法:
http.HandleFunc("/get", GetService)
http.HandleFunc("/post", PostService)
http.HandleFunc("/postform", PostFormService)
//监听端口号
if err := http.ListenAndServe("127.0.0.1:8888", nil); err != nil {
fmt.Println("service start err")
}
客户端
对应的客户端请求方式有:
- 发起Get请求
- 发起Post请求
- 发起PostForm请求
发起Get请求
func GetTest() {
//构造url
u, err := url.Parse("http://localhost:8888/get?")
if err != nil {
fmt.Println("url parse fail")
return
}
q := u.Query()
q.Set("name", "wnw")
q.Set("sex", "wowam")
u.RawQuery = q.Encode()
//发起get请求
resp, err1 := http.Get(u.String())
if err1 != nil || resp.StatusCode != http.StatusOK{
fmt.Println("get fail:", err1)
return
}
defer resp.Body.Close()
//读取响应体
body, err2 := ioutil.ReadAll(resp.Body)
if err2 != nil {
fmt.Println("read body fail")
return
}
fmt.Println(string(body))
//解析数据
}
发起Post请求
func PostTest() {
u := "http://localhost:8888/post?"
user := MyUser{"小小王","女"}
//序列化对象
body, err := json.Marshal(user)
if err != nil {
fmt.Println("marshal fail")
return
}
resp, err1 := http.Post(u, "application/x-www-form-urlencoded", strings.NewReader(string(body)))
if err1 != nil {
fmt.Println("post fail")
return
}
//解析响应的数据
defer resp.Body.Close()
b, err2 := ioutil.ReadAll(resp.Body)
if err2 != nil {
fmt.Println("read body fail")
return
}
fmt.Println(string(b))
}
发起PostForm请求
func PostFormTest() {
//构造参数
u, err := url.Parse("http://localhost:8888/postform?")
if err != nil {
fmt.Println("parse is fail")
return
}
q := u.Query()
q.Set("name", "大大王")
q.Set("sex", "男")
//发起post表单请求
resp, err1 := http.PostForm(u.String(), q)
if err1 != nil {
fmt.Println("post fail")
return
}
//解析响应
defer resp.Body.Close()
body, err2 := ioutil.ReadAll(resp.Body)
if err2 != nil{
fmt.Println("body fail")
return
}
fmt.Println(string(body))
}