@riserise

Как в GO сделать постоянную подписку на канал в Redis?

Всем здравствуйте, собственно сабж

package main

import (
    "fmt"
	"github.com/go-redis/redis"
)

func main() {

	client := redis.NewClient(&redis.Options{
		Addr: "localhost:6379",
		Password: "",
		DB: 0,
	})

        pubsub := client.Subscribe("test")
    	defer pubsub.Close()
    	msg, err := pubsub.ReceiveMessage()
    	if err != nil {
    		panic(err)
    	}
    	fmt.Println(msg.Channel, msg.Payload)
}


Как это дело заставить работать постоянно, а не завершаться после первого же значения помещённого в канал?
  • Вопрос задан
  • 497 просмотров
Пригласить эксперта
Ответы на вопрос 1
@PapaStifflera
Родился, вырос...
Использовать pubsub.Channel() и читать из канала в цикле. В документации есть пример.
Ответ написан
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы