struct redisServer {.../* Pubsub */?? dict *pubsub_channels;? /* Map channels to list of subscribed clients */存放<channel, list> list中是訂閱該pattern的client列表list *pubsub_patterns;? /* A list of pubsub_patterns */存放所有已訂閱的pubsubPattern結構體 ... };typedef struct redisClient {...??? dict *pubsub_channels;? /* channels a client is interested in (SUBSCRIBE) */存放該client定語的<channel, list> list是空。list *pubsub_patterns;? /* patterns a client is interested in (SUBSCRIBE) */存放該client訂閱的pattern；robj類型。... } redisClient;typedef struct pubsubPattern {redisClient *client;robj *pattern; } pubsubPattern;pubsubSubscribeChannel(redisClient *c, robj *channel)：該client訂閱該channel。 如果此前沒訂閱過， 則在redisClient::pubsub_channels中增加該channel、 同時在server::pubsub_channels的中增加該channel與client的相關信息 pubsubUnsubscribeChannel, pubsubSubscribeChannel的逆過程。pubsubSubscribePattern與channel類似，只不過是用list維護的<client, pattern> pubsubUnsubscribePattern， pubsubSubscribePattern的逆過程。pubsubPublishMessage(robj *channel, robj *message) 發布消息： 從server::pubsub_channels中找到該channel下的所有client，發消息。 并從server::pubsub_patterns下逐個檢查pattern是否匹配該channel， 匹配則給該client發消息。pattern使用list， channel使用dict， 是由于pattern可能是正則式，list順序遍歷簡單、dict無必要。取消過程中， 如果無訂閱了則刪除相關的pattern或者channel。

總結

以上是生活随笔為你收集整理的redis代码 发布订阅的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。