golang redis_stream_go

Posted 2021-05-24

package main

import (
	"mytest/stream/consumer"
	"mytest/stream/publisher"
	"mytest/stream/redis"
	"time"
)

func main() {
	redis.Init()
	defer redis.Client.Close()
	go consumer.Consum("1")
	go consumer.Consum("2")
	go consumer.Consum("3")
	//publisher.Publish()
	for i := 0; i < 10; i++ {
		publisher.Publish()
		time.Sleep(2 * time.Second)
	}
	time.Sleep(time.Second * 3)
}

package publisher

import (
	"github.com/go-redis/redis"
	r2"mytest/stream/redis"
)

func Publish() {
	args := redis.XAddArgs{
		Stream:       "codehole",
		MaxLen:       0,
		MaxLenApprox: 0,
		ID:           "*",
		Values:       map[string]interface{}{"name": "laoqian", "age": 30},
	}
	r2.Client.XAdd(&args)
}

package consumer

import (
	"fmt"
	"github.com/go-redis/redis"
	r2 "mytest/stream/redis"
	"time"
)

func Consum(group string) {

	//s, err := r2.Client.XGroupCreate("codehole", group, "$").Result()
	//fmt.Println(s, err)
	for {
		streams, err := r2.Client.XReadGroup(&redis.XReadGroupArgs{
			Group:    group,
			Consumer: "c1",
			Streams:  []string{"codehole", ">"},
			Count:    1,
			Block:    time.Second * 1,
			NoAck:    true,
		}).Result()
		fmt.Println("group:"+group, streams, err)

	}
}

package redis

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

var Client *redis.Client

func Init() {
	Client = redis.NewClient(&redis.Options{
		Addr: "localhost:6379",
	})
	fmt.Println("Redis----------Ping()----------", Client.Ping())
}

json [Golang] golang #golang #snippets中有用的片段

[ fmt ](https://golang.org/pkg/fmt/)
-------
Print any `type`(struct,maps,primitives) with the `key` name 

``` 
fmt.Printf("\n [key] :%+v \n", [value]) 

```

Print Error  

``` 
fmt.Errorf(" \nError: %s", err.Error()) 

```

[ log ](https://golang.org/pkg/log/)
-------------

Print any `type`(struct,maps,primitives) with the `key` name 

``` 
log.Printf("\n [key] :%+v \n", [value]) 

```


[ http  ](https://golang.org/pkg/log/)
-------------

http middleware 

```  
func [middlewareName](h http.Handler) http.Handler {
              return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
              // Do things before request 
           	
              nextMiddleware.ServeHTTP(w, r)
              // Do things after request	  
              })
          } 
```

{
         "http Middleware declaration": {
		"prefix": "md",
		"body": ["func $1(${2:nextMiddleware} http.Handler) http.Handler {\n\treturn http.HandlerFunc(func(${3:w} http.ResponseWriter, ${4:r} *http.Request) {\n\t $5\n\t nextMiddleware.ServeHTTP(${3:w}, ${4:r})\n\t 	  $6\n\t})\n}"],
		"description": "Snippet for http middleware declaration"
	},

	"log.Printf()": {
		"prefix": "lf",
		"body": [
			"log.Printf(\"\\n## ${1:text} ##: %+v\\n\", ${2:value})"
		],
		"description": "log.Printf()"
	},
	"fmt.Printf()": {
		"prefix": "ff",
		"body": [
			"fmt.Printf(\"\\n## ${1:text} ## :%+v \\n\", ${2:value})",
		],
		"description": "log.Printf()"
	}
}