加 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

")
status, err := bufio.NewReader(conn).ReadString("
")
// ...

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服務端

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("
")
trimedInput := strings.Trim(input, "
")
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
"
msg += "Host: www.baidu.com
"
msg += "Connection: close
"
// msg += "Connection: keep-alive
"
msg += "

"

_, 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]))
}
}

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
}

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！