-6

我是 Go (Golang) 的新手。我编写了一个简单的基准程序来测试 MySQL 的并发处理。当我增加并发通道数时，不断收到“dial tcp 52.55.254.165:3306: getsockopt: connection denied”、“unexpected EOF”错误。

每个 go 例程都在一个简单的客户表中批量插入 1 到 n 行。该程序允许设置可变的插入大小（单个语句中的行数）和并行 go 例程的数量（每个 go 例程在上面执行一次插入）。程序适用于小数字行<100和数字走例程<100。但是当数字增加时开始出现 Unexpected EOF 错误，尤其是并行 go 例程的数量。

一直在寻找线索。基于它们，我设置了数据库最大连接以及“max_allowed_pa​​cket”和“max_connections”。我还设置了 go 程序db.db.SetMaxOpenConns(200), db.SetConnMaxLifetime(200), db.SetMaxIdleConns(10). 我已经尝试过大数字和小数字（从 10 到 2000）。似乎没有什么可以解决程序。

我打开了一个全局数据库连接。下面的代码片段：

// main package

func main() {

    var err error
    db, err = sql.Open("mysql","usr:pwd@tcp(ip:3306)/gopoc")
    if err != nil {
        log.Panic(err)
    }
    db.SetMaxOpenConns(1000)
    db.SetConnMaxLifetime(1000)
    db.SetMaxIdleConns(10)

    // sql.DB should be long lived "defer" closes it once this function ends
    defer db.Close()

    if err = db.Ping(); err != nil {
        log.Panic(err)
    }

    http.HandleFunc("/addCust/", HFHandleFunc(addCustHandler))

    http.ListenAndServe(":8080", nil)
}

// add customer handler
func addCustHandler(w http.ResponseWriter, r *http.Request) {

    // experected url: /addCust/?num=3$pcnt=1
    num, _ := strconv.Atoi(r.URL.Query().Get("num"))
    pcnt, _ := strconv.Atoi(r.URL.Query().Get("pcnt"))

    ch := make([]chan string, pcnt) // initialize channel slice
    for i := range ch {
        ch[i] = make(chan string, 1)
    }

    var wg sync.WaitGroup

    for i, chans := range ch {
        wg.Add(1)
        go func(cha chan string, ii int) {
            defer wg.Done()
            addCust(num)
            cha <- "Channel[" + strconv.Itoa(ii) + "]\n"
        }(chans, i)
    }

    wg.Wait()

    var outputstring string

    for i := 0; i < pcnt; i++ {
        outputstring = outputstring + <-ch[i]
    }

    fmt.Fprintf(w, "Output:\n%s", outputstring)
}

func addCust(cnt int) sql.Result {
...
    sqlStr := "INSERT INTO CUST (idCUST, idFI, fName, state, country) VALUES "

    for i := 0; i < cnt; i++ {

        sqlStr += "(" + strconv.Itoa(FiIDpadding+r.Intn(CidMax)+1) + ", " + strconv.Itoa(FiID) +", 'fname', 'PA', 'USA), " 

    }

    //trim the last ,
    sqlStr = sqlStr[0:len(sqlStr)-2] + " on duplicate key update lname='dup';"

    res, err := db.Exec(sqlStr)
    if err != nil {
        panic("\nInsert Statement error\n" + err.Error()) 
    }

    return res
}
4

1 回答 1

1

我想您在每个例程中都调用 sql.Open ？

Open 函数应该只调用一次。您应该在例程之间共享您打开的数据库连接。Open函数返回的DB可以并发使用，有自己的pool

于 2017-02-28T07:17:54.363 回答