前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >go: diskqueue磁盘队列使用

go: diskqueue磁盘队列使用

作者头像
超级大猪
发布2022-11-29 17:26:57
6500
发布2022-11-29 17:26:57
举报
文章被收录于专栏:大猪的笔记

创建队列

代码语言:javascript
复制
import "github.com/nsqio/go-diskqueue" 
buffer := diskqueue.New( 
    name, // 很重要,关系到队列缓存文件的名字 
    config.GlobalLocalConfig.DiskQueueDir, 
 1024*1024*512*1, //  单个文件512M 
 4, // 最小4字节 
 1024*1024*4, // 最大消息4M 
 1000, // 每1000次写入同步 
 5*time.Second, // 每5s同步 
    func(lvl diskqueue.LogLevel, f string, args ...interface{}) { 
 if lvl == diskqueue.INFO { 
            log.Infof(f, args...) 
 } else if lvl >= diskqueue.WARN { 
            log.Errorf(f, args...) 
 } 
 }) 

读取队列:

代码语言:javascript
复制
select { 
case <-p.ctx.Done(): 
 return 
case msg, ok := <-p.bufferQueue.ReadChan(): 
 if !ok { 
        log.Fatal("diskqueue read nil") 
 return 
 } 
 // do sth on msg 
} 
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022-08-25 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档