PHP即時通信設計實現

詳解即時通信設計實現(PHP+GatewayWorker+Redis)

須要實現的功能

  • 一對一聊天(私聊)
  • 一對多聊天(羣聊)
  • 相似QQ,微信等聊天列表 實時消息 顯示

工具選擇

  • GatewayWorker 有以下特性(更多請參考官網手冊)php

    • 基於Workerman開發
    • 基於Gateway、Worker進程模型
    • 支持分佈式部署
    • 支持高併發
    • 支持全局廣播或者向任意客戶端推送數據
    • 支持各類應用層協議
    • 多協議支持
    • 支持對象或者資源永久保持
    • 高性能
    • 方便與其它項目集成
    • 支持長鏈接
咱們主要使用它的WebSocket通信協議,而且此框架很是方便的與 ThinkPHP,laravel 等框架結合使用,GatewayWorker可獨立部署,php負責相關的業務邏輯
  • Redis 鍵值操做,集合列表等。
即時通信中,最重要的是響應速度,咱們須要展現 「消息列表」 那麼這時會有 未讀消息,未讀數量,最後一條消息內容,時間等等。

websocket與GatewayWorker 原理使用 將再也不敘述,不懂的童鞋 請上度娘

效果展現

羣聊|私聊效果圖laravel

mahua

消息列表效果圖web

mahua

數據庫設計(羣聊,私聊 分開)

私聊設計(簡要設計)


參數名 說明
id 主鍵
sender_id 發送者id
receive_id 接收者id
chat_identify 標識 :a與b聊天,b與a聊天。記錄 a-b
message_details 消息內容
last_time_at 聊天時間間隔 超過必定時間時記錄
  • chat_identify 字段用處,這個字段是爲了更方便的查找 a,b 之間的聊天記錄。
  • last_time_at QQ,微信聊天記錄之間,隔一段時間會有 時間 記錄,並不顯示每一條聊天記錄的時間

羣聊(簡要設計)

  • 與私聊很像,只不過接收者id,變成 group_id 羣組id。

消息列表設計,但願看到的效果是 「私聊,羣聊」等都在一個列表展現,而且數據實時發生變化。這裏藉助Redis

每一個用戶的列表都是一個集合 key = message_list:user_id
Redis集合存儲 消息類型 1私信,2羣聊

message_list:user_id{
    json_encode(['消息類型','接收者id|羣組id']),
    json_encode(['消息類型','接收者id|羣組id']),
    json_encode(['消息類型','接收者id|羣組id']),
}

查找每一個人的消息列表,直接取出該列表便可,但每一個成員 都要對應 ‘未讀消息數量’,‘最後一條消息內容’,‘最後一條小時時間’。因爲是可變的,因此須要單獨存儲

Redis 鍵值 key = message_content:user_id_消息類型_id

key =>json_encode(['消息數量','最後一條消息內容','時間'])

上面 集合列表裏的每個成員都 對應這裏的每一個鍵值。
  • 消息更新都要操做Redis,相應的更新內容。
  • 速度上 毋庸置疑,redis 至關的迅速。

須要後續優化的地方

  • 私聊|羣聊 記錄表。目前設計是單表單庫。顯然,隨着用戶量增長,必然爆棚。影響查詢的響應速度。redis

    • (解決方案無非:分庫分表,轉移備份歷史記錄)
  • GatewayWorker 通信框架,是單服務器部署,不能支持過高的併發。

這裏只是對 即時通信 設計上作了一些簡要的闡述,若有疑問和建議,請在評論區回覆。

相關文章
相關標籤/搜索