170 похожих чатов

У кого-нибудь возникали когда-нибудь траблы с тем, что течёт память

(увеличивается в потолок правильнее сказать, так как фат истиной утечки установлен не был) из net/http, fasthttp при наличии > 1000 горутин?


func worker(timeout time.Duration, wg *sync.WaitGroup, in chan Pair, out chan Pair) {
client := &fasthttp.Client{
MaxIdleConnDuration: timeout,
}
for {
scheme := []string{"https"}
domain := <-in
for _, s := range scheme {
t := time.Now()
req := fasthttp.AcquireRequest()
resp := fasthttp.AcquireResponse()

host := fmt.Sprintf("%s://%s", s, domain.String)
req.Header.SetMethodBytes([]byte("GET"))
req.SetRequestURI(host)
err := client.DoTimeout(req, resp, timeout)
s := fmt.Sprint(time.Now().Sub(t), resp.StatusCode(), err, " ", host, " ", resp.LocalAddr())
out <- Pair{String: s, Index: domain.Index, Err: err}

fasthttp.ReleaseResponse(resp)
fasthttp.ReleaseRequest(req)
}
}
wg.Done()
}

6 ответов

18 просмотров
Егор- Автор вопроса

Я его не стал заморачиваться писать, покуда 250 лямов строк я не дожидался, когда обработаются. Меня раньше разрывается RAM

О, я знаю, было такое же. У client есть метод типа CloseIdleConnections(), его нужно вызывать, когда клиент больше не нужен, он закроет все соединения и освободит память.

Егор- Автор вопроса

.

Ghost I Am 👻
О, я знаю, было такое же. У client есть метод типа...

@cuda23 попробуй это, должно помочь, просто закрывай сразу как тебе не нужно будет соединение.

Егор
.

мне кажется что 100000 клиентов это тоже много

Егор- Автор вопроса

Вот, собственно я так делал

Похожие вопросы

Обсуждают сегодня

30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
13
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
Как передать управляющий символ в открытую через CreateProcess консоль? Собсна, есть процедура: procedure TRedirectThread.WriteData(Data: OEMString); var Written: Cardinal;...
Serjone
6
в JclConsole объявлено так: function CtrlHandler(CtrlType: DWORD): BOOL; stdcall; - где ваше объявление с stdcall? у вас на картинке нет stdcall
Karagy
8
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
~ 2m21s  nix shell github:nixos/nixpkgs#stack ~  stack ghc -- --version error: … while calling the 'derivationStrict' builtin at /builtin/derivation.nix:...
Rebuild your mind.
6
Карта сайта