- 综合排序
- 最热优先
- 最新优先
- 来自专栏solate 杂货铺
go-nsq 使用
首先就是一个生产者消费者的模式，自己创建的消费者只要有HandleMessage方法就可以 package main import ( "fmt" "time" "github.com/nsqio/go-nsq nsq admin 参数说明 nsq admin 中显示的那些参数，可以在这里进行查看 http://nsq.io/components/nsqadmin.html#metrics ##参考 go-nsq
87020发布于 2019-07-22 - 来自专栏Golang语言社区
go-nsq使用简述
/tmp目录下的一个文件中 五 代码测试： package main import ( "fmt" "time" "github.com/nsqio/go-nsq" ) // nsq
1.4K60发布于 2018-03-23 - 来自专栏Golang语言社区
go-nsq使用简述
/tmp目录下的一个文件中 五 代码测试： package main import ( "fmt" "time" "github.com/nsqio/go-nsq" ) //
1.9K100发布于 2018-03-26 - 来自专栏Golang语言社区
Golang优秀实用开源项目收集
github.com/bradfitz/gomemcache/memcache https://godoc.org/github.com/bradfitz/gomemcache/memcache 4.MQ go-nsq go get github.com/nsqio/go-nsq https://godoc.org/github.com/nsqio/go-nsq go-nsq是nsq的golang client包，nsq
1.6K70发布于 2018-03-20 - 来自专栏Golang语言开发栈
Golang 语言编写的消息队列 NSQ 官方客户端 go-nsq 怎么使用？
本文我们主要介绍 NSQ 官方提供的 golang 客户端 go-nsq。关于 NSQ 的更多内容，感兴趣的读者朋友们可以查阅官方文档，限于篇幅，本文不再赘述。 使用 go-nsq 操作 NSQ，需要安装 go-nsq 库，它提供了许多用于操作 NSQ 的函数和方法。 安装方式： // Mac 安装 nsq brew install nsq // 安装 go-nsq go get -u github.com/nsqio/go-nsq 02 生产者 go-nsq 包中的 并且分别介绍了 Producer 和 Consumer 的简单使用方法，大家可以根据自己的业务需求，使用 go-nsq 灵活运用 NSQ。 关于 go-nsq 的更多内容，感兴趣的读者朋友们可以阅读官方文档。 推荐阅读： Golang 语言怎么编写测试代码？
2K20发布于 2021-11-02 - 来自专栏全栈工程师修炼之路
4.Go语言项目操作之NSQ分布式消息队列实践
NSQ 实践操作 1.go-nsq 安装 描述: NSQ官方为了开发者提供了Go语言版的客户端go-nsq(https://github.com/nsqio/go-nsq)，更多客户端支持请查看CLIENT go-nsq库安装命令如下所示: ➜ src cd weiyigeek.top ➜ weiyigeek.top go get -u github.com /nsqio/go-nsq # go: downloading github.com/nsqio/go-nsq v1.1.0 # go: downloading github.com/golang /snappy v0.0.4 # go get: added github.com/golang/snappy v0.0.4 # go get: added github.com/nsqio/go-nsq producer.go package main import ( "bufio" "fmt" "log" "os" "strings" "github.com/nsqio/go-nsq
1.6K10编辑于 2022-09-29 - 来自专栏aoho求索
高性能消息中间件 NSQ 解析-应用实践
首先是创建生产者： package main import ( "fmt" "log" "time" "github.com/nsqio/go-nsq" ) func main() ) } time.Sleep(time.Second * 1) } p.Stop() } 生产者的逻辑比较简单，基于 nsq 官方提供的 github.com/nsqio/go-nsq package main import ( "log" "sync" "github.com/nsqio/go-nsq" ) func main() { wg := &sync.WaitGroup
76321发布于 2021-03-16 - 来自专栏大猪的笔记
go: nsq启动与部署
--nsqd-http-address 127.0.0.1:4151 producer package main import ( "fmt" "github.com/nsqio/go-nsq break } } } consumer package main import ( "log" "time" "github.com/nsqio/go-nsq
72220发布于 2021-06-17 - 来自专栏技术之路
Docker部属Nsq集群
我用go语言 简单写一个发送信息的例子： go使用的库是 go-nsq 地址 ： github.com/nsqio/go-nsq func main() { config := nsq.NewConfig 客户端golang代码 package main import ( "fmt" "github.com/nsqio/go-nsq" "log" "os" "os
1.8K91发布于 2018-01-31 - 来自专栏TSINGSEE青犀视频
EasyCVR使用NSQ处理消息时topic和channel的理解
相同，channel 不同，一个是 channel 1 一个是 channel 2，代码如下： package main import ( "fmt" "github.com/nsqio/go-nsq 消费者代码如下： package main import ( "fmt" "github.com/nsqio/go-nsq" "log" "os" "os/signal"
1.1K30发布于 2021-11-12 - 来自专栏技术之路
剖析nsq消息队列(一) 简介及去中心化实现原理
go-nsq nsq官方的go语言客户端，基本上市面上的主流编程语言都有相应的客户端在这里 还有可视化的组件nsqadmin和一些工具像nsq_to_file、nsq_stat、等等，这些在后期的帖子里会介绍 总结 我使用的客户端库是官方库 go-nsq，使用直接连nsqd的方式， 如果有nsqd出现问题，现在的处理方式，他会每隔一段时间执行一次重连操作。想去掉这个连接信息就要额外做一些处理了。 客户端简单代码 package main import ( "fmt" "os" "os/signal" "time" "github.com/nsqio/go-nsq message.Body)) return nil } 方法ConnectToNSQLookupds就是用于连接nsqlookupd的，但是需要注意的是，连接的是http端口7201和8201，库go-nsq
2K40发布于 2019-09-29 - 来自专栏K8s 系列
golang-nsq系列(一)--初识
Golang 使用 nsq 创建生产者：producer.go package main import ( "fmt" "log" "time" "github.com/nsqio/go-nsq 创建消费者：consumer.go package main import ( "log" "sync" "github.com/nsqio/go-nsq" ) func main(
82210发布于 2021-09-22 - 来自专栏devops_k8s
Go之NSQ简介,原理和使用
Go操作NSQ 安装go客户端 /* go get -u github.com/nsqio/go-nsq */ 生产者 // nsq_producer/main.go package main import ( "bufio" "fmt" "os" "strings" "github.com/nsqio/go-nsq" ) // NSQ Producer Demo var producer nsq_consumer/main.go package main import ( "fmt" "os" "os/signal" "syscall" "time" "github.com/nsqio/go-nsq
4.4K83发布于 2020-10-30 - 来自专栏TSINGSEE青犀视频
如何在EasyCVR中实现NSQ延时推流技术？
因此我们本文主要是调研是否有该功能的过程，我们主要使用 DeferredPublish 方法实现，方法代码如下： package main import ( "fmt" "github.com/nsqio/go-nsq
72410发布于 2021-11-18 - 来自专栏DevOps
Go：构建应用程序的10大框架
└── publish.go consume.go 代码： package main import ( "log" "sync" "github.com/nsqio/go-nsq go run consume/consume.go publish.go 代码： package main import ( "log" "github.com/nsqio/go-nsq log.Panic(err) } } 运行 publish： $ go run publish/publish.go 项目地址：https://github.com/nsqio/go-nsq
58410编辑于 2024-03-29 - 来自专栏Golang语言社区
NSQ的golang客户端简单使用
获取客户端 nsq的golang客户端是官方版本的 go get github.com/nsqio/go-nsq 即可 简单的消费者和生产者使用 该客户端有原始的command函数用于一些基础操作，也有
1.9K70发布于 2018-03-23 - 来自专栏跟着asong学Golang
推荐几个可以写到简历上的Go方向优质开源项目（需花点心思研究）
项目地址：https://github.com/zeromicro/go-zero/blob/master/readme-cn.md go-nsq NSQ是一个基于Go语言的分布式实时消息平台，可用于大规模系统中的实时消息服务 项目地址：https://github.com/nsqio/go-nsq 学习地址：https://cloud.tencent.com/developer/article/1735996 Tidb Tidb
2.6K20编辑于 2022-07-11 - 来自专栏Golang语言社区
NSQ：分布式的实时消息平台--简介
收到的消息是无序的, 实现了松散订购 发现服务nsqlookupd具有最终一致性,消息最终能够找到所有Topic生产者 官方和第三方还为NSQ开发了众多客户端功能库，如官方提供的基于HTTP的nsqd、Go客户端go-nsq
1.6K60发布于 2018-03-22 - 来自专栏Golang语言开发栈
Golang 语言极简类型转换库 cast
推荐阅读： Golang 语言编写的消息队列 NSQ 官方客户端 go-nsq 怎么使用？ Golang 语言 gRPC 到底是什么？ Golang 语言中的 defer 怎么使用？
1.3K30发布于 2021-11-18 - 来自专栏Golang语言社区
NSQ：分布式的实时消息平台--简介
收到的消息是无序的, 实现了松散订购 发现服务nsqlookupd具有最终一致性,消息最终能够找到所有Topic生产者 官方和第三方还为NSQ开发了众多客户端功能库，如官方提供的基于HTTP的nsqd、Go客户端go-nsq
1.4K103发布于 2018-03-26
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号