首页 > 代码库 > Go语言TCP/UDP Socket编程
Go语言TCP/UDP Socket编程
1. TCP编程
TCPClient
// TCPClient project main.go package main import ( "fmt" "net" "os" ) func main() { var buf [512]byte if len(os.Args) != 2 { fmt.Fprintf(os.Stderr, "Usage: %s host:port ", os.Args[0]) os.Exit(1) } service := os.Args[1] tcpAddr, err := net.ResolveTCPAddr("tcp4", service) checkErr(err) conn, err := net.DialTCP("tcp", nil, tcpAddr) defer conn.Close() checkErr(err) rAddr := conn.RemoteAddr() n, err := conn.Write([]byte("Hello server!")) checkErr(err) n, err = conn.Read(buf[0:]) checkErr(err) fmt.Println("Reply from server ", rAddr.String(), string(buf[0:n])) os.Exit(0) } func checkErr(err error) { if err != nil { fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) os.Exit(1) } }
TCPServer
// TCPServer project main.go package main import ( "fmt" "net" "os" ) func main() { service := ":5000" tcpAddr, err := net.ResolveTCPAddr("tcp4", service) checkErr(err) listener, err := net.ListenTCP("tcp", tcpAddr) checkErr(err) for { conn, err := listener.Accept() if err != nil { continue } go handleClient(conn) } } func checkErr(err error) { if err != nil { fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) os.Exit(1) } } func handleClient(conn net.Conn) { defer conn.Close() var buf [512]byte for { n, err := conn.Read(buf[0:]) if err != nil { return } rAddr := conn.RemoteAddr() fmt.Println("Receive from client", rAddr.String(), string(buf[0:n])) _, err2 := conn.Write([]byte("Welcome client!")) if err2 != nil { return } } }
2. UDP编程
UPDClient
// UDPClient project main.go package main import ( "fmt" "net" "os" ) func main() { var buf [512]byte if len(os.Args) != 2 { fmt.Fprintf(os.Stderr, "Usage: %s host:port ", os.Args[0]) os.Exit(1) } service := os.Args[1] udpAddr, err := net.ResolveUDPAddr("udp4", service) checkErr(err) conn, err := net.DialUDP("udp", nil, udpAddr) defer conn.Close() checkErr(err) rAddr := conn.RemoteAddr() n, err := conn.Write([]byte("Hello server!")) checkErr(err) n, err = conn.Read(buf[0:]) checkErr(err) fmt.Println("Reply from server ", rAddr.String(), string(buf[0:n])) os.Exit(0) } func checkErr(err error) { if err != nil { fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) os.Exit(1) } }
UDPServer
// UDPServer project main.go package main import ( "fmt" "net" "os" ) func main() { service := ":5000" udpAddr, err := net.ResolveUDPAddr("udp4", service) checkErr(err) conn, err := net.ListenUDP("udp", udpAddr) checkErr(err) for { handleClient(conn) } } func checkErr(err error) { if err != nil { fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) os.Exit(1) } } func handleClient(conn *net.UDPConn) { defer conn.Close() var buf [512]byte for { n, rAddr, err := conn.ReadFromUDP(buf[0:]) if err != nil { return } fmt.Println("Receive from client", rAddr.String(), string(buf[0:n])) _, err2 := conn.WriteToUDP([]byte("Welcome client!"), rAddr) if err2 != nil { return } } }
Go语言TCP/UDP Socket编程
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。