Я получаю слишком много открытых соединений, когда соединение сохраняется - PullRequest
0 голосов
/ 26 октября 2018

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

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: паника, обслуживающая 127.0.0.1:44800: ошибка 1040: слишком много соединений goroutine 220522 [выполняется]: нетто/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)
}

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

1 Ответ

0 голосов
/ 26 октября 2018

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

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

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

Как показано в самом верхнем ответе на этот вопрос Увеличение максимального количества соединений tcp / ip в linux соединения по умолчанию в секунду для Linux довольно консервативны, и небольшой простой сервер Go вполне может его перевесить

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

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...