всем привет, стоит задача написать бота с горутинами и слушанием вебсокетов сейчас есть какойто фреймфорк под это дело? я на пару лет выпал из go )

Самые из тухлых известных мне веб сокетов, ничем особо не выделяющихся - горилла. А так у kataras/iris беспрецендентный лидирующий веб сокет. Нужна головная боль - бери гориллу, нужна простота и WS фреймворк как он есть, бери iris/websocket.

ясно, ничего особо не поменялось )

всем привет, стоит задача написать бота с горутинами и слушанием вебсокетов сейчас есть какойто фреймфорк под это дело? я на пару лет выпал из go )

У гориллы всё сами поднимать будете, простые вещи типа комнат, или массива с существующими на данный момент подключениями, или getConnByID, там всего этого просто не реализовывали. В iris это есть и новые спицы для колеса велосипеда вставлять даже не нужно.

Здравствуйте. Если тест обычных http хендлеров, принимающих http.ResponseWriter, *http.Request, выглядит так: // есть какой-то хендлер - handler req, _ := http.NewRequest("METHOD", "/some/url", nil) rec := httptest.NewRecorder() handler.ServerHTTP(rec, req) // используем rec для тестов то как можно протестировать какое-нибудь middleware, принимающее http.Handler?

https://medium.com/@PurdonKyle/unit-testing-golang-http-middleware-c7727ca896ea это не?

У гориллы всё сами поднимать будете, простые вещи типа комнат, или массива с существующими на данный момент подключениями, или getConnByID, там всего этого просто не реализовывали. В iris это есть и новые спицы для колеса велосипеда вставлять даже не нужно.

если нужны простые вебсокеты, но не нужен оверхед в виде фреймворка. то лучше использовать что-то простое

всем привет, стоит задача написать бота с горутинами и слушанием вебсокетов сейчас есть какойто фреймфорк под это дело? я на пару лет выпал из go )

сейчас есть какойто фреймфорк под это дело?

кстати, мне нужно 2+2 сложить, есть фреймворк?

кстати, мне нужно 2+2 сложить, есть фреймворк?

https://github.com/Herzult/SimplePHPEasyPlus

не, мне на го нужно или жиквери

можно в отдельном докере поднять как микросервис

можно в отдельном докере поднять как микросервис

оверхед

хотя можно заюзать https://github.com/deuill/go-php и завести код на пыхе

https://medium.com/@PurdonKyle/unit-testing-golang-http-middleware-c7727ca896ea это не?

r.RequestURI в middleware - пустой https://pastebin.com/hHXYej42

r.RequestURI в middleware - пустой https://pastebin.com/hHXYej42

окей, тут я ошибся

Всем привет. Пишут тут маленькую мониторилку, она отдает ответ в json. Имеется такой вот код: conn, _ := net.Dial("tcp", "ip:port") jsonRequest := []byte(`{"method":"read"}`) conn.Write(jsonRequest) var sendString string connbuf := bufio.NewReader(conn) for{ str, err := connbuf.ReadBytes('\x04') if len(str)>0 { //тут расшифровка json } if err!= nil { break } } формат ответа сервера {"id": 0, "result": ["qqq", "www", "eee", "rrr", "ttt", "yyy"], "error": null} Пытаюсь парсить в структуру: type Result struct { Id int resul []string error string } dat := Result{} _ := json.Unmarshal(str, &dat); но ничего не получается, в массиве result пусто

что я делаю не так?

проверьте что возвращает json.Unmarshal

он возвращает ошибку, в которой ответ на ваш вопрос

хм у вас в структуре error это string, а в значениях null, проблема может быть в этом

ну и то, что в значениях result это []string, а в структуре map[string]interface{}

ойой, это не правильная версия

Всем привет. Пишут тут маленькую мониторилку, она отдает ответ в json. Имеется такой вот код: conn, _ := net.Dial("tcp", "ip:port") jsonRequest := []byte(`{"method":"read"}`) conn.Write(jsonRequest) var sendString string connbuf := bufio.NewReader(conn) for{ str, err := connbuf.ReadBytes('\x04') if len(str)>0 { //тут расшифровка json } if err!= nil { break } } формат ответа сервера {"id": 0, "result": ["qqq", "www", "eee", "rrr", "ttt", "yyy"], "error": null} Пытаюсь парсить в структуру: type Result struct { Id int resul []string error string } dat := Result{} _ := json.Unmarshal(str, &dat); но ничего не получается, в массиве result пусто

Теги забыл добавить

Теги забыл добавить

какие тэги?

json:"имяполя"

какие тэги?

для членов структуры

хм у вас в структуре error это string, а в значениях null, проблема может быть в этом

ошибка в unmarshal EOF

сейчас теги проставлю

сейчас теги проставлю

type Result struct { Id int `json:"id"` Result []string `json:"result"` Error string `json:"error"` }

ага, спасибо, прописал

ошибка в unmarshal EOF

проверьте также что у вас в str (сделайте Println, там может быть не совсем то, что вы ожидаете)

там байты, я же делаю str, err := connbuf.ReadBytes('\x04')

проверьте также что у вас в str (сделайте Println, там может быть не совсем то, что вы ожидаете)

ведь в json.Unmarshal(str, &dat) str тут не строчка же, а массив байтов

я про содержание, а не тип

func Unmarshal(data []byte, v interface{})

я про содержание, а не тип

ну если сделать ReadString и вывести, получается то, что я выше скидывал

Спасибо, все получилось!

это я тупил )

скорее всего дело где-то в этом, можно попробовать вместо lexer.emit(DigitToken(lexer.context.buffer.Bytes()[:])) lexer.context.buffer.Reset() сделать tmp:=make([]byte,lexer.context.buffer.Len()) copy(tmp,lexer.context.buffer.Bytes()) lexer.emit(DigitToken(tmp)) lexer.context.buffer.Reset() не меняя DigitToken() даже наверно луче, меньше шансов что Buffer поменяеться в процессе

да, дело в этом. помогло.

спасибо

да, дело в этом. помогло.

не за что слайсы они такие :)

слаесы игрушка дьявола

не за что слайсы они такие :)

lexer.emit(DigitToken(lexer.context.buffer.Bytes()[:])) lexer.context.buffer.Reset() да, вот тут в момент emit'а, токен отправлялся в канал, выгребался токенайзером, и запускалась следующая итерация, в то время как Reset (см. вторую строчку) еще не отработал

tmp := make([]byte, lexer.context.buffer.Len()) copy(tmp, lexer.context.buffer.Bytes()) lexer.context.buffer.Reset() lexer.emit(DigitToken(tmp)) решило проблему

коллеги я тут с GAE разбираюсь и не могу понять есть ли бесплатный вариант как в AWS lambda? хочу попробовать потестить.

или я плохо читаю доки?

lexer.emit(DigitToken(lexer.context.buffer.Bytes()[:])) lexer.context.buffer.Reset() да, вот тут в момент emit'а, токен отправлялся в канал, выгребался токенайзером, и запускалась следующая итерация, в то время как Reset (см. вторую строчку) еще не отработал

не, имено после ресета слайс терял данные, ты данные в канал отправил, но еще не прочитал, пришел ресет, ты читаешь, а в слайсе уже следующие данные byte.Buffer вещь своеобразная там надо или либо полноценный Read делать или копирование из буфера с контролем что он не измениться в процессе иначе печалька

Чятик, а я могу как-то убить горутину по таймауту?

Условно, она занята инфинити лупой, а я хочу её гарантированно прибить по таймауту

Чятик, а я могу как-то убить горутину по таймауту?

да

Чятик, а я могу как-то убить горутину по таймауту?

можешь

Разрешаем)

