golang tcp收数据库

在现代软件开发中，与数据库进行交互是非常常见的需求。而使用TCP协议进行数据传输是一种高效可靠的方式。本文将介绍如何使用Golang编写一个TCP服务器，通过TCP连接与数据库进行数据交互。

1. 建立TCP连接

首先，我们需要建立一个TCP服务器，以便与客户端进行通信。在Golang中，可以使用net包来简单地创建一个TCP服务器。

首先，我们需要指定服务器的地址和端口号：

addr := "127.0.0.1:8080"
listener, err := net.Listen("tcp", addr)

接下来，我们需要等待客户端的连接请求，并为每个连接请求创建一个新的协程来处理：

for {
    conn, err := listener.Accept()
    if err != nil {
        log.Fatal(err)
    }
    go handleConnection(conn)
}

在handleConnection函数中，我们可以与客户端进行数据交互。下面，我们将介绍如何使用TCP连接与数据库进行数据交互。

2. 连接数据库

在开始与数据库进行数据交互之前，我们需要先连接到数据库。Golang提供了多个数据库驱动，可以根据自己的需求选择适合的数据库驱动。

以MySQL为例，我们可以使用"database/sql"包来连接到MySQL数据库：

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

func connectDB() (*sql.DB, error) {
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname")
    return db, err
}

在connectDB函数中，我们指定了MySQL的连接地址和数据库名。实际使用时，需要将"user"和"password"替换为真实的用户名和密码。

3. 数据交互

在建立了TCP连接并连接到数据库之后，我们就可以进行数据交互了。这里以查询数据为例：

func handleConnection(conn net.Conn) {
    defer conn.Close()
    
    db, err := connectDB()
    if err != nil {
        fmt.Fprintf(conn, "Failed to connect to database")
        return
    }
    
    rows, err := db.Query("SELECT * FROM table")
    if err != nil {
        fmt.Fprintf(conn, "Failed to query data from database")
        return
    }
    defer rows.Close()
    
    for rows.Next() {
        var id int
        var name string
        var age int
        err := rows.Scan(&id, &name, &age)
        if err != nil {
            fmt.Fprintf(conn, "Failed to read data from database")
            return
        }
        fmt.Fprintf(conn, "id: %v, name: %v, age: %v\n", id, name, age)
    }
    
    err = rows.Err()
    if err != nil {
        fmt.Fprintf(conn, "Failed to read data from database")
        return
    }
    
    fmt.Fprintf(conn, "Data query finished")
}

在handleConnection函数中，我们首先通过connectDB函数连接到数据库。然后，我们使用db.Query函数执行SQL查询，并通过rows.Next和rows.Scan来读取查询结果。

最后，我们通过fmt.Fprintf将查询结果返回给客户端。如果在执行查询过程中出现错误，我们同样通过fmt.Fprintf将错误消息返回给客户端。

通过以上步骤，我们就可以使用Golang编写一个TCP服务器，通过TCP连接与数据库进行数据交互了。