以下是一些Go语言网络编程的实例:
TCP服务器
代码示例:
package main import ( "fmt" "io" "net" ) func handleConnection(conn net.Conn) { defer conn.Close() for { buf := make([]byte, 1024) n, err := conn.Read(buf) if err != nil { return } fmt.Printf("Received: %s", string(buf[:n])) conn.Write([]byte("Message received.")) } } func main() { listener, err := net.Listen("tcp", "localhost:8080") if err != nil { fmt.Println("Error listening:", err) return } defer listener.Close() for { conn, err := listener.Accept() if err != nil { continue } go handleConnection(conn) } }
- 说明:这个示例创建了一个TCP服务器,监听
localhost:8080
端口。每当有新的客户端连接时,它都会启动一个新的goroutine来处理该连接。服务器读取客户端发送的数据,并将其打印到控制台,然后向客户端发送确认消息[^1^]。
TCP客户端
代码示例:
package main import ( "fmt" "net" ) func main() { conn, err := net.Dial("tcp", "localhost:8080") if err != nil { fmt.Println("Error dialing:", err) return } defer conn.Close() conn.Write([]byte("Hello, server!")) buf := make([]byte, 1024) n, err := conn.Read(buf) if err != nil { fmt.Println("Error reading:", err) return } fmt.Printf("Received: %s", string(buf[:n])) }
- 说明:这个示例是一个TCP客户端,它连接到上面提到的TCP服务器,并发送一条消息。然后,它等待服务器的响应,并将其打印到控制台[^1^]。
HTTP服务器
代码示例:
package main import ( "fmt" "net/http" ) func helloHandler(w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hello, World!") } func main() { http.HandleFunc("/", helloHandler) http.ListenAndServe(":8080", nil) }
- 说明:这个示例创建了一个简单的HTTP服务器,监听
localhost:8080
端口。当HTTP请求到达服务器时,它会调用helloHandler
函数来处理请求,并向客户端发送“Hello, World!”作为响应[^5^]。
并发HTTP服务器
代码示例:
package main import ( "fmt" "log" "net/http" ) func helloHandler(w http.ResponseWriter, r *http.Request) { fmt.Fprintf(w, "Hello, %q", r.URL.Path[1:]) } func main() { http.HandleFunc("/", helloHandler) log.Fatal(http.ListenAndServe(":8090", nil)) }
- 说明:这个示例展示了如何创建一个可以处理并发请求的HTTP服务器。它使用了Go语言的并发特性(goroutine),使得每个HTTP请求都在自己的goroutine中处理,从而提高了服务器的性能和响应速度[^5^]。
WebSocket服务器
代码示例:
package main import ( "fmt" "log" "net/http" "github.com/gorilla/websocket" ) var upgrader = websocket.Upgrader{ } // use default options func echo(w http.ResponseWriter, r *http.Request) { c, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Print("upgrade:", err) return } defer c.Close() for { mt, message, err := c.ReadMessage() if err != nil { log.Println("read:", err) break } log.Printf("recv: %s", message) err = c.WriteMessage(mt, message) if err != nil { log.Println("write:", err) break } } } func main() { http.HandleFunc("/echo", echo) log.Fatal(http.ListenAndServe("localhost:8080", nil)) }
- 说明:这个示例使用
gorilla/websocket
库创建了一个简单的WebSocket服务器。当客户端连接到服务器时,它会将接收到的消息回显给客户端[^1^]。
综上所述,这些实例涵盖了Go语言网络编程中的多种常见场景,包括TCP通信、HTTP服务、并发处理以及WebSocket通信。通过学习和实践这些实例,你可以更好地理解Go语言的网络编程模型,并掌握构建高效、可靠网络应用的技能。