Go 语言 和 Redis 普通订阅与发布 pubsub,使用 go-redis/redis

yufei       3 年, 11 月 前       3354

package main

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

func main() {
    rdb := redis.NewClient(&redis.Options{
        Addr:     "localhost:6379", // 使用默认数据库
        Password: "",               // 没有密码则置空
        DB:       0,                // 使用默认的数据库
    })

    pong, err := rdb.Ping().Result() // 检查是否连接
    if err != nil {
        log.Fatal(err)
    }

    // 连接成功啦
    log.Println(pong)

    // 订阅全部消息
    pubsub := rdb.Subscribe("name")
    // 等待消息返回,原因是上一个方法不是立即返回的,囧
    _, err = pubsub.Receive()
    if err != nil {
        log.Fatal(err)
    }

    // 用管道来接收消息
    ch := pubsub.Channel()

    // 处理消息
    for msg := range ch {
        log.Println(msg.Channel, ":", msg.Payload)
    }

}
目前尚无回复
简单教程 = 简单教程,简单编程
简单教程 是一个关于技术和学习的地方
现在注册
已注册用户请 登入
关于   |   FAQ   |   我们的愿景   |   广告投放   |  博客

  简单教程,简单编程 - IT 入门首选站

Copyright © 2013-2022 简单教程 twle.cn All Rights Reserved.