colindev / events Goto Github PK

• Auth operate
• Event operate

必須符合以下條件

1. 握手訊息為 client auth
2. server send connected 必須在頻道註冊完成之後

• client Conn.Auth -> hub.auth
• client conn pool 的 auth 行為

同步被跟隨者的連線紀錄

read

• conn.readLine

• conn.readLen

• conn.Receive

  • Reply
  • Err
  • Pong
  • Event

write

• conn.writeLen

• conn.writeEvent

• conn.Auth

• conn.Recover

• conn.RecoverSince

• conn.Subsceibe

• conn.Unsubscribe

• conn.Fire

• conn.Ping

• read only
• write only
• read write

以 auth 為握手協定
$name:flags

• server Conn.SetFlags / Conn.Weritable

include launcher

• Uncompress
• specify DSN

讓 log 比較好判斷

支援 轉接 redis server in / out

• 支援 fire flag
• 支援 recover flag
• 支援 auth / ghost connect

• 連線池縮放狀態

狀況說明

當斷線的 client 重新連上時且初始化偵聽頻到當下,會立刻收到當前的最新訊息
之後的 recover 命令無法改變前面已收到的訊息順序

作法

連線一段時間內替換 write buffer
等收到recover 請求後寫完再換回去

問題

具名連線時會造成訊息延遲感

評估

過往資料流與當前活躍資料在某個程度上並沒有相依關係

• 評估每秒可以收幾個簡單事件
• 100 個 listener 分別註冊 10 個頻道, 10 個 發送端 每秒一個 1mb 訊息

• client Conn.Auth -> hub.auth
• client conn pool 的 auth 行為

• makeEventStream
• parseLen
• parseEvent

• event.Join support
• hub.publish support

• parseEvent
• parseLen

• Conn.EachChannels
• Conn.Subscribe
• Conn.Unsubscribe
• Conn.IsListening
• Conn.Readline
• Conn.writeLen
• Conn.writeEvent
• Conn.writePong
• Conn.writeReply
• Conn.writeError

原本: >[n]

改為: >[n[:m]]

• Hub.auth
• Hub.quit
• Hub.quitAll
• Hub.publish
• Hub.recover
• Hub.publish / Hub.recover with concurrency

• client conn
• [ ] server hub 獨立寫
• server conn
• server store