AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Go语言学习笔记（六）net & net/http

2018-03-30 1408
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

加 Golang学习 QQ群共同学习进步成家立业工作 ^-^ 群号：96933959

net

import "net"

net包提供了可移植的网络I/O接口，包括TCP/IP、UDP、域名解析和Unix域socket。

虽然本包提供了对网络原语的访问，大部分使用者只需要Dial、Listen和Accept函数提供的基本接口；以及相关的Conn和Listener接口。crypto/tls包提供了相同的接口和类似的Dial和Listen函数。

 

Listen函数创建的服务端：

复制代码 
ln, err := net.Listen("tcp", ":8080")
if err != nil {
    // handle error
}
for {
    conn, err := ln.Accept()
    if err != nil {
        // handle error
        continue
    }
    go handleConnection(conn)
}
复制代码

Dial函数和服务端建立连接：

复制代码 
conn, err := net.Dial("tcp", "google.com:80")
if err != nil {
    // handle error
}
fmt.Fprintf(conn, "GET / HTTP/1.0\r\n\r\n")
status, err := bufio.NewReader(conn).ReadString('\n')
// ...
复制代码

 

TCPConn

TCPConn代表一个TCP网络连接，实现了Conn接口。

Conn接口

Conn接口代表通用的面向流的网络连接。多个线程可能会同时调用同一个Conn的方法。

复制代码 
type Conn interface {
    // Read从连接中读取数据
    // Read方法可能会在超过某个固定时间限制后超时返回错误，该错误的Timeout()方法返回真
    Read(b []byte) (n int, err error)
    // Write从连接中写入数据
    // Write方法可能会在超过某个固定时间限制后超时返回错误，该错误的Timeout()方法返回真
    Write(b []byte) (n int, err error)
    // Close方法关闭该连接
    // 并会导致任何阻塞中的Read或Write方法不再阻塞并返回错误
    Close() error
    // 返回本地网络地址
    LocalAddr() Addr
    // 返回远端网络地址
    RemoteAddr() Addr
    // 设定该连接的读写deadline，等价于同时调用SetReadDeadline和SetWriteDeadline
    // deadline是一个绝对时间，超过该时间后I/O操作就会直接因超时失败返回而不会阻塞
    // deadline对之后的所有I/O操作都起效，而不仅仅是下一次的读或写操作
    // 参数t为零值表示不设置期限
    SetDeadline(t time.Time) error
    // 设定该连接的读操作deadline，参数t为零值表示不设置期限
    SetReadDeadline(t time.Time) error
    // 设定该连接的写操作deadline，参数t为零值表示不设置期限
    // 即使写入超时，返回值n也可能>0，说明成功写入了部分数据
    SetWriteDeadline(t time.Time) error
}
复制代码

 

栗子一(tcp)

tcp服务端 

复制代码 
package main

import (
    "fmt"
    "net"
)

func process(conn net.Conn) {
    defer conn.Close()
    for {
        buf := make([]byte, 512)
        n, err := conn.Read(buf)
        if err != nil {
            fmt.Println("read err:", err)
            return
        }
        fmt.Println("read:", string(buf[:n]))
    }
}

func main() {
    fmt.Println("server start...")
    listen, err := net.Listen("tcp", "0.0.0.0:8000")
    if err != nil {
        fmt.Println("listen failed, err:", err)
        return
    }
    for {
        conn, err := listen.Accept()
        if err != nil {
            fmt.Println("accept failed, err:", err)
            continue
        }
        go process(conn)
    }
}
复制代码

 

tcp客户端

复制代码 
package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "strings"
)

func main() {
    conn, err := net.Dial("tcp", "localhost:8000")
    if err != nil {
        fmt.Println("err dialing:", err.Error())
        return
    }
    defer conn.Close()
    inputReader := bufio.NewReader(os.Stdin)
    for {
        input, _ := inputReader.ReadString('\n')
        trimedInput := strings.Trim(input, "\r\n")
        if trimedInput == "Q" {
            return
        }
        _, err := conn.Write([]byte(trimedInput))
        if err != nil {
            fmt.Println("err conn.write:", err)
            return
        }
    }
}
复制代码

 

栗子二（http）

封装一个http连接，请求百度

复制代码 
package main

import (
    "fmt"
    "io"
    "net"
)

