golang-nsq消息队列应用
2024-08-27 07:51:15
1. 安装nsq
brew install nsq
2.启动nsq
https://nsq.io/overview/quick_start.html
3.golang client
var producer *nsq.Producer
var consumer *nsq.Consumer type t struct { } func (this *t)HandleMessage(message *nsq.Message) error{
fmt.Println(string(message.Body))
return nil
}
func init() { producer,_ = nsq.NewProducer("127.0.0.1:4150",nsq.NewConfig()) // 初始化生产者
consumer,_ = nsq.NewConsumer("fwd","ch1",nsq.NewConfig())
consumer.AddHandler(new(t))
consumer.ConnectToNSQD("127.0.0.1:4150")
}
func main() { go func() { }()
for{
time.Sleep(time.Second)
producer.Publish("fwd",[]byte("哈哈哈哈哈"))
} }
输出:
2018/07/30 12:14:27 INF 2 [fwd/ch1] (127.0.0.1:4150) connecting to nsqd
2018/07/30 12:14:28 INF 1 (127.0.0.1:4150) connecting to nsqd
哈哈哈哈哈
哈哈哈哈哈
哈哈哈哈哈
最新文章
- 「视频直播技术详解」系列之七:直播云 SDK 性能测试模型
- RCF进程间通信Demo程序
- 继续送假期干货——响应式图片工具smartImg
- php示例代码之类似于C#中的String.Format方法
- FL2440驱动添加(3)LCD驱动添加学习笔记
- ThinkPHP讲解(二)控制器
- 使用dom4j技术对xml文件的基本操作
- android Loger日志类(获取内置sd卡)
- css考核点整理(十一)-响应式开发经验,响应式页面的三种核心技术是什么
- Java中@Deprecated、@SupressWarning、@Override的作用
- 怎样使用jsp实现header和footer与网页内容的分离
- Android WebView中显示一张或多张图片
- oracle数据库冷备中的手工备份和恢复
- javaScript(1)---概述
- Java操作Memcached
- Delphi调用API函数获取Windows目录信息、获取System目录信息、获取Temp临时文件目录信息
- redux源码图解:createStore 和 applyMiddleware
- git常用方法
- ORA-30377 MV_CAPABILITIES_TABLE not found
- 【python3+request】python3+requests接口自动化测试框架实例详解教程