本文档旨在引导读者使用 Go 语言构建一个基本的 TCP 客户端-服务器应用。我们将介绍服务器端监听端口、客户端连接服务器，以及简单的数据交互。通过本文，读者将了解 Go 语言网络编程的基础知识，并能搭建起一个简单的客户端-服务器通信框架。
服务器端实现
服务器端的主要职责是监听指定的端口，接受客户端的连接请求，并处理客户端发送的数据。以下是一个简单的 TCP 服务器端示例：
package main
import (
"fmt"
"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()
fmt.Println("Server listening on :8080")
for {
conn, err := listener.Accept()
if err != nil {
fmt.Println("Error accepting: ", err.Error())
continue
}
fmt.Println("Client connected")
go handleConnection(conn) // 使用 goroutine 处理每个连接
}
}
func handleConnection(conn net.Conn) {
defer conn.Close()
buffer := make([]byte, 1024)
for {
n, err := conn.Read(buffer)
if err != nil {
fmt.Println("Error reading:", err.Error())
return
}
fmt.Printf("Received from client: %s\n", string(buffer[:n]))
_, err = conn.Write([]byte("Server received: " + string(buffer[:n])))
if err != nil {
fmt.Println("Error writing:", err.Error())
return
}
}
}代码解释：
- net.Listen("tcp", ":8080"): 创建一个 TCP 监听器，监听 8080 端口。
- listener.Accept(): 接受客户端的连接请求，返回一个 net.Conn 对象，代表一个连接。
- go handleConnection(conn): 使用 goroutine 并发处理每个连接。
- handleConnection(conn): 读取客户端发送的数据，并向客户端发送响应。
注意事项：
- 服务器端应该使用 goroutine 并发处理每个连接，避免阻塞主线程。
- defer conn.Close() 确保在连接处理完成后关闭连接，释放资源。
- 错误处理至关重要，应该检查每个可能出错的地方，并进行适当的处理。
客户端实现
客户端的主要职责是连接服务器，发送数据，并接收服务器的响应。以下是一个简单的 TCP 客户端示例：
瑞宝通JAVA版B2B电子商务系统
下载
瑞宝通B2B系统使用当前流行的JAVA语言开发，以MySQL为数据库，采用B/S J2EE架构。融入了模型化、模板、缓存、AJAX、SEO等前沿技术。与同类产品相比，系统功能更加强大、使用更加简单、运行更加稳 定、安全性更强，效率更高，用户体验更好。系统开源发布，便于二次开发、功能整合、个性修改。 由于使用了JAVA开发语言，无论是在Linux/Unix，还是在Windows服务器上，均能良好运行
package main
import (
"bufio"
"fmt"
"net"
"os"
"strings"
)
func main() {
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
fmt.Println("Error connecting:", err.Error())
os.Exit(1)
}
defer conn.Close()
fmt.Println("Connected to server")
reader := bufio.NewReader(os.Stdin)
for {
fmt.Print("Enter text: ")
line, _ := reader.ReadString('\n')
line = strings.TrimRight(line, "\r\n")
_, err := conn.Write([]byte(line + "\n"))
if err != nil {
fmt.Println("Error writing:", err.Error())
break
}
buffer := make([]byte, 1024)
n, err := conn.Read(buffer)
if err != nil {
fmt.Println("Error reading:", err.Error())
break
}
fmt.Printf("Received from server: %s\n", string(buffer[:n]))
}
}代码解释：
- net.Dial("tcp", "localhost:8080"): 连接到 localhost:8080 的 TCP 服务器。
- bufio.NewReader(os.Stdin): 创建一个从标准输入读取数据的 reader。
- conn.Write([]byte(line + "\n")): 向服务器发送数据。
- conn.Read(buffer): 接收服务器的响应。
注意事项：
- 客户端也需要进行错误处理，确保程序的健壮性。
- 在循环中读取用户输入并发送数据，直到发生错误或用户主动退出。
- strings.TrimRight(line, "\r\n") 去除用户输入字符串末尾的回车换行符，避免干扰数据传输。
运行示例
- 首先编译并运行服务器端代码。
- 然后编译并运行客户端代码。
- 在客户端的命令行中输入文本，并观察服务器端的输出。
- 服务器端会将接收到的文本打印到控制台，并将 "Server received: " + 接收到的文本 返回给客户端。
- 客户端会将接收到的服务器响应打印到控制台。
总结
本文介绍了如何使用 Go 语言构建一个简单的 TCP 客户端-服务器应用。通过这个示例，读者可以了解 Go 语言网络编程的基本概念和步骤。 在实际应用中，可以根据具体需求扩展这个框架，例如添加更复杂的数据处理逻辑、实现身份验证和授权等功能。 记住，并发处理和错误处理是构建可靠网络应用的关键。
