✨✨ 欢迎大家来到景天科技苑✨✨

🎈🎈 养成好习惯，先赞后看哦~🎈🎈

🏆 作者简介：景天科技苑

🏆《头衔》：大厂架构师，华为云开发者社区专家博主，阿里云开发者社区专家博主，CSDN全栈领域优质创作者，掘金优秀博主，51CTO博客专家等。

🏆《博客》：Python全栈，Golang开发，PyQt5和Tkinter桌面开发，小程序开发，人工智能，js逆向，App逆向，网络系统安全，数据分析，Django，fastapi，flask等框架，云原生K8S，linux，shell脚本等实操经验，网站搭建，数据库等分享。

所属的专栏：Go语言开发零基础到高阶实战

景天的主页：景天科技苑

文章目录

Go语言网络编程一、Go语言网络编程概述二、TCP编程1. 创建TCP服务器2. 创建TCP客户端

三、UDP编程1. 创建UDP服务器2. 创建UDP客户端

四、高级用法1. HTTP服务器2. HTTP客户端

五、WebSocket六、TLS/SSL加密七、总结

Go语言网络编程

Go语言作为一种简洁而强大的编程语言，在网络编程方面表现尤为出色。其内置的net包提供了丰富的网络I/O基础设施，支持TCP、UDP协议，以及DNS解析等功能。

TCP提供可靠的、面向连接的通信，适用于需要确保数据传输完整性的场景。而UDP提供无连接的快速数据传输，适用于实时性要求较高但对数据完整性要求不高的场景。

Go语言的并发模型基于轻量级的goroutines和channels。每个网络请求都可以在自己的goroutine中处理，实现高效的并发。Channels用于在goroutines之间安全地传递数据。

Go语言的net包提供了网络I/O的基础设施，包括TCP/UDP协议，以及DNS解析。这些核心组件使得Go语言在网络编程方面非常强大。

本文将结合实际案例，详细介绍Go语言在网络编程中的详细用法。

一、Go语言网络编程概述

TCP和UDP

TCP（传输控制协议）：提供可靠的、面向连接的通信。TCP协议在发送数据之前会先建立连接，确保数据的完整性和顺序性。UDP（用户数据报协议）：提供无连接的快速数据传输。UDP协议在发送数据之前不会建立连接，因此传输速度较快，但不保证数据的完整性和顺序性。

并发

Go语言的并发模型是基于轻量级的goroutines实现的。每个网络请求都可以在自己的goroutine中处理，从而实现高效的并发。

Channels

Channels是Go语言中用于在goroutines之间安全地传递数据的机制。通过channels，我们可以实现goroutines之间的同步和通信。

核心组件

net包：提供了网络I/O的基础设施，包括TCP/UDP协议，以及DNS解析等功能。

二、TCP编程

TCP编程涉及创建TCP服务器和TCP客户端，并通过TCP连接进行数据的发送和接收。

1. 创建TCP服务器

一个基本的TCP服务器需要完成以下步骤：

监听端口：使用net.Listen函数监听指定的TCP端口。接受连接：使用Accept方法接受来自客户端的连接请求。处理连接：在一个新的goroutine中处理每个连接，以实现并发处理。

以下是一个简单的TCP服务器示例：

<code>// server.go

package main

import (

"bufio"

"fmt"

"net"

)

func main() { -- -->

listener, err := net.Listen("tcp", "localhost:8888")

if err != nil {

fmt.Println("开启服务端错误:", err)

return

}

defer listener.Close()

for {

conn, err := listener.Accept()

if err != nil {

fmt.Println("接收错误:", err)

continue // 改为continue，可以处理下一个连接

}

go handleConnection(conn)

}

}

func handleConnection(conn net.Conn) {

defer conn.Close()

// 读取客户端数据

message, err := bufio.NewReader(conn).ReadString('\n')

if err != nil {

fmt.Println("读取错误:", err)

return

}

fmt.Println("Message Received:", message)

// 回发数据

response := "收到你的消息了:" + message

conn.Write([]byte(response))

}

2. 创建TCP客户端

一个基本的TCP客户端需要完成以下步骤：

建立连接：使用net.Dial函数连接到服务器。发送和接收数据：通过连接发送数据，并接收服务器的响应。关闭连接：在完成数据传输后关闭连接。

以下是一个简单的TCP客户端示例：

// client.go

package main

import (

"bufio"

"fmt"

"net"

)

func main() {

conn, err := net.Dial("tcp", "localhost:8888")

if err != nil {

fmt.Println("连接错误:", err)

return

}

defer conn.Close()

// 发送数据

message := "玩游戏\n"

_, err = conn.Write([]byte(message))

if err != nil {

fmt.Println("发送数据错误:", err)

return

}

fmt.Println("发送数据:", message)

// 读取响应

response, err := bufio.NewReader(conn).ReadString('\n')

if err != nil {

fmt.Println("读取响应错误:", err)

return

}

fmt.Println("收到响应:", response)

}

