项目功能-消息推送 (重点)

青旅半醒 2023-06-03 02:46 18阅读 0赞

![1552472-20190901185401869-53660420.png][]

*  RPC和消息队列的对比
    
     *  如果需要服务端立即返回结果, 最好使用RPC(效率高, 不需要中转)
     *  如果不需要服务端返回结果 或者 需要减轻生产者压力, 可以使用消息队列(消费者可以执行异步任务, 减轻同一时间服务器的并发压力)

## 将推送消息放入消息队列中 ##

![1552472-20190901185532540-752281247.png][]  
![1552472-20190901185538579-140345423.png][]

## 获取用户身份 ##

![1552472-20190901185607068-2011308682.png][]

## IM服务器从消息队列中获取数据 ##

![1552472-20190901185638981-1932520880.png][]

## IM ##

- 当用户连接IM时, 取出user_id, 并进入其user_id对应的房间
    - 从消息队列中取出关注通知

![1552472-20190901185703480-590920031.png][]

# 需求: 让用户id 和 sid进行绑定 # 1.获取用户id: 传递jwt # 2.绑定用户身份 from server import sio, JWT_SECRET from flask import Request def _get_user_id(token): # 取出用户id # 取出jwt中的数据 from jwt_util import verify_jwt payload = verify_jwt(token, secret=JWT_SECRET) if payload: return payload.get('user_id') else: return None @sio.on('connect') def on_connect(sid, envrion): request = Request(envrion) token = request.args.get('token') user_id = _get_user_id(token) # 用户一连接im服务器, 就让其进入自己的用户id对应的房间 room="2" print("进入房间: %s" % user_id) sio.enter_room(sid, str(user_id)) @sio.on('disconnect') def on_disconnect(sid): rooms = sio.rooms(sid) for room in rooms: # 断开连接, 离开所有的房间 sio.leave_room(sid, room)

## web服务器 ##

- 将关注通知放入消息队列, 消息发送给作者的user_id对应的房间

![1552472-20190901185724713-1318710462.png][]

*  细节
    
     *  测试 web应用必须使用生产模式,否则消息队列管理器会报错
 *  RabbitMQ `amqp://guest:guest@192.168.105.128:5672`

上线收到通知的逻辑
    1. 用户一旦连接IM, 
    1> 需要让user_id和sid建立关系
    2> 一旦离线就删除关系  
    3> 关系可以存在redis中
    
    2.web应用
    1> 从redis中取user_id对应的sid
    2> 如果能取出, 说明在线, 直接往消息队列中添加消息
    3> 如果不能取出, 说明离线, 将消息保存到redis中 
    
    3. im应用
    1> 一旦建立连接, 先从redis中查询是否有消息被保存
    2> 如果有,取出并发给客户端, 取出后从redis中删除数据
    3> 同时还需要从消息队列中实时取出消息数据

转载于:https://www.cnblogs.com/oklizz/p/11443186.html

[1552472-20190901185401869-53660420.png]: /images/20230601/36d8d8ed8be04741b2d396e354380693.png
[1552472-20190901185532540-752281247.png]: /images/20230601/8322281aa9af4b1b92e4a497fa7bed0f.png
[1552472-20190901185538579-140345423.png]: /images/20230601/fcb1002c6cf84c62830670bd4761bd9f.png
[1552472-20190901185607068-2011308682.png]: /images/20230601/b8ad0cb3608d479897cc4a840c181830.png
[1552472-20190901185638981-1932520880.png]: /images/20230601/cccc56f3eca74b97b0b1645f6aa6caa9.png
[1552472-20190901185703480-590920031.png]: /images/20230601/55092b5ec96c42eaacfbc44756c3b056.png
[1552472-20190901185724713-1318710462.png]: /images/20230601/90db9e5dcf144510992f835a886367de.png