rabbitmq使用

远程访问其他服务器的rabbitmq

1.先添加用户并分配角色

rabbitmqctl add_user lisi lisi123  // 设置用户名和密码
rabbitmqctl set_user_tags name administrator

2.用户授权

rabbitmqctl set_permissions -p / lisi ".*" ".*" ".*"

不然会引发异常：pika.exceptions.ProbaleAccessDeniedError

 

rabbitmq相关命令

rabbitmqctl add_user username password：添加用户

rabbitmqctl delete_user username：删除用户

rabbitmqctl list_users：列出所有用户

rabbitmqctl list_user_permissions username：列出用户权限

rabbitmqctl set_permissions -p vhostpath username ".*" ".*" ".*"：设置用户权限

rabbitmqctl clear_permissions -p vhostpath username：清除用户权限

rabbitmqctl change_password username newpassword：修改密码

rabbitmqctl add_vhost vhostpath：创建虚拟主机

rabbitmqctl delete_vhost vhostpath：删除虚拟主机

rabbitmqctl list_vhosts：列出所有虚拟主机

rabbitmqctl list_permissions -p vhostpath：列出虚拟主机上的所有权限 

rabbitmqctl status：节点状态
rabbitmqctl -p vhostpath purge_queue blue：清除队列里的消息

典型应用场景

1.异步处理

场景说明：用户注册后，需要发注册邮件和注册短信，传统的方法有两种 串行和并行

• 串行方式：将注册信息写入数据库后，发送注册邮件，再发送注册短信，以上三个任务全部完成后才返回给客户端。这有一个问题是：邮件，短信不是必须的，只是一个通知，这会让客户端等待没有必要等待的东西。

  

• 并行方式：将注册信息写入数据库后 ，在发送邮件的同时发送短信，以上三个任务完成后，返回给客户端，并行的方式能缩短处理的时间。

  

• 消息队列：假设三个业务节点分别使用50ms，则串行方式使用150ms，并行使用100ms。虽然并行已经缩短了处理的时间，但是前面说过，邮件和短信对我正常使用网站没有任何影响，客户端不必要等待其发送完成才显示注册成功，应该是写入数据库后就返回。引入消息队列后，把不是必须的业务逻辑异步处理。

  

由此可以看出，引入消息队列后，用户的响应时间就等于写入数据库的时间 + 写入消息队列的时间(可忽略)。

这里应该使用mq的广播模型，可以被多个消费者订阅，不同消费者实现各自的业务。

 

2.应用解耦

场景: 双11是购物狂欢节，用户下单后，订单系统需要通知库存系统，传统的做法就是订单系统调用库存系统的接口。

这种做法有个缺点：

当库存系统出现故障时，订单就会失败。订单系统和库存系统高耦合。

引入消息队列：

• 订单系统：用户下单后，订单系统完成持久化处理，再将消息写入消息队列，返回用户下单成功。

• 库存系统：订阅下单的消息，进行库操作，就算库存系统出现故障，消息队列也能保证消息的可靠投递，不会导致消息丢失。

 

3.流量削峰

场景：秒杀活动，一般会因为瞬间流量过大，导致应用挂掉，为了解决该问题，一般在业务模块前加入消息队列。

作用：

• 1.可以控制秒杀活动人数，超过此一定阈值的订单直接丢弃

• 2.可以缓解短时间的高流量压垮应用（应用能按自己最大处理能力获取订单处理）

过程：

1.用户的请求服务器收到之后，首先写入消息队列，加入消息队列的消息长度超过最大值，则直接抛弃用户请求或者跳转到错误页面。

2.秒杀业务根据消息队列中的请求信息，再做后续逻辑处理