TODO：Golang UDP連接簡單測試慎用Deadline
UDP 是User Datagram Protocol的簡稱舷蒲， 中文名是用戶數(shù)據(jù)報協(xié)議，是OSI（Open System Interconnection友多，開放式系統(tǒng)互聯(lián)） 參考模型中一種無連接的傳輸層協(xié)議牲平，提供面向事務(wù)的簡單不可靠信息傳送服務(wù)，IETF RFC 768是UDP的正式規(guī)范域滥。UDP在IP報文的協(xié)議號是17纵柿。在網(wǎng)絡(luò)中它與TCP協(xié)議一樣用于處理數(shù)據(jù)包，是一種無連接的協(xié)議骗绕。在OSI模型中藐窄，在第四層——傳輸層，處于IP協(xié)議的上一層酬土。UDP有不提供數(shù)據(jù)包分組荆忍、組裝和不能對數(shù)據(jù)包進(jìn)行排序的缺點(diǎn)，也就是說撤缴，當(dāng)報文發(fā)送之后刹枉，是無法得知其是否安全完整到達(dá)的。
1.Golang UDP服務(wù)
package main
import (
“fmt”
“net”
)
func sendResponse(conn *net.UDPConn, addr *net.UDPAddr) {
_, err := conn.WriteToUDP([]byte(“From server: Hello I got your mesage “), addr)
if err != nil {
fmt.Printf(“Couldn’t send response %v”, err)
}
}
func main() {
p := make([]byte, 2048)
addr := net.UDPAddr{
Port: 12345,
IP: net.ParseIP(“127.0.0.1”),
}
ser, err := net.ListenUDP(“udp”, &addr)
if err != nil {
fmt.Printf(“Some error %vn”, err)
return
}
for {
_, ? ? remoteaddr, err := ser.ReadFromUDP(p)
fmt.Printf(“Read a message from %v %s n”, remoteaddr, p)
if err != nil {
fmt.Printf(“Some error %v”, err)
continue
}
go sendResponse(ser, remoteaddr)
}
}
2.Golang UDP 客戶端
package main
import (
“bufio”
“fmt”
“net”
“os”
“time”
)
func main() {
addr, err := net.ResolveUDPAddr(“udp”, “:12345”)
if err != nil {
fmt.Println(“net.ResolveUDPAddr fail.”, err)
os.Exit(1)
}
socket, err := net.DialUDP(“udp”, nil, addr)
if err != nil {
fmt.Println(“net.DialUDP fail.”, err)
os.Exit(1)
}
t := time.Now()
socket.SetDeadline(t.Add(time.Duration(5 * time.Second)))
// socket.SetWriteDeadline(t.Add(time.Duration(5 * time.Second)))
// socket.SetReadDeadline(t.Add(time.Duration(5 * time.Second)))
defer socket.Close()
r := bufio.NewReader(os.Stdin)
for {
switch line, ok := r.ReadString(‘n’); true {
case ok != nil:
fmt.Printf(“bye bye!n”)
return
default:
_, err := socket.Write([]byte(line))
if err != nil {
fmt.Println(“error send data,err:”, err)
return
}
data := make([]byte, 1024)
_, remoteAddr, err := socket.ReadFromUDP(data)
if err != nil {
fmt.Println(“error recv data,err:”, err)
return
}
fmt.Printf(“from %s:%sn”, remoteAddr.String(), string(data))
}
}
}
3.可以把代表拷貝的本地運(yùn)行測試屈呕，Golang的設(shè)置方法有三個：SetDeadline微宝，SetWriteDeadline，SetReadDeadline虎眨，設(shè)置了Deadline是指定時間戳為超時點(diǎn)蟋软，操作指定時間戳連接就會超時镶摘，再次發(fā)送包，接受包就會超時會提示i/o timeout
error send data,err: write udp 127.0.0.1:51608->127.0.0.1:12345: i/o timeout
error recv data,err: read udp 127.0.0.1:51608->127.0.0.1:12345: i/o timeout
所以要保持心跳在線就需要不斷刷新Deadline的時間戳岳守。本文僅供參考凄敢，如果有相應(yīng)場景，會使用到湿痢，^_^涝缝。
wxgzh:ludong86