运行服务器和客户端程序，客户端将发送消息“玩游戏”到服务器，服务器将接收该消息并回发“收到你的消息了:玩游戏”。

三、UDP编程

UDP编程与TCP编程类似，但不需要建立连接，因此代码相对更简单。

1. 创建UDP服务器

一个基本的UDP服务器需要完成以下步骤：

监听端口：使用net.ListenUDP函数监听指定的UDP端口。接受数据：使用ReadFromUDP方法接收来自客户端的数据。发送响应：使用WriteToUDP方法发送响应到客户端。

以下是一个简单的UDP服务器示例：

<code>// udp_server.go

package main

import (

"fmt"

"net"

"os"

)

func main() { -- -->

// 解析UDP地址

raddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8088")

if err != nil {

fmt.Println("解析地址错误:", err)

os.Exit(1)

}

// 监听UDP端口

conn, err := net.ListenUDP("udp", raddr)

if err != nil {

fmt.Println("监听端口错误:", err)

os.Exit(1)

}

defer conn.Close()

fmt.Println("UDP服务器启动，监听端口 8088")

buffer := make([]byte, 1024)

for {

// 读取数据

n, udpaddr, err := conn.ReadFromUDP(buffer)

if err != nil {

fmt.Println("读取数据错误:", err)

continue

}

fmt.Printf("Received %d bytes from %s: %s\n", n, udpaddr, string(buffer[:n]))

// 发送回复

response := []byte("收到你的消息了!")

_, err = conn.WriteToUDP(response, udpaddr)

if err != nil {

fmt.Println("发送回复错误:", err)

}

}

}

在这个例子中，我们首先通过net.ResolveUDPAddr函数解析UDP地址，然后通过net.ListenUDP函数监听指定端口。服务器在一个无限循环中读取客户端发送的数据，并将其打印到控制台。然后，服务器将一条回复消息发送回客户端。

2. 创建UDP客户端

一个基本的UDP客户端需要完成以下步骤：

建立连接：使用net.ResolveUDPAddr和net.DialUDP函数连接到服务器。发送数据：使用Write方法发送数据到服务器。接收响应：使用ReadFromUDP方法接收服务器的响应。

以下是一个简单的UDP客户端示例：

// udp_client.go

package main

import (

"fmt"

"net"

"os"

)

func main() {

// 解析UDP地址

raddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8088")

if err != nil {

fmt.Println("解析地址错误:", err)

os.Exit(1)

}

// 建立连接

conn, err := net.DialUDP("udp", nil, raddr)

if err != nil {

fmt.Println("连接错误:", err)

os.Exit(1)

}

defer conn.Close()

// 发送数据

// 客户端发送用conn.Write(message)

message := []byte("Hello, UDP Server!")

_, err = conn.Write(message)

if err != nil {

fmt.Println("发送数据错误:", err)

os.Exit(1)

}

fmt.Println("发送数据:", string(message))

// 读取响应

buffer := make([]byte, 1024)

n, _, err := conn.ReadFromUDP(buffer)

if err != nil {

fmt.Println("读取响应错误:", err)

os.Exit(1)

}

fmt.Println("收到响应:", string(buffer[:n]))

}

在这个例子中，我们首先通过net.ResolveUDPAddr函数解析UDP地址，然后通过net.DialUDP函数建立与服务器的连接。客户端发送一条消息给服务器，并读取服务器的回复。

四、高级用法

除了基本的TCP和UDP编程外，Go语言还提供了许多高级的网络编程功能，如HTTP服务器、WebSocket、TLS/SSL加密等。

1. HTTP服务器

Go语言内置的net/http包提供了简单的HTTP服务器实现。以下是一个基本的HTTP服务器示例：

// http_server.go

package main

import (

"fmt"

"net/http"

)

// 定义发送接收数据函数

func helloHandler(w http.ResponseWriter, r *http.Request) {

fmt.Fprintf(w, "Hello, World!\n")

//也可以写数据响应给客户端

// 给浏览器响应数据，这里响应的时字符串，标签不生效

w.Write([]byte("<h1>感谢大家来到景天科技苑!</h1>"))

}

func main() {

// 访问这个url就会触发 helloHandler 函数 （Request） ResponseWriter

http.HandleFunc("/", helloHandler)

fmt.Println("Starting server at :8080")

if err := http.ListenAndServe(":8080", nil); err != nil {

fmt.Println("Error starting server:", err)

}

}

2. HTTP客户端

除了HTTP服务器，Go语言也提供了强大的HTTP客户端功能。以下是一个基本的HTTP客户端示例：

// http_client.go

package main

import (

"fmt"

"io/ioutil"

"net/http"

)

func main() {

resp, err := http.Get("http://localhost:8080")

if err != nil {

fmt.Println("Error making GET request:", err)

return

}

defer resp.Body.Close()

body, err := ioutil.ReadAll(resp.Body)

if err != nil {

fmt.Println("Error reading response body:", err)

return

}

fmt.Println("Response:", string(body))

}

