【redis】redis 消息队列学习

  本站以分享各种运维经验和运维所需要的技能为主
  《python零底子入门》：python零底子入门学习
  《python运维脚本》： python运维脚本实践
  《shell》：shell学习
  《terraform》一连更新中：terraform_Aws学习零底子入门到最佳实战
  《k8》从问题中去学习k8s
  《docker学习》暂未更新
  《ceph学习》ceph日常问题办理分享
  《日记收集》ELK+各种中间件
  《运维日常》运维日常
  《linux》运维口试100问
  《DBA》db的介绍使用（mysql、redis、mongodb...）
   
一、redis消息队列

1.什么是消息队列

1. 在生活中，其实有很多的例子，都类似消息队列。
3. 比如：工厂生产出来的面包，交给超市，商场来出售，客户通过超市，商场来买面包，客户不会针对某一个工厂去选择，
4. 只管从超市买出来，工厂也不会管是哪一个客户买了面包，只管生产出来之后，交给超市，商场来处理。
6. 消息队列（Message Queue）是一种应用间的通信方式，消息发送后可以立即返回，有消息系统来确保信息的可靠传递，
7. 消息生产者只管把消息发布到消息队列中而不管谁来取，消息消费者只管从消息队列中取消息而不管谁发布的，这样发布者和使用者都不用知道对方的存在。

复制代码

2.为什么使用消息队列

1. 首先，我们可以知道，消息队列是一种异步的工作机制，比如说日志收集系统，为了避免数据在传输过程中丢失，还有订单系统，
2. 下单后，会生成对应的单据，库存的扣减，消费信息的发送，一个下单，产生这么多的消息，都是通过一个操作的触发，然后将其他的消息放入消息队列中，依次产生。
3. 再就是很多网站的，秒杀活动之类的，前多少名用户会便宜，都是通过消息队列来实现的。
5. 这些例子，都是通过消息队列，来实现，业务的解耦，最终数据的一致性，广播，错峰流控等等，从而完成业务的逻辑。

复制代码

3.消息队列产品

1. 1）rabbit-MQ（最初起源于金融系统，用于分布式系统中存储转发消息。OpenStack）
2. 2）Zero-MQ（SaltStack）
3. 3）Kafka（JAVA）
4. 4）redis（key:value数据库，缓存，消息队列）

复制代码

4.Redis发布消息-任务队列模式（queuing）

1. 任务队列：顾名思义，就是“传递消息的队列”。与任务队列进行交互的实体有两类，一类是生产者（producer），另一类则是消费者（consumer）。
2. 生产者将需要处理的任务放入任务队列中，而消费者则不断地从任务队列中读入任务信息并执行。
4. 任务队列的好处
5. 1）松耦合。
6. 生产者和消费者只需按照约定的任务描述格式，进行编写代码。
7. 2）易于扩展。
8. 多消费者模式下，消费者可以分布在多个不同的服务器中，由此降低单台服务器的负载。

复制代码

5.Redis发布消息-发布-订阅模式(publish-subscribe)

1. 其实从Pub/Sub的机制来看，它更像是一个广播系统，多个订阅者（Subscriber）可以订阅多个频道（Channel），多个发布者（Publisher）可以往多个频道（Channel）中发布消息。
3. 可以这么简单的理解：
4. 1）Subscriber：收音机，可以收到多个频道，并以队列方式显示
5. 2）Publisher：电台，可以往不同的FM频道中发消息
6. 3）Channel：不同频率的FM频道

复制代码

6.订阅模式实践

1）订阅单个频道

1. #第一个窗口，订阅一个频道
2. 127.0.0.1:6379> SUBSCRIBE gongsiqun
3. Reading messages... (press Ctrl-C to quit)
4. 1) "subscribe"
5. 2) "gongsiqun"
6. 3) (integer) 1
8. #第二个窗口向频道发布消息
9. 127.0.0.1:6379> PUBLISH gongsiqun 今晚大保健
10. (integer) 1
12. #回到第一个频道查看
13. 1) "message"
14. 2) "gongsiqun"
15. 3) "\xe4\xbb\x8a\xe6\x99\x9a\xe5\xa4\xa7\xe4\xbf\x9d\xe5\x81\xa5"

复制代码

2）订阅多个频道

1. #第一个窗口订阅多个频道
2. 127.0.0.1:6379> SUBSCRIBE gongsiqun jiatingqun
3. Reading messages... (press Ctrl-C to quit)
4. 1) "subscribe"
5. 2) "gongsiqun"
6. 3) (integer) 1
7. 1) "subscribe"
8. 2) "jiatingqun"
9. 3) (integer) 2
11. #第二个窗口向频道发布消息
12. 127.0.0.1:6379> PUBLISH gongsiqun jiwnandabaojian
13. (integer) 1
14. 127.0.0.1:6379> PUBLISH jiatingqun jinwanjiaban
15. (integer) 1
17. #回到第一个窗口查看
18. 1) "message"
19. 2) "gongsiqun"
20. 3) "jiwnandabaojian"
22. 1) "message"
23. 2) "jiatingqun"
24. 3) "jinwanjiaban"

复制代码

二、Redis事务

1.MySQL事务

1. #成功的事务
2. begin;
3. sql1;
4. sql2;
5. ...
6. commit;
8. #失败的事务
9. begin;
10. sql1;
11. sql2;
12. ...
13. rollback;

复制代码

2.redis事务下令

1. #1.开启事务
2. MULTI
3. ​
4. #2.结束事务（执行所有事务块内的命令）
5. EXEC
6. ​
7. #3.取消事务（放弃执行事务块内的所有命令）
8. DISCARD
9. ​
10. #4.监视一个(或多个) key，如果在事务执行之前这个(或这些) key 被其他命令所改动，那么事务将被打断。
11. WATCH
12. ​
13. #5.取消监控
14. UNWATCH

复制代码

3.事务的示例

1. #使用事务执行
2. 127.0.0.1:6379> MULTI
3. OK
4. 127.0.0.1:6379> set k100 v100
5. QUEUED
6. 127.0.0.1:6379> set k200 v200
7. QUEUED
8. 127.0.0.1:6379> get k200
9. QUEUED
10. 127.0.0.1:6379> EXEC
11. 1) OK
12. 2) OK
13. 3) "v200"
15. #事务取消
16. 127.0.0.1:6379> MULTI
17. OK
18. 127.0.0.1:6379> set k1 v1
19. QUEUED
20. 127.0.0.1:6379> set k2 v2
21. QUEUED
22. 127.0.0.1:6379> get k1
23. QUEUED
24. 127.0.0.1:6379> DISCARD
25. OK
26. 127.0.0.1:6379> keys *
27. (empty list or set)
29. #监控一个key
30. 127.0.0.1:6379> WATCH k1
31. OK
32. 127.0.0.1:6379> MULTI
33. OK
34. 127.0.0.1:6379> set k1 v1000000
35. QUEUED
37. #另一个窗口修改k1
38. 127.0.0.1:6379> set k1 00000
39. OK
41. #回到第一个窗口提交事务
42. 127.0.0.1:6379> EXEC
43. (nil)
44. 127.0.0.1:6379> get k1
45. "00000"

复制代码

4.注意

1. 1.redis只支持乐观锁
2. 2.事务在不使用watch监控时，谁后提交谁为准
3. 3.事务在使用watch监控时，谁先提交谁为准
4. 4.watch只监控一次事务并且是当前连接的事务

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。