мб кинуть из процесса-спаунера туда канал, чекать в инфинит лупе если пришло что пора закрывать, тогда break

https://medium.com/@matryer/stopping-goroutines-golang-1bf28799c1cb

Не могу. Там идёт операция и горутина просто не дойдёт до чтения из канала

как - то так оно делается

Не могу. Там идёт операция и горутина просто не дойдёт до чтения из канала

какая операция идет?

Я тупо не дойду до второго кейса

какая операция идет?

Условно, клонирование репозитория из гита. Я хочу убить это спустя минуту

ну делай прирывание при клонировании

прочитал строки, зашел на круг в форе

все что связано с операций в блок дефаулт

как только таймер сработает ретурн или брейк

ERROR: S client not available

Хорошо. Я в горутине выполняю атомарную операцию. Не могу её разделить. Но хочу грохнуть её спустя 60с. Так понятнее?

Хорошо. Я в горутине выполняю атомарную операцию. Не могу её разделить. Но хочу грохнуть её спустя 60с. Так понятнее?

Атомарные операции не исполняются по 60 сек

атомарную операцию нельзя убить

Наивный

К сожалению, идея убивать атомарную операцию пришла не с потолка

Хорошо. Я в горутине выполняю атомарную операцию. Не могу её разделить. Но хочу грохнуть её спустя 60с. Так понятнее?

Атомарная из определения не делимая, как вы хотите ее разделить???

Я не хочу её делить. Я хочу её прервать

К сожалению, идея убивать атомарную операцию пришла не с потолка

Да Х знает

Я не хочу её делить. Я хочу её прервать

Еще раз атомарные операции, по тому и называются атомарными, что они не делимые и разделить ее нельзя

например 2-1 - это атомарная операция

У вас что-то с фокусом не то, почитайте что такое атомарные операции, потом задавайте такие вопросы

Я не хочу её делить. Я хочу её прервать

мб как отдельный микросервис и запуск через exec?)

Вернёмся к исходному вопросу: могу ли я убить горутину не изнутри горутины?

Вернёмся к исходному вопросу: могу ли я убить горутину не изнутри горутины?

НЕТ

Вернёмся к исходному вопросу: могу ли я убить горутину не изнутри горутины?

Только изнутри и никак иначе

Вернёмся к исходному вопросу: могу ли я убить горутину не изнутри горутины?

Посмотри исходники менеджера горутин

Посмотри исходники менеджера горутин

Надежда умирает последней?))))

)))

Задача все равно странная)

Условно, клонирование репозитория из гита. Я хочу убить это спустя минуту

зачем это так?)

зачем это так?)

мне нужно прикрутить таймаут к тому, во что я не могу вмешаться.

Мб на C/C++ на потоках с врапером под Go переделать

мне нужно прикрутить таймаут к тому, во что я не могу вмешаться.

Плохо тебе...

Я начинаю думать, что на баше это было бы строк на 800 короче и работало бы >_<

)))

Плохо тебе...

Как правило такие задачи решаются тем что на самом деле можно переделать то, что по началу нельзя было переделать)))

Как правило такие задачи решаются тем что на самом деле можно переделать то, что по началу нельзя было переделать)))

+

Я начинаю думать, что на баше это было бы строк на 800 короче и работало бы >_<

Тебе никто не мешает сделать врапер нужного процесса на баше

Но лучше не допускать таких вещей

Но лучше не допускать таких вещей

Да я сам с таким сталкивался, а в итоге оказывалось что надо один врапер из либы разобрать и все становилось нормально, все таймауты спокойно навешиваются и тд и тп