Added Image

Author: Felipe

Dockerfile

@@ -0,0 +1,17 @@
+FROM golang:1.13-alpine as builder
+ENV GOPATH="$HOME/go"
+RUN apk --no-cache add git
+WORKDIR $GOPATH/src
+
+COPY . $GOPATH/src
+
+RUN go get -d -v golang.org/x/net/html
+RUN CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o app consumer/*.go
+
+
+FROM alpine:latest
+RUN apk --no-cache add ca-certificates
+WORKDIR /root/
+
+COPY --from=builder $HOME/go/src/app .
+CMD ["./app"] 

Makefile

@@ -0,0 +1,25 @@
+docker:
+@docker-compose down
+@docker-compose build
+@docker-compose up -d
+
+dockerdown:
+@docker-compose down
+
+build:
+@echo "---- Building Application ----"
+@go build -o consumer consumer/*.go
+@go build -o producer producer/*.go
+
+consume:
+@echo "---- Running Consumer ----"
+@export REDIS_HOST=localhost
+@export STREAM=events
+#@export GROUP=GroupOne
+@go run consumer/*.go
+
+run:
+@echo "---- Running Producer ----"
+@export REDIS_HOST=localhost
+@export STREAM=events
+@go run producer/*.go

README.md

@@ -11,6 +11,8 @@ O Redis tem estratégias para guardar os dados em memória e em disco, garantind
 
 # Redis Streams para Mensageria (ou Messaging)
 
+![Design of flow](/media/flow.png)
+
 **Pontos Positivos**
 
 - Suporta Topicos e Filas 

consumer/main.go

@@ -17,17 +17,14 @@ import (
 uuid "github.com/satori/go.uuid"
 )
 
-const (
-streamName = "events"
-consumerGroup = "consumersOne"
-)
-
 var (
-waitGrp sync.WaitGroup
-mutex sync.Mutex
-client *redis.Client
-start string = ">" //"0" //"0-0" //"-"
-consumerName string = uuid.NewV4().String()
+waitGrp sync.WaitGroup
+mutex sync.Mutex
+client *redis.Client
+start string = ">"
+streamName string = os.Getenv("STREAM")
+consumerGroup string = os.Getenv("GROUP")
+consumerName string = uuid.NewV4().String()
 )
 
 func init() {
@@ -187,5 +184,5 @@ func processStream(stream redis.XMessage, retry bool, handlerFactory func(t even
 //client.XDel(streamName, stream.ID)
 client.XAck(streamName, consumerGroup, stream.ID)
 
-//time.Sleep(3 * time.Second)
+//time.Sleep(2 * time.Second)
 }

docker-compose.yml

@@ -0,0 +1,31 @@
+version: '3'
+
+services:
+ redis:
+ image: redis:alpine
+ container_name: redis-srv
+ ports:
+ - 6379:6379
+
+ redis-commander:
+ container_name: redis-commander-web
+ hostname: redis-commander
+ image: rediscommander/redis-commander:latest
+ restart: always
+ environment:
+ - REDIS_HOSTS=local:redis:6379
+ ports:
+ - "8081:8081"
+
+ consumer:
+ container_name: go-consumer
+ build: '.'
+ environment:
+ REDIS_HOST: redis
+ STREAM: events
+ GROUP: GroupOne
+ depends_on:
+ - redis
+ ports:
+ - '8088:8088'
+ restart: always

media/flow.png

@@ -1,13 +1,16 @@
 package utils
 
-import "github.com/go-redis/redis/v7"
+import (
+"fmt"
+"os"
+
+"github.com/go-redis/redis/v7"
+)
 
 //NewRedisClient create a new instace of client redis
 func NewRedisClient() (*redis.Client, error) {
 client := redis.NewClient(&redis.Options{
-//Addr: "redis-14450.c1.asia-northeast1-1.gce.cloud.redislabs.com:14450",
-//Password: "37uaACndCvuQ1heADnHkishnAhMmosWq", // no password set
-Addr: "localhost:6379",
+Addr: fmt.Sprintf("%s:6379", os.Getenv("REDIS_HOST")),
 Password: "",
 DB: 0, // use default DB
 })

packages/utils/utils.go

@@ -3,19 +3,19 @@ package main
 import (
 "fmt"
 "math/rand"
+"os"
 "time"
 
 evt "github.com/felipeagger/go-redis-streams/packages/event"
 "github.com/felipeagger/go-redis-streams/packages/utils"
 "github.com/go-redis/redis/v7"
 )
 
-const (
-streamName = "events"
+var (
+streamName string = os.Getenv("STREAM")
+client *redis.Client
 )
 
-var client *redis.Client
-
 func init() {
 var err error
 client, err = utils.NewRedisClient()