go-redis 发布/订阅

栏目: 数据库 · 发布时间: 6年前

内容简介:最近golang 的项目开始使用redis 对于redis 真的是接触少,而且是golang版本的 只能是看着文档一点一点的入手了

go-redis 发布/订阅

最近golang 的项目开始使用 redis 对于redis 真的是接触少,而且是golang版本的 只能是看着文档一点一点的入手了

连接初始化

RedisClient = redis.NewClient(&redis.Options{
            Addr:     "localhost:6379",
            Password: "", // no password set
            DB:       0,  // use default DB
        })

发布

//参数1 频道名 字符串类型 
    //参数2 发送的内容 他是个 interface{} 类型 因为我要和前端对接 所以data是我转的json字符

    err := RedisClient.Publish("message", data).Err()
        if err != nil {
            return errors.New("发布失败")
        }

订阅

func Subscribe(){
        //参数1 频道名 字符串类型
        pubsub := redis.Redis.Subscribe("homework")
            _, err := pubsub.Receive()
            if err != nil {
                
                return
            }
            ch := pubsub.Channel()
            for msg := range ch {
                fmt.Println( msg.Channel, msg.Payload, "\r\n")
            }
    }
    这里的订阅了频道,阻塞了代码继续执行,所以我们 需要 go Subscribe() 来让我们的程序 继续执行 并且go Subscribe() 写在init方法内 服务启动只执行一次

以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

ppk谈JavaScript

ppk谈JavaScript

Peter-Paul Koch / 淘宝UED / 人民邮电出版社 / 2008-4 / 59.00元

本书全方位介绍了JavaScript,主要讨论了浏览器兼容性、可访问性、底层语法以及与HTML结构层的协同等问题。书中既包括理论性的讲解,又给出了相关的示例脚本以进行进一步阐述。通过8个真实项目示例,介绍了JavaScript核心语言、BOM、事件处理、DOM、修改CSS样式表以及数据检索等内容。 本书适合具有一定网页开发经验的Web开发人员阅读。一起来看看 《ppk谈JavaScript》 这本书的介绍吧!

RGB转16进制工具
RGB转16进制工具

RGB HEX 互转工具

SHA 加密
SHA 加密

SHA 加密工具

html转js在线工具
html转js在线工具

html转js在线工具