Go语言使用NSQ消息队列

Python013

Go语言使用NSQ消息队列,第1张

重点提示:

这样我们就启动了一个 nsqd 的实例

编写一个消息生产者

nsq_single_product.go

编写一个消息消费者

nsq_single_consumer.go

添加第一个实例

添加第二个实例

消息生产者

nsq_cluster_product.go

消息消费者

nsq_cluster_consumer.go

生产者消费者问题是一个著名的线程同步问题，该问题描述如下：有一个生产者在生产产品，这些产品将提供给若干个消费者去消费，为了使生产者和消费者能并发执行，在两者之间设置一个具有多个缓冲区的缓冲池，生产者将它生产的产品放入一个缓冲区中，消费者可以从缓冲区中取走产品进行消费，显然生产者和消费者之间必须保持同步，即不允许消费者到一个空的缓冲区中取产品，也不允许生产者向一个已经放入产品的缓冲区中再次投放产品。

golang 的channel天生具有这种特性，即

①缓冲区满时写，缓冲区空时读，都会阻塞。

②channel 本身就是并发安全的。

golang实现多生产者多消费者：

运行结果：

可以看出，用golang实现生产者消费者非常简单，PV操作不需要各种加锁解锁，奥妙就在于CSP模型，即golang提倡的用通信代替共享内存。