關(guān)于持久化到Redis的消息格式，主要是說(shuō)在Broker上把消息持久化的過(guò)程中，需要存儲(chǔ)哪些類(lèi)型的消息，因?yàn)槲覀兊南⑹欠謙opic的，而每個(gè)topic又有若干個(gè)queue組成，而我們的topic和queue由于redis存儲(chǔ)結(jié)構(gòu)的原因，我們需要將它們分區(qū)對(duì)應(yīng)存儲(chǔ)一下，而不能像關(guān)系型數(shù)據(jù)庫(kù)那樣靈活，所以要額外設(shè)計(jì)幾個(gè)數(shù)據(jù)結(jié)構(gòu)來(lái)存儲(chǔ)它們。
一 Topic字典
二 Topic對(duì)應(yīng)的Queue字典
三 Queue里的消息
四 某個(gè)客戶(hù)端對(duì)應(yīng)某個(gè)Queue的消費(fèi)進(jìn)度
以上四個(gè)結(jié)構(gòu)是我們要說(shuō)的，它們會(huì)在推消息，拉消息，刪消息時(shí)用到，下面一一介紹一下，講的不好不對(duì)的地方，歡迎大家為大叔留言。
一 Topic字典
主要存儲(chǔ)每個(gè)topic，它是一個(gè)set集合，redis的我集合類(lèi)型之一，每個(gè)key是唯一的LindMq_Topic，值value就是我們客戶(hù)端傳來(lái)的具體topic的名字，這主要是在刪除過(guò)期的消息時(shí)用的，主是作用是遍歷所有的topic消息類(lèi)型，這樣我們?cè)趧h除消息時(shí)，就可以把所有注冊(cè)的topic都找到了，最后把過(guò)期的刪除，默認(rèn)消息存活周期是一天。
