實現過程全紀錄——本身寫一個「微信朋友圈」（包括移動端與PC端）

時間 2019-12-07

標籤實現過程紀錄本身一個微信朋友包括移動欄目無線简体版

原文原文鏈接

一.朋友圈的基本單元——動態

首先定義一個自定義控件用來顯示每條動態。html

二.運行效果

三.核心解讀

PushedMessage 有個PushIndex屬性，表示發送消息的index，從0開始遞增。每一個人Push的index都是從0開始，ResponseMoments 的 MessageList 是個字典，Key表示 index。sql

        //
        // 摘要:
        //     拉取個人朋友們發的消息。當收到服務器回覆，將觸發ResponseMomentsReceived事件。
        //
        // 參數:
        //   startPullIndex:
        //     從哪一個index的消息開始拉取（不包含該index對應的那條）。若是startPullIndex小於0，表示拉取最新的N條。
        //
        //   latest:
        //     latest爲true，表示拉取更新的（大於startPullIndex）；爲false表示拉取以前的（小於startPullIndex）。
        void Pull(long startPullIndex, bool latest);
        //
        // 摘要:
        //     拉取目標用戶所發的消息。當收到服務器回覆，將觸發ResponseMomentsReceived事件。
        //
        // 參數:
        //   ownerID:
        //     所要拉取的目標用戶的ID
        //
        //   startPushIndex:
        //     從哪一個index的消息開始拉取（不包含該index對應的那條）。若是startPushIndex小於0，表示拉取最新的N條。
        //
        //   latest:
        //     latest爲true，表示拉取更新的（大於startPullIndex）；爲false表示拉取以前的（小於startPullIndex）。
        void Pull(string ownerID, long startPushIndex, bool latest);

當調用這個方法時，表示獲取個人朋友們的動態，我朋友們的動態會排序，index就是用這個key表示的。數據庫

latest 參數表示是下拉，仍是上拉。編程

四.DynamicsLoader解讀

DynamicsLoader中最主要的是Load方法。服務器

  public void Load(Dictionary<long, PushedMessage> currentMessageList, FlowLayoutPanel flowLayoutPanel, IMomentsClient client)
        {
            this.preLastIndex = this.lastIndex;
            foreach (var item in currentMessageList)
            {
                if (this.firstIndex < 0)
                {
                    this.firstIndex = item.Key - currentMessageList.Count + 1;
                }
                if (item.Key < this.firstIndex)
                {
                    this.firstIndex = item.Key;
                }
                if (item.Key > this.lastIndex)
                {
                    this.lastIndex = item.Key;
                }
                if (!this.messageList.ContainsKey(item.Key))
                {
                    this.messageList.Add(item.Key, item.Value);
                }
            }
            this.freeIndex = this.lastIndex - 20;

            if ((this.lastIndex - this.preLastIndex) > 39)
            {
                this.firstIndex = this.lastIndex - currentMessageList.Count + 1;
                this.preLastIndex = this.firstIndex;
                this.freeIndex = this.preLastIndex;
                this.messageList.Clear();
                this.messageList = currentMessageList;
            }
            this.listIndex = new List<long>((IEnumerable<long>)this.messageList.Keys);
            this.listIndex.Sort();
            flowLayoutPanel.Controls.Clear();           
            foreach (var item in this.listIndex)
            {
                DynamicsControl crl = new DynamicsControl();
                crl.Initialize(this.messageList[item].OwnerID, Encoding.UTF8.GetString(this.messageList[item].Content), this.messageList[item].PushTime);
                flowLayoutPanel.Controls.Add(crl);
                flowLayoutPanel.Controls.SetChildIndex(crl, 0);            
            }
            this.listIndex.Clear();
            this.listIndex = null;
            if (this.isUp)
            {
                if (flowLayoutPanel.Controls.Count != 0)
                {
                    flowLayoutPanel.ScrollControlIntoView(flowLayoutPanel.Controls[0]);
                }              
            }
            else
            {
                if (flowLayoutPanel.Controls.Count != 0)
                {
                    flowLayoutPanel.ScrollControlIntoView(flowLayoutPanel.Controls[flowLayoutPanel.Controls.Count - 1]); 
                }       
            }          
            if (currentMessageList.Count == 0)
            {
                return;
            }
            if ((this.lastIndex - this.preLastIndex) < 20)
            {
                return;
            }
            do
            {
                client.Pull(this.freeIndex, false);
                this.freeIndex -= 20;
            }
            while (this.freeIndex > this.preLastIndex);
        }

正如前面所言，每一條動態都有一個index，那麼我每次獲取動態的時候，就須要保留一個最小的索引，用於下拉的時候使用；保留一個最大的索引，用於上拉的時候使用。當最新的動態比本地的動態多出20條以上時，則分爲兩種狀況：1.兩次能夠加載完的就加載兩次，2兩次沒法加載完的，就只加載最新的20條，並將本地舊動態所有刪除。網絡

五.移動端如何通訊

一.消息編解碼整體策略

NPush默認使用緊湊的序列化器，其遵循的策略以下：
字符串一概使用UTF-8編碼。若是是基礎數據類型，則直接記錄其字節。
若是是bool，則用一個字節表示，0表示false，1表示true。
若是是string，先記錄其長度(int，-1表示爲null，0表示string.Empty)，再記錄UTF8編碼的字節。
若是是byte[]，先記錄其長度(int，-1表示爲null)，再記錄其內容。
若是是Image ，先記錄其長度(int，-1表示爲null)，再記錄是否爲Gif（一個byte），再記錄序列化內容。
若是是Color ，長度固定爲3個字節，一次記錄R/G/B的值。
若是是List<>，先記錄元素數(int，-1表示爲null)，再依次記錄每一個元素的內容。
若是是Dictionary<,>，先記錄元素對的個數(int，-1表示爲null)，再依次記錄每一個元素的Key,Value。
若是是自定義的class和struct，則先記錄其序列化的長度(int，-1表示爲null)，再記錄其序列化後的內容分佈式