【开源中国 APP 全新上线】“动弹” 回归、集成大模型对话、畅读技术报告”
是这样,消息队列负责存储一些信息,然后用来持久化到数据库,主要用来解决高并发下减轻数据库的压力以及解决线程阻塞问题,而redis的pub/sub功能主要用来发布和订阅消息,而且消息是瞬时的,实在想象不到它和队列有什么关系。。现在假设我要解决一个抢红包的高并发的问题,我只需要让点击红包的用户存进redis的一个list里面,然后单开一个线程不断从list中读取数据进行持久化就行了,这样实现了队列功能,也解决了线程阻塞和数据库压力问题,和消息的发布订阅也没什么关系啊,难道是我理解有误?如果是这样,请大神指点,就以抢红包大并发为例,谢谢!
不知道LZ是在哪看到把发布/订阅和消息队列联系在一起的。
redis的发布/订阅, 是一种消息通信模式,一般可以用于及时通信系统,比如聊天室,实时提醒。主要是为了解耦消息发布者和消息订阅者之间的耦合。
就像你说的消息是瞬时的,来一个就要处理一个,在大并发下,并没有解决线程堵塞和数据库压力问题。
如果简单的消息队列,可以用redis的list结构处理, 或者选用专门的像rabbitmq等这样的
以上,纯属个人理解,有问题请告诉我,,,
这里边你所谓的单独起一个线程,实际上实现的就是监听嘛,消息发布者实际就是你在往队列里面压数据,而消息订阅者就是你写的线程来读取。
所以,这里面,队列是一种数据结构,而你所说的发布者/订阅者其实就是想要做的事的一种模式,通过队列来进行存储实现了,也不一定非用队列的,用SortSet进行值排序,一样可以称之为队列。
用@scheudle去轮询redis吧。这也是订阅的一种方式。
订阅发布个人感觉更多的会用在限流时的消息中间件的消息处理场景中