Redis Pub/Sub

README.md

Redis Publish/Subscribe Sample

Car: Subscriber

Food: Publisher

car.go

package main

import (
	"fmt"

	"github.com/go-redis/redis"
	"github.com/sirupsen/logrus"
)

func main() {

	// create redis connection
	logrus.Infoln("Redis connection init...")
	client := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // no password set
		DB:       0,  // use default DB
	})

	_, err := client.Ping().Result()
	if err != nil {
		panic(err) // ;)
	}

	// subscribe `delivery` channel
	pubsub := client.Subscribe("foodDelivery")
	_, err = pubsub.Receive()
	if err != nil {
		panic(err)
	}

	// Go channel which receives messages.
	ch := pubsub.Channel()

	// Consume messages.
	select {
	case msg := <-ch:
		fmt.Println(msg.Channel, "-> Heyy,", msg.Payload)
		pubsub.Close()
	}

}

food.go

package main

import (
	"time"

	"github.com/go-redis/redis"
	"github.com/sirupsen/logrus"
)

func main() {

	// create redis connection
	logrus.Infoln("Redis connection init...")
	client := redis.NewClient(&redis.Options{
		Addr:     "localhost:6379",
		Password: "", // no password set
		DB:       0,  // use default DB
	})

	_, err := client.Ping().Result()
	if err != nil {
		panic(err) // ;)
	}

	// Publish a message after 2 Seconds -> `delivery` channel (demo)
	time.AfterFunc(2*time.Second, func() {
		err = client.Publish("foodDelivery", "food is ready").Err()
		if err != nil {
			panic(err)
		}
	})

	// demo...
	time.Sleep(3 * time.Second)

}