https://github.com/go-redis/redis

    1. import (
    2.     "context"
    3.     "fmt"
    5.     "github.com/go-redis/redis/v8"
    6. )
    8. var ctx = context.Background()
    10. func main() {
    11.     rdb := redis.NewClient(&redis.Options{
    12.         Addr:     "192.168.31.151:6379",
    13.         Password: "314159", // no password set
    14.         DB:       0,        // use default DB
    15.     })
    17.     err := rdb.Set(ctx, "key", "value", 0).Err()
    18.     if err != nil {
    19.         panic(err)
    20.     }
    22.     val, err := rdb.Get(ctx, "key").Result()
    23.     if err != nil {
    24.         panic(err)
    25.     }
    26.     fmt.Println("key", val)
    27. }
    1. func main() {
    2.     pubsub := rdb.Subscribe(ctx, "mychannel1")
    4.     // Wait for confirmation that subscription is created before publishing anything.
    5.     _, err := pubsub.Receive(ctx)
    6.     if err != nil {
    7.         panic(err)
    8.     }
    10.     // Publish a message.
    11.     err = rdb.Publish(ctx, "mychannel1", "hello").Err()
    12.     if err != nil {
    13.         panic(err)
    14.     }
    16.     // Go channel which receives messages.
    17.     ch := pubsub.Channel()
    19.     time.AfterFunc(time.Second, func() {
    20.         // When pubsub is closed channel is closed too.
    21.         _ = pubsub.Close()
    22.     })
    24.     // Consume messages.
    25.     for msg := range ch {
    26.         fmt.Println(msg.Channel, msg.Payload)
    27.     }
    28. }