在Go中实现一个简单的TCP/UDP服务器涉及到创建并监听网络连接以及接收/发送数据。以下是如何在Go中实现TCP和UDP服务器的简单示例。
### TCP服务器
```go
package main
import (
"fmt"
"io"
"net"
"os"
)
func main() {
// 监听指定端口
listener, err := net.Listen("tcp", ":8080")
if err != nil {
fmt.Println("Error listening:", err.Error())
os.Exit(1)
}
defer listener.Close() // 确保在main函数结束时关闭监听器
fmt.Println("Server is listening on port 8080...")
for {
// 接受连接请求
conn, err := listener.Accept()
if err != nil {
fmt.Println("Error accepting: ", err.Error())
os.Exit(1)
}
// 处理每个连接，这里我们只是简单地打印出接收到的数据并回显回去
go handleRequest(conn) // 使用goroutine处理每个连接，以避免阻塞主线程
}
}
func handleRequest(conn net.Conn) {
defer conn.Close() // 确保在函数结束时关闭连接
// 读取数据直到遇到换行符或错误发生
buf := make([]byte, 1024) // 定义一个缓冲区来存储接收到的数据
for {
n, err := conn.Read(buf) // 读取数据，直到有错误或读满n个字节（取决于TCP包大小）
if err != nil {
if err != io.EOF { // 如果不是EOF则表示读取错误了，则关闭连接并返回错误信息给客户端
fmt.Println("Error reading:", err.Error())
} else { // 如果是EOF则表示客户端关闭了连接，正常退出循环即可。
}
} else { // 否则，将读取到的数据回显给客户端并打印出来。注意：此处不应在真实生产环境中回显给客户端。否则可能会引发安全问题。此处仅为演示。
fmt.Printf("Received from client: %s\n", string(buf[:n])) // 注意不要在实际的服务器上回显输入数据，因为它可能会引起安全问题。
}
}
}
```
上述代码实现了一个基本的TCP服务器，在指定端口（例如`8080`）上监听来自客户端的连接请求。它通过一个goroutine为每个连接的客户端启动一个`handleRequest`函数，然后这个函数处理数据并读取它（请注意安全上的考量，上述示例简单且不是安全的实现）。请记住在实际的生产环境中使用TLS（加密的）和安全实践。在接收到客户端数据时，可以决定如何处理它，这里简单演示了打印出来。这仅是开始，根据实际需求可能需要做更多的事情。同时记得正确处理任何错误情况，例如读取/写入时发生错误等。在处理完每个连接后，应确保关闭连接以释放资源。使用`defer`语句是一个好习惯，可以确保即使在处理过程中发生错误也能正确关闭连接。使用goroutine是为了避免每个连接的阻塞其他连接的处理。 当然，这个例子是阻塞的，因为每次只处理一个连接。在实际应用中，你可能需要使用更复杂的并发控制机制来处理多个并发连接。 此外，请确保在生产环境中不要将任何接收到的数据回显给客户端，这可能引发安全问题。 如果你需要更复杂的逻辑或功能（如TLS支持、认证等），则需要更详细的代码实现。但是上面的例子是一个好的起点。 为了简化起见，本例中不涉及异常情况处理、多线程并发处理以及加密传输等安全特性。对于更复杂的应用场景，需要更加细致的代码实现和异常处理逻辑。请记住安全总是第一位的！ 接下来是UDP服务器的示例： ### UDP服务器 ```go package main import ( "fmt" "net" "os" ) func main() { // 监听UDP地址和端口 addr, err := net.ResolveUDPAddr("udp", ":8080") if err != nil { fmt.Println("Error resolving address:", err.Error()) os.Exit(1) } // 在给定地址和端口上打开一个UDP包 conn, err := net.ListenUDP("udp", addr) if err != nil { fmt.Println("Error listening on address:", err.Error()) os.Exit(1) } defer conn.