ЯК
err = ch.Qos(
1, // prefetch count
0, // prefetch size
false, // global
)
Size: a a a
2021 June 01
ЯК
В байтах что ли?
ЯК
Можно сказать что какой-то воркер может обрабатывать сообщения которые не больше определенного размера в байтах?
ЯК
Интереснооооооо)
J
Если английский знаешь тогда этот ресурс неплохо объяснит
https://youtube.com/c/TechWorldwithNana
https://youtube.com/c/TechWorldwithNana
ЯК
А знаете что ещё странно? ну это уже чисто гошный вопрос, есть два цикла фор в форе, внутренный вор подписан
(Надеюсь код номрально вставился)
Так вот, у меня в консоли высвечивается
ПОтом
И всё) дальше код почему то не едёт, хотя должен был во внешнем лупе заново начаться, если закоментриую закрытие коннекшенов и каналов, то всё нормально крутиться,))) Очень странно))))
for {
someLoop:
for {
select {
case someErr := <-errChan:
break someLoop
}
}
log.Println("After break readMessagesLoop!")
if err := conn.Close(); err != nil {
log.Printf("[main] conn.Close Error: %v", err)
}
if err := ch.Close(); err != nil {
log.Printf("[main] ch.Close Error: %v", err)
}
log.Println("Restart worker")
}(Надеюсь код номрально вставился)
Так вот, у меня в консоли высвечивается
After break readMessagesLoop!
ПОтом
[main] conn.Close Error: Exception (504) Reason: "channel/connection is not open"
И всё) дальше код почему то не едёт, хотя должен был во внешнем лупе заново начаться, если закоментриую закрытие коннекшенов и каналов, то всё нормально крутиться,))) Очень странно))))
ЯК
По факту код должен был без проблем дойти до конца же и высветить
И начаться опять, но нет, буквально последний лог еррора и всё, стоит на месте, не паникует ничего)
Если закоментировать именно
Эту часть, то всё будет дозодить до
и начинаться цикл заново)
log.Println("Restart worker")И начаться опять, но нет, буквально последний лог еррора и всё, стоит на месте, не паникует ничего)
Если закоментировать именно
if err := conn.Close(); err != nil {
log.Printf("[main] conn.Close Error: %v", err)
}
if err := ch.Close(); err != nil {
log.Printf("[main] ch.Close Error: %v", err)
}Эту часть, то всё будет дозодить до
log.Println("Restart worker")и начинаться цикл заново)
ЯК
worker-2 | 2021/06/01 05:49:29 After break readMessagesLoop!
worker-2 | 2021/06/01 05:49:29 [main] conn.Close Error: Exception (504) Reason: "channel/connection is not open"
worker-1 | 2021/06/01 05:49:29 After break readMessagesLoop!
worker-1 | 2021/06/01 05:49:29 [main] conn.Close Error: Exception (504) Reason: "channel/connection is not open"
worker-3 | 2021/06/01 05:49:29 After break readMessagesLoop!
worker-3 | 2021/06/01 05:49:29 [main] conn.Close Error: Exception (504) Reason: "channel/connection is not open"
AK
S
Я вот как раз без проработки пробежался, реально теряешь нить после середины
АК
а зачем вам select в данном примере, если вы читаете только из 1 канала? уберите его и запустите, (только добавьте if на someErr, ну точнее ok, хотя смотря что вам нужно))
ЯК
Это для примера) не хотел весь листинг засовывать)
ЯК
И проблема же не в селекте)
ЯК
Проблема почема почему-то в них
что ли какимто образом)
if err := conn.Close(); err != nil {
log.Printf("[main] conn.Close Error: %v", err)
}
if err := ch.Close(); err != nil {
log.Printf("[main] ch.Close Error: %v", err)
}что ли какимто образом)
АК
1. в вашем примере кода непонятно что за conn и что за ch, откуда они беруться и что с ними до кода происходит.
2. Вы в цикле закрываете канал, но при любом чтении из канала ошибок - вы завершаете цикл (насколько я знаю, из канала всегда (условно) можно считать значение. пусть даже и нулевое для типа канала, а значит вы всегда (при условии что канал ошибок не закрыт) что-то там получаете и завершаете цикл.
Но проблема в том что далье по коду вы хотели закрыть коннект и канал, но т.к цикл кончился раньше - вы этого не делаете
2. Вы в цикле закрываете канал, но при любом чтении из канала ошибок - вы завершаете цикл (насколько я знаю, из канала всегда (условно) можно считать значение. пусть даже и нулевое для типа канала, а значит вы всегда (при условии что канал ошибок не закрыт) что-то там получаете и завершаете цикл.
Но проблема в том что далье по коду вы хотели закрыть коннект и канал, но т.к цикл кончился раньше - вы этого не делаете
АК
засуньте в defer закрытие conn и ch и попробуйте. Ну это если я верно понял задачу
ЯК
Да мы там реббит обсуждали выше, это конекшн и канал ребита)