温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Go语言网络编程知识点有哪些

发布时间:2021-11-10 09:04:47 来源:亿速云 阅读:155 作者:iii 栏目:开发技术

这篇文章主要介绍“Go语言网络编程知识点有哪些”,在日常操作中,相信很多人在Go语言网络编程知识点有哪些问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Go语言网络编程知识点有哪些”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

    1. Socket 编程

    在 Go 语言中编写网络程序时,我们将看不到传统的编码形式。以前我们使用 Socket 编程时,会按照如下步骤展开。

    建立 Socket:使用 socket()函数。

    绑定 Socket:使用 bind()函数。

    监听:使用 listen()函数。或者连接:使用 connect()函数。

    接受连接:使用 accept()函数。

    接收:使用 receive()函数。或者发送:使用 send()函数。
    Go 语言标准库对此过程进行了抽象和封装。无论我们期望使用什么协议建立什么形式的连接,都只需要调用 net.Dial()即可。

    1.1 Dial()函数

    Dial()函数的原型如下:

    func Dial(net, addr string) (Conn, error)

    其中 net 参数是网络协议的名字,addr 参数是IP 地址或域名,而端口号以:的形式跟随在地址或域名的后面,端口号可选。如果连接成功,返回连接对象,否则返回 error
    我们来看一下几种常见协议的调用方式。

    TCP 链接:

    conn, err := net.Dial("tcp", "192.168.1.8:3000")

    UDP链接:

    conn, err := net.Dial("udp", "192.168.1.12:975")

    ICMP链接(使用协议名称):

    conn, err := net.Dial("ip4:icmp", "www.baidu.com")

    ICMP链接(使用协议编号):

    conn, err := net.Dial("ip4:1", "10.0.0.3")

    在成功建立连接后,我们就可以进行数据的发送和接收。发送数据时,使用 connWrite()成员方法,接收数据时使用 Read()方法。

    2. HTTP 编程

    2.1 HTTP 客户端

    Go 内置的 net/http 包提供了最简洁的 HTTP 客户端实现,我们无需借助第三方网络通信库(比如 libcurl)就可以直接使用 HTTP 中用得最多的 GETPOST 方式请求数据。

    基本方法

    net/http 包的 Client 类型提供了如下几个方法,让我们可以用最简洁的方式实现HTTP 请求:

    func (c *Client) Get(url string) (r *Response, err error)
    func (c *Client) Post(url string, bodyType string, body io.Reader) (r *Response, err error)
    func (c *Client) PostForm(url string, data url.Values) (r *Response, err error)
    func (c *Client) Head(url string) (r *Response, err error)
    func (c *Client) Do(req *Request) (resp *Response, err error)

    下面概要介绍这几个方法。

    • http.Get()

    要请求一个资源,只需调用 http.Get()方法(等价于 http.DefaultClient.Get())即可,示例代码如下:

    resp, err := http.Get("http://example.com/")
    if err != nil { // 处理错误 ...
    	return
    }
    defer resp.Body.close()
    io.Copy(os.Stdout, resp.Body)

    上面这段代码请求一个网站首页,并将其网页内容打印到标准输出流中。

    • http.Post()

    要以POST 的方式发送数据,也很简单,只需调用 http.Post()方法并依次传递下面的 3 个参数即可:

    请求的目标 URL将要 POST 数据的资源类型(MIMEType)数据的比特流([]byte 形式)

    下面的示例代码演示了如何上传一张图片:

    resp, err := http.Post("http://example.com/upload", "image/jpeg", &imageDataBuf)
    if err != nil{ // 处理错误
    	return
    }
    if resp.StatusCode != http.StatusOK {// 处理错误
    	return
    }
    • http.PostForm()

    http.PostForm()方法实现了标准编码格式为 application/x-www-form-urlencoded的表单提交。下面的示例代码模拟 HTML 表单提交一篇新文章:

    resp, err := http.PostForm("http://example.com/posts", url.Values{"title": 
    {"article title"}, "content": {"article body"}})
    if err != nil{ // 处理错误
    	return
    }
    • http.Head()

    HTTP 中的 Head 请求方式表明只请求目标 URL 的头部信息,即 HTTP Header 而不返回 HTTP
    Body。Go 内置的 net/http 包同样也提供了 http.Head() 方法,该方法同 http.Get() 方法一样,
    只需传入目标 URL 一个参数即可。下面的示例代码请求一个网站首页的 HTTP Header 信息:

    resp, err := http.Head("http://baidu.com/")
    • (*http.Client).Do()

    在多数情况下,http.Get()http.PostForm() 就可以满足需求,但是如果我们发起的
    HTTP 请求需要更多的定制信息,我们希望设定一些自定义的 Http Header 字段,比如:

    • 设定自定义的"User-Agent"

    • 传递 Cookie

    此时可以使用 net/httphttp.Client对象的 Do()方法来实现

    req, err := http.NewRequest("GET", "http://baidu.com", nil) 
    // ...
    req.Header.Add("User-Agent", "Gobook Custom User-Agent") 
    // ...
    client := &http.Client{ //... } 
    resp, err := client.Do(req)

    2.2 HTTP 服务端

    2.2.1 处理 HTTP 请求

    使用 net/http 包提供的 http.ListenAndServe() 方法,可以在指定的地址进行监听,开启一个 HTTP,服务端该方法的原型如下:

    func ListenAndServe(addr string, handler Handler) error

    该方法用于在指定的 TCP 网络地址 addr 进行监听,然后调用服务端处理程序来处理传入的连接请求。该方法有两个参数:第一个参数 addr 即监听地址;第二个参数表示服务端处理程序,通常为空,这意味着服务端调用 http.DefaultServeMux 进行处理,而服务端编写的业务逻辑处理程序 http.Handle()http.HandleFunc() 默认注入 http.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))

    net/http 包还提供 http.ListenAndServeTLS() 方法,用于处理 HTTPS 连接请求:

    func ListenAndServeTLS(addr string, certFile string, keyFile string, handler Handler) error

    ListenAndServeTLS()ListenAndServe() 的行为一致,区别在于只处理 HTTPS 请求。此外,服务器上必须存在包含证书和与之匹配的私钥的相关文件,比如 certFile 对应 SSL证书文件存放路径,keyFile 对应证书私钥文件路径。如果证书是由证书颁发机构签署的,certFile 参数指定的路径必须是存放在服务器上的经由 CA认证过的 SSL 证书

    3. RPC 编程

    在 Go 中,标准库提供的 net/rpc 包实现了 RPC 协议需要的相关细节,开发者可以很方便地使用该包编写 RPC 的服务端和客户端程序,这使得用 Go 语言开发的多个进程之间的通信变得非常简单。

    net/rpc 包允许 RPC 客户端程序通过网络或是其他 I/O 连接调用一个远端对象的公开方法(必须是大写字母开头、可外部调用的)。在 RPC 服务端,可将一个对象注册为可访问的服务,之后该对象的公开方法就能够以远程的方式提供访问。一个 RPC 服务端可以注册多个不同类型的对象,但不允许注册同一类型的多个对象。

    一个对象中只有满足如下这些条件的方法,才能被 RPC 服务端设置为可供远程访问:

    • 必须是在对象外部可公开调用的方法(首字母大写);

    • 必须有两个参数,且参数的类型都必须是包外部可以访问的类型或者是 Go 内建支持的类型;

    • 第二个参数必须是一个指针;

    • 方法必须返回一个 error 类型的值。

    以上 4 个条件,可以简单地用如下一行代码表示:

    func (t *T) MethodName(argType T1, replyType *T2) error

    在上面这行代码中,类型 T、T1 和 T2 默认会使用 Go 内置的 encoding/gob 包进行编码解码。

    该方法(MethodName)的第一个参数表示由 RPC 客户端传入的参数,第二个参数表示要返回给 RPC 客户端的结果,该方法最后返回一个 error 类型的值。
    RPC 服务端可以通过调用 rpc.ServeConn 处理单个连接请求。多数情况下,通过 TCP 或是 HTTP 在某个网络地址上进行监听来创建该服务是个不错的选择。

    3.1 Go 语言中的 RPC 支持与处理

    在 Go 中,标准库提供的net/rpc包实现了RPC 协议需要的相关细节,开发者可以很方便地使用该包编写 RPC 的服务端和客户端程序,这使得用 Go 语言开发的多个进程之间的通信变得非常简单。

    net/rpc 包允许 RPC 客户端程序通过网络或是其他 I/O 连接调用一个远端对象的公开方法(必须是大写字母开头、可外部调用的)。在RPC服务端,可将一个对象注册为可访问的服务,之后该对象的公开方法就能够以远程的方式提供访问。一个RPC服务端可以注册多个不同类型的对象,但不允许注册同一类型的多个对象。

    一个对象中只有满足如下这些条件的方法,才能被RPC服务端设置为可供远程访问:

    • 必须是在对象外部可公开调用的方法(首字母大写);

    • 必须有两个参数,且参数的类型都必须是包外部可以访问的类型或者是Go内建支持的类型;

    • 第二个参数必须是一个指针;

    • 方法必须返回一个 error 类型的值。

    以上 4 个条件,可以简单地用如下一行代码表示:

    func (t *T) MethodName(argType T1, replyType *T2) error

    在上面这行代码中,类型 T、T1 和 T2 默认会使用 Go 内置的 encoding/gob 包进行编码解码。关于 encoding/gob 包的内容,稍后我们将会对其进行介绍。

    该方法(MethodName)的第一个参数表示由 RPC 客户端传入的参数,第二个参数表示要返回给 RPC 客户端的结果,该方法最后返回一个 error 类型的值。

    RPC 服务端可以通过调用 rpc.ServeConn 处理单个连接请求。多数情况下,通过 TCP 或是 HTTP 在某个网络地址上进行监听来创建该服务是个不错的选择。

    3.2 Gob 简介

    Gob 是 Go 的一个序列化数据结构的编码解码工具,在Go标准库中内置 encoding/gob包以供使用。一个数据结构使用 Gob进行序列化之后,能够用于网络传输。

    JSONXML这种基于文本描述的数据交换语言不同,Gob是二进制编码的数据流,并且 Gob 流是可以自解释的,它在保证高效率的同时,也具备完整的表达能力。

    作为针对 Go的数据结构进行编码和解码的专用序列化方法,这意味着 Gob 无法跨语言使用。在 Gonet/rpc 包中,传输数据所需要用到的编码解码器,默认就是 Gob。由于Gob 仅局限于使用 Go 语言开发的程序,这意味着我们只能用 GoRPC 实现进程间通信。

    然而,大多数时候,我们用Go编写的 RPC 服务端(或客户端),可能更希望它是通用的,与语言无关的,无论是 Python 、 Java 或其他编程语言实现的 RPC 客户端,均可与之通信。

    3.3 设计优雅的 RPC 接口

    Go 的 net/rpc 很灵活,它在数据传输前后实现了编码解码器的接口定义。这意味着,开发者可以自定义数据的传输方式以及 RPC 服务端和客户端之间的交互行为。
    RPC 提供的编码解码器接口如下:

    type ClientCodec interface {
    	WriteRequest(*Request, interface{}) error 
    	ReadResponseHeader(*Response) error
    	ReadResponseBody(interface{}) error
    	Close() error
    }
    
    type ServerCodec interface {
    	ReadRequestHeader(*Request) error 
    	ReadRequestBody(interface{}) error 
    	WriteResponse(*Response, interface{}) error
    	Close() error
    }

    接口 ClientCodec 定义了 RPC 客户端如何在一个 RPC 会话中发送请求和读取响应。客户端程序通过 WriteRequest() 方法将一个请求写入到 RPC 连接中,并通过ReadResponseHeader()ReadResponseBody() 读取服务端的响应信息。当整个过程执行完毕后,再通过 Close()方法来关闭该连接。

    接口 ServerCodec 定义了 RPC 服务端如何在一个 RPC 会话中接收请求并发送响应。服务端程序通过ReadRequestHeader()ReadRequestBody() 方法从一个 RPC 连接中读取 请求信息,然后再通过WriteResponse() 方法向该连接中的 RPC 客户端发送响应。当完成该过程后,通过 Close()方法来关闭连接。

    通过实现上述接口,我们可以自定义数据传输前后的编码解码方式,而不仅仅局限于Gob。同样,可以自定义RPC服务端和客户端的交互行为。实际上,Go 标准库提供的 net/rpc/json包,就是一套实现了 rpc.ClientCodecrpc.ServerCodec 接口的 JSON-RPC 模块。

    到此,关于“Go语言网络编程知识点有哪些”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!

    向AI问一下细节

    免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

    AI