Кидай запросы параллельно

Пиши их в канал потом все

да struct я так и сделал

Доставай из канала и сортируй как надо

но я не пойму как в цикле делать каналы и потом из них чиатть

и как-то дождаться всех ответов

там типа wg.wait()

мне нужен только один канал или массив?

Смотря что ты хочешь делать

Прочитай про chan

Как они работают

там типа wg.wait()

Не надо

да вот читал, с одним я работать понимаю как, а вот с массивом - нет. Вот я тут и спрашиваю

Ну кинь код свой, давай напишу

допустим у меня есть метод fetch(url, index, ch) и есть urls массив

я в цикле for index,url:=range urls { go fetch(url, index, ch) }

вот только в for я не понимаю как сделалть этот вот ch и как потом из него прочитать

Горутина отдельная с циклом пока не получили все записи

И бери из канала каждый раз

<-ch

а горутьиана на каждый запрос тоже нужна?

мне нужно сделать только один канал? ch := make(chan Response, len(urls))?

https://tour.golang.org/concurrency/4

https://tour.golang.org/concurrency/2

https://tour.golang.org/concurrency/4

Спасибо

https://tour.golang.org/concurrency/2

ch := make(chan FeedResponse, len(urls)) for index, url := range urls { go GetFeed(url, index, ch) } for res := range ch { fmt.Println(res) } close(ch) Вот так все работает только программа не завершается. Что не так?

ну так канал то не закрыт

ну так канал то не закрыт

+

он и крутит в бесконечном цикле

ch := make(chan FeedResponse, len(urls)) for index, url := range urls { go GetFeed(url, index, ch) } for res := range ch { fmt.Println(res) } close(ch) Вот так все работает только программа не завершается. Что не так?

Когда все принял закрывай канал, да и там вроде len(urls) не надо

что значит закрыть канал?

close(ch) там ведь есть, или это не то?

так он после цикла

а, в цикле нужно закрыть? Тогда как определить что все закрыл?

а цикл не завершается

что все получил

а, в цикле нужно закрыть? Тогда как определить что все закрыл?

waitgroup посмотрите

что все получил

Чувак я же кидал

Дочитай до конца

https://tour.golang.org/concurrency/4

В чем проблемма

Ну один в один там

В чем проблемма

там цикл синхронный и поэтому понятно когда закрыть

там цикл синхронный и поэтому понятно когда закрыть

Точно?)

x, y := 0, 1 for i := 0; i < n; i++ { c <- x x, y = y, x+y } close(c)

ну тут ведь когда прошел цикл и все передано в канал вызывается close

Ну смотри тогда wait group)))

ну вот :) Я об этом сначала и спрашивал?

ладно. Всем спасибо. Разобрался

если кому интересно, получилось вот так func GetFeeds(urls []string) [][]byte { length := len(urls) results := make([][]byte, length) ch := make(chan FeedResponse, length) for index := 0; index < length; index++ { go GetFeed(urls[index], index, ch) } for index := 0; index < length; index++ { res := <-ch results[res.Index] = res.Body } close(ch) fmt.Println(len(results)) return results } ну чтобы без waitgroup обойтись

что самое прикольное в js это одна строчка. Хоть конечно там не thread а event loop Promise.all(urls.map(getFeed)).then(sortedArrayOfResponses)

что самое прикольное в js это одна строчка. Хоть конечно там не thread а event loop Promise.all(urls.map(getFeed)).then(sortedArrayOfResponses)

Можно на структурах и в Go сделать в пару строк (для дальнейшего использования), если покурить...

Ребят как заставить го складывать бины в $GOPATH/bin, щас он кидает тупо в $GOPATH

Ребят как заставить го складывать бины в $GOPATH/bin, щас он кидает тупо в $GOPATH

win?

win?

mac os

в $PATH прописал $GOPATH/bin

mac os

Попробуй указать $GOBIN

$GOBIN = $GOPATH/bin

мб у тебя где-то он уже прописан на каталог $GOPATH

и тупо туда устанавливает

https://golang.org/cmd/go/#hdr-GOPATH_environment_variable

не помогло

ааа понял косяк

Можно на структурах и в Go сделать в пару строк (для дальнейшего использования), если покурить...

Думаю что нет. И это не в минус Go. Он и так очень хорош

ERROR: S client not available

надо не go build а go install, сорян

ребят подскажите у кого опыт есть, как лучше организовать общение между микросеврисами на го, просто через http rest или кто-то способ получше знает?

Grpc

Socket, rpc?

ну а плюсы есть какие-то по отношению к http рест?

ну а плюсы есть какие-то по отношению к http рест?

Не json

Полноценный РПЦ вот

Grpc

А graphql?

А graphql?

Несколько не в месте взаимодействия между серверами

Несколько не в месте взаимодействия между серверами

А))

А клиент - сервер, что юзают?

А клиент - сервер, что юзают?

пока ничего, но либо рест либо graph ql буду пилить)

Понятно.

У graphql что с безопасностью?

У graphql что с безопасностью?

а что собственно не так? Я лично ничего не слышал плохого о нем

а что собственно не так? Я лично ничего не слышал плохого о нем

Ну например слышал что мона выкачать весь сайт/бд, лехко и просто. Плюс нуно наверное что-то писать дополнительное что-бы, ограничивать запросы.

Ну например слышал что мона выкачать весь сайт/бд, лехко и просто. Плюс нуно наверное что-то писать дополнительное что-бы, ограничивать запросы.

ну по ресту так же можно выкачать всё что хочешь, а так можно в графе с помощью вложенных запросов подвесить всё, но это всё решается просто ограничем на вложенные запросы

Плят, https://gobyexample.ru/ умер по ходу.

Ну например слышал что мона выкачать весь сайт/бд, лехко и просто. Плюс нуно наверное что-то писать дополнительное что-бы, ограничивать запросы.

это не так. graphql - язык запросов в общем-то.

Это понятно, но можно всё по чуть-чуть и запросить)

Это понятно, но можно всё по чуть-чуть и запросить)

ну да. ты же апи делаешь, чтобы кто-то что-то запрашивал?

А почему не конвертится? Отдельно каждый байт конвертить нужно? type IPAddr [4]byte func (i IPAddr) Stringer() string { v := string(i) return v }

А почему не конвертится? Отдельно каждый байт конвертить нужно? type IPAddr [4]byte func (i IPAddr) Stringer() string { v := string(i) return v }

что пишет?

cannot convert i (type IPAddr) to type string как-то так...

а если так: return string([]byte(i))

cannot convert i (type IPAddr) to type []byte

string(i[:])

Ага, супер, работает))

Чот никак не доходило что мона срез заюзать.

type Book struct { isbn string json:"isbn" title string json:"title" author string json:"author" } book := Book{isbn:"1234", title:"Call of Cthulhu", author:"Lovecraft"} json.NewEncoder(os.Stdout).Encode(book) Выводит в терминал {}. Написал имена полей структуры с заглавной буквы и всё вывело должным образом. Это так и должно работать?