func main() {
    conn, err := net.Dial("tcp", "www.baidu.com:80")
    if err != nil {
        fmt.Println("err dialing:", err.Error())
        return
    }
    defer conn.Close()

    msg := "GET / HTTP/1.1\r\n"
    msg += "Host: www.baidu.com\r\n"
    msg += "Connection: close\r\n"
    // msg += "Connection: keep-alive\r\n"
    msg += "\r\n\r\n"

    _, err = io.WriteString(conn, msg)
    if err != nil {
        fmt.Println("io write string failed, err:", err)
        return
    }
    buf := make([]byte, 4096)
    for {
        count, err := conn.Read(buf)
        if err != nil {
            break
        }
        fmt.Println(string(buf[:count]))
    }
}
复制代码

 

net/http

import "net/http"

http包提供了HTTP客户端和服务端的实现。

Get、Head、Post和PostForm函数发出HTTP/ HTTPS请求。

resp, err := http.Get("http://example.com/")
...
resp, err := http.Post("http://example.com/upload", "image/jpeg", &buf)
...
resp, err := http.PostForm("http://example.com/form",
    url.Values{"key": {"Value"}, "id": {"123"}})

程序在使用完回复后必须关闭回复的主体。

复制代码 
resp, err := http.Get("http://example.com/")
if err != nil {
    // handle error
}
defer resp.Body.Close()
body, err := ioutil.ReadAll(resp.Body)
// ...
复制代码

要管理HTTP客户端的头域、重定向策略和其他设置，创建一个Client：

复制代码 
client := &http.Client{
    CheckRedirect: redirectPolicyFunc,
}
resp, err := client.Get("http://example.com")
// ...
req, err := http.NewRequest("GET", "http://example.com", nil)
// ...
req.Header.Add("If-None-Match", `W/"wyzzy"`)
resp, err := client.Do(req)
// ...
复制代码

要管理代理、TLS配置、keep-alive、压缩和其他设置，创建一个Transport：

tr := &http.Transport{
    TLSClientConfig:    &tls.Config{RootCAs: pool},
    DisableCompression: true,
}
client := &http.Client{Transport: tr}
resp, err := client.Get("https://example.com")

Client和Transport类型都可以安全的被多个go程同时使用。出于效率考虑，应该一次建立、尽量重用。

ListenAndServe使用指定的监听地址和处理器启动一个HTTP服务端。处理器参数通常是nil，这表示采用包变量DefaultServeMux作为处理器。Handle和HandleFunc函数可以向DefaultServeMux添加处理器。

http.Handle("/foo", fooHandler)
http.HandleFunc("/bar", func(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "Hello, %q", html.EscapeString(r.URL.Path))
})
log.Fatal(http.ListenAndServe(":8080", nil))

要管理服务端的行为，可以创建一个自定义的Server：

复制代码 
s := &http.Server{
    Addr:           ":8080",
    Handler:        myHandler,
    ReadTimeout:    10 * time.Second,
    WriteTimeout:   10 * time.Second,
    MaxHeaderBytes: 1 << 20,
}
log.Fatal(s.ListenAndServe())
复制代码

 

栗子server

复制代码 
import (
    "fmt"
    "net/http"
)

func Hello(w http.ResponseWriter, r *http.Request) {
    fmt.Println("Hello World.")
    fmt.Fprintf(w, "Hello World.\n")
}

func main() {
    http.HandleFunc("/", Hello)
    err := http.ListenAndServe("0.0.0.0:6000", nil)
    if err != nil {
        fmt.Println("http listen failed.")
    }
}
复制代码

 

栗子client

复制代码 
import (
    "fmt"
    "io/ioutil"
    "net/http"
)

func main() {
    res, err := http.Get("http://www.baidu.com")
    if err != nil {
        fmt.Println("Get error:", err)
        return
    }

    data, err := ioutil.ReadAll(res.Body)
    if err != nil {
        fmt.Println("Get data error:", err)
        return
    }

    fmt.Println(string(data))
}
复制代码

 

栗子head

复制代码 
import (
    "fmt"
    "net/http"
    "time"
)

var url = []string{
    "http://www.baidu.com",
    "http://www.google.com",
    "http://pan.263.net",
}

