實現用戶微博的個人時間線和定制時間線：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62

imprort?redis class?TimeLine(object): ????"""用戶定制時間線和個人時間線""" ????def?__init__(self,?client): ????????self.client?=?client ????????? ????def?custom_push(self,?user_id,?msg_id,?time): ????????"""將微博推入到用戶定制的時間線中""" ????????custom_timeline_key?=?"weibo::user::"?+?str(user_id)?+?"::custom_timeline" ????????self.client.zadd(custom_timeline_key,?time,?msg_id) ????????? ????def?personal_push(self,?user_id,?msg_id,?time): ????????"""將微博推入到用戶的個人時間線中""" ????????personal_timeline_key?=?"weibo::user::"?+?str(user_id)?+?"::personal_timeline" ????????self.client.zadd(personal_timeline_key,?time,?msg_id) ????????? ????def?broadcast(msg_id,?time,?*fans_ids): ????????"""將微博推入所有粉絲的定制時間線中""" ????????for?fans?in?fans_ids: ????????????self.custom_push(fans,?msg_id,?time) ????????? ????def?custom_paging(self,?user_id,?n): ????????"""獲取用戶定制時間線第n頁的微博""" ????????count?=?5??#?5條數據為一頁 ????????custom_timeline_key?=?"weibo::user::"?+?str(user_id)?+?"::custom_timeline" ????????start_index?=?(n-1)?*?count??#?起始索引 ????????end_index?=?n*count?-?1??#?結束索引 ????????return?self.client.zrevrange(custom_timeline_key,?start_index,?end_index) ????????? ????def?personal_paging(self,?user_id,?n): ????????"""獲取用戶個人時間線第n頁的微博""" ????????count?=?5??#?5條數據為一頁 ????????personal_timeline_key?=?"weibo::user::"?+?str(user_id)?+?"::personal_timeline" ????????start_index?=?(n-1)?*?count??#?起始索引 ????????end_index?=?n*count?-?1??#?結束索引 ????????return?self.client.zrevrange(personal_timeline_key,?start_index,?end_index) if?__name__?==?"__main__": ??redis_client?=?redis.StrictRedis()???????? ??msg?=?Message(redis_client) ??message_id,?weibo_timestamp?=?msg.create(10086,?"hello?world") ??#?print("message_id:",?message_id) ??#?print("weibo_timestamp:",?weibo_timestamp) ??tl?=?TimeLine(redis_client) ??tl.custom_push(10086,?message_id,?weibo_timestamp) ??tl.personal_push(10086,?message_id,?weibo_timestamp) ??relation?=?RelatoinShip(redis_client) ??fans_dict?=?relation.get_all_fans(10086) ??if?fans_dict?==?False: ??????print("沒有粉絲") ??else: ??????fans_list?=?list() ??????for?fans?in?fans_dict: ??????????fans_list.append(fans.decode()) ??????tl.broadcast(message_id,?weibo_timestamp,?*fans_list) ????????? ??print(tl.custom_paging(10086,?1)) ??print(tl.personal_paging(10086,?1))

????什么是用戶個人的微博時間線和定制的微博時間線呢？用戶微博定制時間線包含了用戶自己以及用戶正在關注的人所發布的微博，我們用"weibo::user::<id>::custom_timeline"這個有序集合鍵保存；用戶個人微博時間線，只包含用戶自己發送的微博，我們用"weibo::user::<id>::personal_timeline"這個有序集合鍵保存。

????????每條時間線都是一個有序集合，有序集合的元素是所發布微博的ID，分值為微博發布的時間。每當用戶發送新的微博時，redis用zadd將新微博的時間和id添加到有序集合中。

????????當然我們不能漏了廣播操作，即每當用戶發送一條新的微博時，redis不僅要將這條微博推入該用戶的定制時間線和個人時間線，還需要將這條微博推入到該用戶的所有粉絲的定制時間線中。

????????在上面的代碼中，我們使用了之前已經定義好的Message類來生成一條微博消息，再使用RelationShip類來實現向所有的粉絲的定制時間線推送微博信息。

本文轉自戴柏陽的博客博客51CTO博客，原文鏈接http://blog.51cto.com/daibaiyang119/1963053如需轉載請自行聯系原作者

daibaiyang119

總結

以上是生活随笔為你收集整理的Redis实现微博后台业务逻辑系列（六）的全部內容，希望文章能夠幫你解決所遇到的問題。

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