golang - etcd消息队列queue,如何解决global的index增长?
本文介绍了golang - etcd消息队列queue,如何解决global的index增长?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
问 题
(初用etcd)我现在想用etcd 来做能阻塞的消息队列,文档里提到了queue,问题在于
"key": "/queue/00000000000000000029"
后的数字是根据index生成的,但index是个global的,这时我index+1后wait=true,
curl 'http://127.0.0.1:2379/v2/keys/queue/00000000000000000030?wait=true'
如果中图有其它key的操作,就会出现问题,这个应该怎么解决?
解决方案
从你描述分析,你的需求可能是两种情况:
一是分布式锁,拿到锁以后才能继续操作,实现全局顺序操作。
二是消息队列,多个生产者向队列写,一个消费者读,实现全局顺序操作。
如果是第二种需求,可以参考etcd的原文。
原文描述:
so the next key can be more than previous + 1.
To enumerate the in-order keys as a sorted list, use the "sorted" parameter.
curl -s 'http://127.0.0.1:2379/v2/keys/queue?recursive=true&sorted=true'
如果使用这种方式,建议使用V3版本,性能可能好一些。
这篇关于golang - etcd消息队列queue,如何解决global的index增长?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文