func main() {
    for _, v := range url {
        http.DefaultClient.Timeout = time.Second * 2
        resp, err := http.Head(v)
        if err != nil {
            fmt.Printf("head %s failed, err: %v\n", v, err)
            continue
        }
        fmt.Printf("head %s succ, status: %v\n", v, resp.Status)
    }
}
复制代码

 

栗子（form） 

复制代码 
import (
    "fmt"
    "io"
    "log"
    "net/http"
)

const form = `
<html>
    <body>
        <form action="#" method="post" name="bar">
            <input type="text" name="in"/>
            <input type="text" name="in"/>
            <input type="submit" value="Submit"/>
        </form>
    </body>
</html>
`

func SimpleServer(w http.ResponseWriter, request *http.Request) {
    io.WriteString(w, "Hello World.")
}

func FormServer(w http.ResponseWriter, request *http.Request) {
    w.Header().Set("Content-Type", "text/html")
    switch request.Method {
    case "GET":
        io.WriteString(w, form)
    case "POST":
        request.ParseForm()
        io.WriteString(w, request.Form["in"][1])
        io.WriteString(w, "\n")
        io.WriteString(w, request.FormValue("in"))
    }
}

func logPanics(handle http.HandlerFunc) http.HandlerFunc {
    return func(writer http.ResponseWriter, request *http.Request) {
        defer func() {
            if x := recover(); x != nil {
                log.Printf("[%v] caught panic: %v", request.RemoteAddr, x)
            }
        }()
        handle(writer, request)
    }
}

func main() {
    http.HandleFunc("/test1", SimpleServer)
    http.HandleFunc("/test2", logPanics(FormServer))
    err := http.ListenAndServe("0.0.0.0:6000", nil)
    if err != nil {
        fmt.Println("http listen failed.")
    }
}
复制代码

 

栗子（template）

复制代码 
package main

import (
    "fmt"
    "html/template"
    "net/http"
)

type Person struct {
    Title string
    Name  string
    Age   int
}

func SimpleServer(w http.ResponseWriter, request *http.Request) {
    indexFailPath := "./index.html"
    t, err := template.ParseFiles(indexFailPath)
    if err != nil {
        fmt.Println("parse file err:", err)
        return
    }
    p := Person{Name: "Nick", Age: 18, Title: "Good."}
    if err = t.Execute(w, p); err != nil {
        fmt.Println("There was an error:", err.Error())
        return
    }
}

func main() {
    http.HandleFunc("/test1", SimpleServer)
    err := http.ListenAndServe("0.0.0.0:9000", nil)
    if err != nil {
        fmt.Println("http listen failed.")
    }
}
复制代码
复制代码 
<html>
    <head>
        <title>
            {{.Title}}
        </title>
    </head>
    <body>
        <p>{{.Name}}</p>
        {{if gt .Age 18}}
            <p>MAN: {{.Name}}</p>
        {{else}}
            <p>Kid: {{.Name}}</p>
        {{end}}
    </body>
</html>
复制代码

 

更多用法

  • not 非
{{if not .condition}} 
{{end}}

  • and 与
{{if and .condition1 .condition2}} 
{{end}}

  • or 或
{{if or .condition1 .condition2}} 
{{end}}

  • eq 等于
{{if eq .var1 .var2}} 
{{end}}

  • ne 不等于
{{if ne .var1 .var2}} 
{{end}}

  • lt 小于 (less than)
{{if lt .var1 .var2}} 
{{end}}

  • le 小于等于
{{if le .var1 .var2}} 
{{end}}

  • gt 大于
{{if gt .var1 .var2}} 
{{end}}

  • ge 大于等于
{{if ge .var1 .var2}} 
{{end}}
  • range 循环 {{range.}} {{end }}

 

Appendix

大端字节序的实现

复制代码 
    data, err := json.Marshal("hello world")
    if err != nil {
        return
    }

    var buf [4]byte
    packLen := uint32(len(data))
    fmt.Println("packlen:", packLen)

    // 前4个字节表示data大小
    binary.BigEndian.PutUint32(buf[0:4], packLen)

    n, err := conn.Write(buf[:])
    if err != nil || n != 4 {
        fmt.Println("write data  failed")
        return
    }

    _, err = conn.Write([]byte(data))
    if err != nil {
        return
    }
复制代码

 

Http  状态码

