go-redis pub sub example

go-redis-pub-sub.go

package main

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

var (
    RedisClient *redis.Client
)

func main() {
	RedisClient  =  redis.NewClient(&redis.Options{
		Addr:         Env.Redis.Host + ":" + Env.Redis.Port,
		Password: Env.Redis.Password,
		DB:            Env.Redis.Db,
	})

        // MULTIPLES REPETITION STRUCTURES INSIDE GO ROUTINES

	go func(){
		psNewMessage := RedisClient.Subscribe("channel1")
		for {
			msg, _ := psNewMessage.ReceiveMessage()
			go func() {
				// DO SOMETHING WITH msg
			}()
		}
	}()
	go func(){
		psCallInPulse := RedisClient.Subscribe("channel2")
		for {
			msg, _ := psCallInPulse.ReceiveMessage()
			go func() {
				// DO SOMETHING WITH msg
			}()
		}
	}()

        // MORE 7 GO ROUTINES
}