對(duì)于(社交軟件類)群消息来候,一般分為寫擴(kuò)散和讀擴(kuò)散
1? ? 寫擴(kuò)散
? ? ? ? 當(dāng)群里有一個(gè)人發(fā)送消息的時(shí)候,服務(wù)端收到消息后逸雹,先在群的消息表記錄一條數(shù)據(jù)营搅,在查出群里的人,向每個(gè)人的消息表插入一條未讀的數(shù)據(jù)梆砸,如果用戶在線转质,則把這條消息推送給用戶,并且在更新個(gè)人的消息表帖世,把這個(gè)消息置為已讀休蟹。當(dāng)用戶上線時(shí)候,直接拉去自己的消息表日矫,把未讀的消息按照全量給或者分頁給的方式響應(yīng)給用戶赂弓,并且把消息置為已讀。
? ? ? ? 這種情況哪轿,用戶發(fā)送的消息盈魁,需要保存兩份,特別是大文本消息窃诉,msg_deatail在群消息表和個(gè)人消息表都存了一分杨耙,對(duì)于個(gè)人消息表設(shè)計(jì)還要考慮群消息,不過一個(gè)儲(chǔ)存消息這種飘痛,不會(huì)采用關(guān)系型數(shù)據(jù)庫珊膜,可以考慮用非關(guān)系的數(shù)據(jù)庫,盡量冗余多一點(diǎn)字段敦冬,減少表與表的關(guān)聯(lián)關(guān)系辅搬,最好是沒有,只做單表查詢脖旱。
2? ? 讀擴(kuò)散
? ??????當(dāng)群里有一個(gè)人發(fā)送消息的時(shí)候堪遂,服務(wù)端收到消息后,先在群的消息表記錄一條數(shù)據(jù)萌庆,在查出群里的人溶褪,遍歷每個(gè)人,判斷是否在線践险,如果在線猿妈,就把該消息推送給用戶吹菱,并且更新用戶對(duì)于群消息的已讀下標(biāo)位,當(dāng)用戶不在線彭则,就什么也不做鳍刷,用戶從下線變成上線,拉去群消息時(shí)俯抖,現(xiàn)需要查自己的群消息下標(biāo)位输瓜,然后再遍歷自己加入的群,獲取是否有最新的群消息芬萍,如果有尤揣,則取出來,最后響應(yīng)給用戶
? ? ? ? 這種情況柬祠,用戶發(fā)送的消息北戏,只是在群消息表保存了一份,針對(duì)于在線的用戶才做了群消息下標(biāo)位的更新漫蛔,相當(dāng)于每個(gè)人每個(gè)群在這個(gè)表里面只會(huì)存在一條記錄嗜愈,后面的群消息,只是更新下標(biāo)位惩猫,相比于寫擴(kuò)散芝硬,多了查詢時(shí)候的復(fù)雜度蚜点,寫擴(kuò)散轧房,用戶拉去離線的群消息,只需要查自己的個(gè)人消息表绍绘,而讀擴(kuò)散奶镶,則需要查兩個(gè)表,群消息下標(biāo)位表陪拘,群消息表厂镇,也只能是遍歷去查詢?nèi)合⒈恚ㄟ@塊可以考慮用線程池去做左刽,各個(gè)群消息查詢相互獨(dú)立捺信,不影響)。
對(duì)于(直播類)房間消息欠痴,用讀擴(kuò)散最好
這種情況下迄靠,類似于用戶的臨時(shí)會(huì)話,一個(gè)用戶只能在一個(gè)房間里喇辽,用戶的狀態(tài)掌挚,要么在房間里,要么離開了房間菩咨,當(dāng)房間有新的消息時(shí)吠式,可以去redis中查房間下有多少用戶陡厘,向每個(gè)用戶推送消息,并且異步向數(shù)據(jù)庫寫入一條房間消息做備案特占,用戶收到消息時(shí)糙置,也查詢自己的數(shù)據(jù),做去重操作是目,如果不是重復(fù)的消息罢低,就加入消息表,并向UI展示這條消息胖笛,重復(fù)的消息网持,什么也不做,用戶向上拉去的時(shí)候长踊,不用再請(qǐng)求服務(wù)器功舀,直接查詢自己的消息表,如果離開房間身弊,可以考慮本地清除這個(gè)房間的消息