复制代码 
const (
    StatusContinue           = 100
    StatusSwitchingProtocols = 101
    StatusOK                   = 200
    StatusCreated              = 201
    StatusAccepted             = 202
    StatusNonAuthoritativeInfo = 203
    StatusNoContent            = 204
    StatusResetContent         = 205
    StatusPartialContent       = 206
    StatusMultipleChoices   = 300
    StatusMovedPermanently  = 301
    StatusFound             = 302
    StatusSeeOther          = 303
    StatusNotModified       = 304
    StatusUseProxy          = 305
    StatusTemporaryRedirect = 307
    StatusBadRequest                   = 400
    StatusUnauthorized                 = 401
    StatusPaymentRequired              = 402
    StatusForbidden                    = 403
    StatusNotFound                     = 404
    StatusMethodNotAllowed             = 405
    StatusNotAcceptable                = 406
    StatusProxyAuthRequired            = 407
    StatusRequestTimeout               = 408
    StatusConflict                     = 409
    StatusGone                         = 410
    StatusLengthRequired               = 411
    StatusPreconditionFailed           = 412
    StatusRequestEntityTooLarge        = 413
    StatusRequestURITooLong            = 414
    StatusUnsupportedMediaType         = 415
    StatusRequestedRangeNotSatisfiable = 416
    StatusExpectationFailed            = 417
    StatusTeapot                       = 418
    StatusInternalServerError     = 500
    StatusNotImplemented          = 501
    StatusBadGateway              = 502
    StatusServiceUnavailable      = 503
    StatusGatewayTimeout          = 504
    StatusHTTPVersionNotSupported = 505
)
复制代码

 

文章标签：
Go
网络协议
移动开发
Unix
域名解析
安全
关键词：
Go语言
Go语言http
Go Http
语言HTTP
语言.NET
nothingfinal
目录
相关文章
vohelon
|
16天前
|
网络协议 安全 Go
Go语言进行网络编程可以通过**使用TCP/IP协议栈、并发模型、HTTP协议等**方式
【10月更文挑战第28天】Go语言进行网络编程可以通过**使用TCP/IP协议栈、并发模型、HTTP协议等**方式
vohelon
44 13
龙大吉
|
29天前
|
JSON C# 开发者
C#语言新特性深度剖析：提升你的.NET开发效率
【10月更文挑战第15天】C#语言凭借其强大的功能和易用性深受开发者喜爱。随着.NET平台的演进，C#不断引入新特性，如C# 7.0的模式匹配和C# 8.0的异步流，显著提升了开发效率和代码可维护性。本文将深入探讨这些新特性，助力开发者在.NET开发中更高效地利用它们。
龙大吉
34 1
龙大吉
|
4月前
|
人工智能 物联网 开发工具
.NET技术：多元语言、丰富库与跨平台能力引领软件开发新纪元。
`【7月更文挑战第4天】.NET技术：多元语言、丰富库与跨平台能力引领软件开发新纪元。从企业应用、云服务到游戏开发，其角色日益凸显。随着微软的持续创新与社区合作，未来.NET将在物联网、AI等领域拓宽应用，开发者应把握趋势，共创未来。`
龙大吉
42 0
杀死一只知更鸟debug
|
2月前
|
Go
Go语言的条件控制语句及循环语句的学习笔记
本文是Go语言的条件控制语句和循环语句的学习笔记，涵盖了if语句、if-else语句、if嵌套语句、switch语句、select语句以及for循环和相关循环控制语句的使用方法。
杀死一只知更鸟debug
25 0
Go语言的条件控制语句及循环语句的学习笔记
杀死一只知更鸟debug
|
2月前
|
存储 Go
Go: struct 结构体类型和指针【学习笔记记录】
本文是Go语言中struct结构体类型和指针的学习笔记，包括结构体的定义、成员访问、使用匿名字段，以及指针变量的声明使用、指针数组定义使用和函数传参修改值的方法。
杀死一只知更鸟debug
50 0
土木林森
|
3月前
|
JSON C# 开发者
💡探索C#语言进化论：揭秘.NET开发效率飙升的秘密武器💼
【8月更文挑战第28天】C#语言凭借其强大的功能与易用性深受开发者喜爱。伴随.NET平台演进，C#持续引入新特性，如C# 7.0的模式匹配，让处理复杂数据结构更直观简洁；C# 8.0的异步流则使异步编程更灵活高效，无需一次性加载全部数据至内存。通过示例展示了模式匹配简化JSON解析及异步流实现文件逐行读取的应用。此外，C# 8.0还提供了默认接口成员和可空引用类型等特性，进一步提高.NET开发效率与代码可维护性。随着C#的发展，未来的.NET开发将更加高效便捷。
土木林森
61 1
rbvb2ms5saimy
|
2月前
|
人工智能 算法 搜索推荐
Go学习笔记-代码调
近年来，人工智能技术飞速发展，Cody作为由Sourcegraph开发的一款AI驱动编码助手，应运而生。它不仅提供代码预测与补全，还能深度理解代码上下文，为开发者提供准确建议，提升编码效率和质量。Cody能识别潜在错误并提出修复建议，缩短调试时间，同时进行智能代码审查，帮助优化代码结构和风格。未来，随着AI技术进步，Cody将不断学习优化，成为开发者不可或缺的伙伴，推动编程领域的创新与发展。
rbvb2ms5saimy
33 0
路边两盏灯
|
3月前
|
JavaScript 前端开发 Java
【Azure 环境】各种语言版本或命令，发送HTTP/HTTPS的请求合集
【Azure 环境】各种语言版本或命令，发送HTTP/HTTPS的请求合集
路边两盏灯
36 0
软件求生
|
4月前
|
缓存 程序员 开发者
HTTP状态码大全：如何读懂服务器的语言？
大家好，我是小米，今天我们来聊聊HTTP协议中的GET和POST请求。它们在数据传输方式、安全性和应用场景上有不同特点。本文将详细解析它们的区别和特点，帮助你更好地理解和运用这两种请求方式。让我们一起学习吧！
软件求生
70 1
爱发白日梦的后端
|
3月前
|
网络协议 Go
go的net/http有哪些值得关注的细节？
go的net/http有哪些值得关注的细节？
爱发白日梦的后端
25 0

