imxyb

NSQ是一个内存+磁盘型的消息中间件，它使用push流的方式源源不断把消息推送给客户端，并且为了使服务端更加简单、高效，NSQ并不提供有序的消息队列。因此，如果对消息有顺序要求，只有两种解决办法： 改用类似kafka之类的有序消息队列； 生产者和消费者达成一个协议，比如增加一个序列号或者时间戳来表示顺序。 本文要介绍的是第二种方法，下面就来简单用golang实现一个有序的NSQ顺序消息队列。 首先，使用go-nsq客户端写一个main函数，并且连接上nsqlookupd： func main()...