在这个例子中，我们创建了一个HTTP GET请求到<code>http://localhost:8080，并读取了响应体。

五、WebSocket

WebSocket是一种在单个TCP连接上进行全双工通讯的协议。Go语言中有多个第三方库支持WebSocket，其中最流行的是gorilla/websocket。

以下是一个使用gorilla/websocket库的WebSocket服务器和客户端示例：

WebSocket服务器：

// websocket_server.go

package main

import (

"github.com/gorilla/websocket"

"log"

"net/http"

)

var upgrader = websocket.Upgrader{ -- -->

ReadBufferSize: 1024,

WriteBufferSize: 1024,

}

func handler(w http.ResponseWriter, r *http.Request) {

ws, err := upgrader.Upgrade(w, r, nil)

if err != nil {

log.Println("Error upgrading connection:", err)

return

}

defer ws.Close()

for {

// 读取消息

messageType, p, err := ws.ReadMessage()

if err != nil {

log.Println("Error reading message:", err)

return

}

log.Printf("Received message: %s\n", p)

// 发送消息

err = ws.WriteMessage(messageType, p)

if err != nil {

log.Println("Error writing message:", err)

return

}

}

}

func main() {

http.HandleFunc("/ws", handler)

log.Println("Starting server at :8081")

if err := http.ListenAndServe(":8081", nil); err != nil {

log.Println("Error starting server:", err)

}

}

WebSocket客户端：

// websocket_client.go

package main

import (

"github.com/gorilla/websocket"

"log"

"net/url"

"time"

)

func main() {

interrupt := make(chan struct{ })

u := url.URL{ Scheme: "ws", Host: "localhost:8081", Path: "/ws"}

log.Printf("Connecting to %s", u.String())

conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)

if err != nil {

log.Fatal("Dial error: ", err)

return

}

defer conn.Close()

done := make(chan struct{ })

go func() {

defer close(done)

for {

select {

case <-done:

return

case <-interrupt:

err := conn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))

if err != nil {

log.Println("Write close error: ", err)

return

}

select {

case <-done:

case <-time.After(time.Second):

}

return

default:

messageType, p, err := conn.ReadMessage()

if err != nil {

log.Println("Read error: ", err)

return

}

log.Printf("Received: %s", p)

if err := conn.WriteMessage(messageType, p); err != nil {

log.Println("Write error: ", err)

return

}

}

}

}()

time.Sleep(10 * time.Second)

close(interrupt)

<-done

}

在这个例子中，我们创建了一个简单的WebSocket服务器和客户端。服务器接收来自客户端的消息，并将其回发给客户端。客户端连接到服务器，发送消息，并接收服务器的回发消息。

六、TLS/SSL加密

在网络编程中，安全性是至关重要的。TLS/SSL是一种用于在两个通信应用程序之间提供保密性和数据完整性的协议。Go语言的crypto/tls包提供了对TLS/SSL的支持。

以下是一个使用TLS/SSL的HTTP服务器示例：

// tls_server.go

package main

import (

"crypto/tls"

"crypto/x509"

"fmt"

"io/ioutil"

"log"

"net/http"

)

func helloHandler(w http.ResponseWriter, r *http.Request) {

fmt.Fprintf(w, "Hello, Secure World!")

}

func main() {

cert, err := tls.LoadX509KeyPair("cert.pem", "key.pem")

if err != nil {

log.Fatalf("failed to load key pair: %s", err)

}

caCert, err := ioutil.ReadFile("ca.pem")

if err != nil {

log.Fatalf("failed to read ca certificate: %s", err)

}

caCertPool := x509.NewCertPool()

caCertPool.AppendCertsFromPEM(caCert)

tlsConfig := &tls.Config{

Certificates: []tls.Certificate{ cert},

RootCAs: caCertPool,

ClientCAs: caCertPool,

ClientAuth: tls.RequireAndVerifyClientCert,

}

tlsConfig.BuildNameToCertificate()

server := &http.Server{

Addr: ":8443",

Handler: http.HandlerFunc(helloHandler),

TLSConfig: tlsConfig,

}

log.Println("Starting server at :8443")

if err := server.ListenAndServeTLS("", ""); err != nil {

log.Fatalf("failed to start server: %s", err)

}

}

在这个例子中，我们创建了一个使用TLS/SSL的HTTP服务器。我们需要提供服务器证书（cert.pem）和私钥（key.pem），以及CA证书（ca.pem）来验证客户端证书。然后，我们配置TLS/SSL参数，并启动HTTPS服务器。

请注意，这只是一个简单的示例，实际生产环境中需要更复杂的证书管理和安全性配置。

七、总结

Go语言在网络编程方面提供了强大的支持，包括TCP、UDP、HTTP、WebSocket和TLS/SSL等协议。通过内置的net包和第三方库，我们可以轻松地创建各种类型的网络应用程序。本文介绍了Go语言网络编程的基本用法和高级功能，希望能帮助你更好地理解和使用Go语言进行网络编程。