У меня слишком много открытых подключений, хотя подключение поддерживается

У меня есть простой файл Go с целью возврата json-ответа с информацией о клиенте. Когда я тестирую этот скрипт с тестом apache, и запросы остаются в живых

ab -t 10s -kc 1000 http://127.0.0.1:8080/clients/show/1

Но когда запросы не хранятся, я не страдаю от этой паники

ab -t 10s -c 1000 http://127.0.0.1:8080/clients/show/1

ошибка:

2018/10/26 03:26:42 http: panic serving 127.0.0.1:44800: Error 1040: Too many connections goroutine 220522 [running]: net/http.(*conn).serve.func1(0xc001779e00)

Мой код:

package main

import (
    "database/sql"
    "encoding/json"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
    "github.com/gorilla/mux"
    "net/http"
    "runtime"
)

type Client struct {
    ID         int    `json:"id"`
    UserID     int    `json:"user_id"`
    Name       string `json:"name"`
    Telephone  string `json:"telephone"`
    Email      string    `json:"email"`
    Category   sql.NullString `json:"string"`
    Notes      string `json:"notes"`
    Additional sql.NullString `json:"additional"`
    CreatedAt  sql.NullString `json:"created_at"`
    UpdatedAt  sql.NullString `json:"updated_at"`
    DeletedAt  sql.NullString `json:"deleted_at"`
}

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())
    r := mux.NewRouter()

    r.HandleFunc("/clients/show/{id}", showClient).Methods("GET")

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

func handler(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "Hello World!")
}

func showClient(w http.ResponseWriter, r *http.Request) {

    db, err := sql.Open("mysql", "root@tcp(127.0.0.1:3306)/crm")

    if err != nil {
        panic(err.Error())
    }

    var client Client

    // Execute the query
    err = db.QueryRow("SELECT * FROM clients where id = ?", 1).Scan(
        &client.ID,
        &client.UserID,
        &client.Name,
        &client.Telephone,
        &client.Email,
        &client.Category,
        &client.Notes,
        &client.Additional,
        &client.CreatedAt,
        &client.UpdatedAt,
        &client.DeletedAt,
    )

    if err != nil {
        panic(err.Error())
    }

    db.Close()

    json.NewEncoder(w).Encode(client)
}

Может кто-нибудь объяснить, почему это происходит при такой низкой скорости одновременных запросов и как это исправить.

Когда вы вызываете sql.Open, вы получаете пул соединений, которые следует использовать повторно. Вы должны открыть его перед запуском вашего сервера и позволить вашим обработчикам ссылаться на один пул.

Gavin 26.10.2018 06:51
golang.org/pkg/database/sql/#Open> Возвращенная БД безопасна для одновременного использования несколькими горутинами и поддерживает свой собственный пул незанятых соединений. Таким образом, функцию Open нужно вызывать только один раз. Закрывать БД бывает редко.
Berkant Ipek 26.10.2018 07:08
1
2
1 002
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Есть две проблемы: программное использование сокетов и конфигурация сервера.

Для каждого соединения, вероятно, требуется 2 сокета, один для базы данных и один для http-клиента. Перемещение sql.Open () в другую область видимости, чтобы она не вызывалась повторно, поможет с сокетами базы данных. Для http-сервера значения по умолчанию на самом деле довольно низкие - закройте соединения, если неиспользуемых более 2-х, сохраните активность.

Кроме того, возможно, ваш сервер нуждается в модификации.

Как обсуждает этот ответ, количество подключений по умолчанию для Linux довольно консервативно, и небольшой простой сервер Go может его перегрузить.

Настройте сервер в соответствии с приведенным выше ответом, и это должно помочь.

Другие вопросы по теме