热门文章

最新文章

  • 1
    如何申请阿里云免费SSL证书（可用于https网站）并下载下来
  • 2
    7.7. HTTP Auth
  • 3
    谷歌Chrome封杀赛门铁克：废止所有HTTPS凭证
  • 4
    HTTPS部署笔记
  • 5
    https httpclient 请求不绕过 证书
  • 6
    什么是https加密协议？
  • 7
    网站为什么要装https数字证书
  • 8
    Java发送Http请求（HttpClient）
  • 9
    阿里云虚拟主机HTTPS（HTTP+SSL）加密开通了
  • 10
    HTTP协议GET和POST请求的区别
  • 1
    7天玩转 Golang 标准库之 http/net
    61
  • 2
    LabVIEW加载.NET程序集
    89
  • 3
    LabVIEW中使用.NET方法时出现错误1316
    106
  • 4
    LabVIEW中加载.NET 2.0,3.0和3.5程序集
    144
  • 5
    .NET Compact Framework下的GPS NMEA data数据分析（二）转
    42
  • 6
    ASP.NET AJAX使用方法概述（三）
    51
  • 7
    Asp.net 2.0专题之一：MasterPage（2）
    40
  • 8
    使用PyTorch实现L1, L2和Elastic Net正则化
    89
  • 9
    C#/ASP.NET应用程序配置文件app.config/web.config的增、删、改操作
    70
  • 10
    Asp.net 2.0专题之一：MasterPage(2)
    38

    • 相关课程

    更多
  • Go语言核心编程 - 数据结构和算法
  • Go语言核心编程 - 基础语法、数组、切片、Map
  • Go语言核心编程 - 面向对象、文件、单元测试、反射、TCP编程
  • Java Web开发-Web应用、Tomcat、HTTP请求与响应
  • 云安全基础课- HTTP协议基础
  • Go语言完全自学手册图文教程

    • 相关电子书

    更多
  • gohbase ：HBase go客户端
  • CDN助力企业网站进入HTTPS时代
  • Go构建日请求千亿级微服务实践

    • 相关实验场景

    更多
  • 通过轻量消息队列（原MNS）主题HTTP订阅+ARMS实现自定义数据多渠道告警
  • 通过HTTPS加速网关快速部署网站加密
    • 下一篇
    阿里云OSS设置跨域访问