接下來 先講講服務端的吧

代碼部分解析

這里兩個類都要引用 KGSocket dll的

1.ChatNetData 建立一個 客戶端 服務端共用的數(shù)據(jù) 類庫 因為要互相傳的所以肯定要統(tǒng)一

1.png

導出的dll Unity 才能用

2.png

里面就是一些數(shù)據(jù)結(jié)構(gòu)了
網(wǎng)絡消息自定義類 要繼承KGNetData 打上Serializable 序列化標簽
枚舉那些因為沒辦法序列化所以用Int的代替然后接收到再強轉(zhuǎn)回來

using KGSocket;
using System;

namespace ChatNetData
{
    [Serializable]
    public class ChatDatas:KGNetData
    {
        public byte[] HeadData;

        public string PlayerName;

        public SendChat Chatdata;
    }
}

namespace ChatNetData
{

    public enum CMD
    {
        None,
        ReqLogin,
        ReqChatInfo,

        RspLogin,
        RspChatInfo,

    }
}

namespace ChatNetData
{
    public enum ErrorInfo
    {
        None,
        NameRepeatsErr,//名字重復登錄錯誤指令
    }
}

using System;

namespace ChatNetData
{
    [Serializable]
    public  class SendChat
    {
        public string chat;
        public int Islocal;
    }
}

2.ChatDatasPack 用于分辨數(shù)據(jù)是哪個客戶端發(fā)定的數(shù)據(jù)類型**

using ChatNetData;

namespace ChatServer
{
    public class ChatDatasPack
    {
        public ChatSession chatSession;

        public ChatDatas chatDatas;

    }
}

using ChatNetData;

namespace ChatServer
{
    public class ChatDatasPack
    {
        public ChatSession chatSession;

        public ChatDatas chatDatas;

    }
}

3.ChatSessio 每個客戶端的通信都是他來操作**

要繼承KGNetSession<ChatDatas> ChatDatas就是自己定義繼承KGNetData的數(shù)據(jù)類

這里主要的就是 OnDisRecive 斷開回調(diào) ，OnReciveData接收到數(shù)據(jù)回調(diào) OnStartRecive 連接成功回調(diào)

OnReciveData(ChatDatas data) 接收到數(shù)據(jù)會 new一個ChatDatasPack 賦值 添加到ChatServe的任務隊列 排序處理

using KGSocket;
using ChatNetData;

namespace ChatServer
{
    public class ChatSession : KGNetSession<ChatDatas>
    {

        public int SessionID = 0;
public string PlayerName;//緩存用戶的名字public byte[] HeadData;//緩存用戶的頭像圖片數(shù)據(jù)

        protected override void OnDisRecive()
        {
            ("名字：" + PlayerName + "已下線").KLog();

        }
        protected override void OnReciveData(ChatDatas data)
        {
            ("收到名字：" + data.PlayerName + "的請求"+(CMD)data.Cmd).KLog();
            ChatServe.Instance.AddDataPackQue(this,data);
        }

        protected override void OnStartRecive()
        {
            SessionID = ChatServe.Instance.GetSessionID();
            ("ID：" + SessionID + "已連接").KLog();

        }
    }
}

4.ChatServe 這個就是創(chuàng)建服務器socket的了 緩存客戶端 處理接收各個客戶端信息返回的業(yè)務邏輯

要繼承KGSocketServe<ChatSession, ChatDatas>

這里AddDataPackQue 就是添加接收到的消息任務隊列的，會用到一個線程鎖，
lock 這里簡單說一下 作用是被lock的對象，里面的語句塊 一次只被一個線程使用 如果在使用中的 其他線程就會排隊等待執(zhí)行完再輪到下一個 不會出現(xiàn)一窩蜂調(diào)用 順序錯亂情況
添加完后 在Update() 這里進行出列調(diào)用 主線程那邊就可以直接一直調(diào)用Update一直刷新有沒有新的任務隊列就好
然后DisposePack這里就是處理從客戶端接收到的數(shù)據(jù)了 判斷指令調(diào)用對應業(yè)務邏輯

using System.Linq;

using KGSocket;
using ChatNetData;

namespace ChatServer
{
    public class ChatServe : KGSocketServe<ChatSession, ChatDatas>
    {
        private static ChatServe instance;
        public static ChatServe Instance
        {
            get
            {
                if (instance == null)
                {
                    instance = new ChatServe();
                }
                return instance;
            }
            set => instance = value;
        }

        public static readonly object obj = "lock";

        public Queue<ChatDatasPack> DataPackQue = new Queue<ChatDatasPack>();

        #region 緩存
        private int SessionID = 0;

        public int GetSessionID()
        {
            if (SessionID == int.MaxValue)
            {
                SessionID = 0;
            }
            return SessionID += 1;
        }

        public bool IsUserOnLine(string name)
        {
            return SessionList.Select(v=>v.PlayerName).ToList().Contains(name) ;
        }

        #endregion

        public void Update()
        {
            if (DataPackQue.Count>0)
            {
                lock (obj)
                {
                    DisposePack(DataPackQue.Dequeue());
                }
            }
        }

        public void DisposePack(ChatDatasPack pack)
        {
            switch ((CMD)pack.chatDatas.Cmd)
            {
                case CMD.ReqLogin:
                    //判斷在線的名字是否重復
                    if (IsUserOnLine(pack.chatDatas.PlayerName))
                    {
                        pack.chatDatas.Err = (int)ErrorInfo.NameRepeatsErr;
                    }
                    else
                    {
                        pack.chatSession.PlayerName = pack.chatDatas.PlayerName;
                        pack.chatSession.HeadData = pack.chatDatas.HeadData;
                        pack.chatDatas.Cmd = (int)CMD.RspLogin;

                    }

                    pack.chatSession.SendData(pack.chatDatas);

                    break;
                case CMD.ReqChatInfo:
                    pack.chatDatas.Cmd = (int)CMD.RspChatInfo;
                    pack.chatDatas.HeadData = pack.chatSession.HeadData;
                    pack.chatDatas.PlayerName = pack.chatSession.PlayerName;
                    //發(fā)回給自身聊天
                    pack.chatSession.SendData(pack.chatDatas);
                    //改成對方
                    pack.chatDatas.Chatdata.Islocal = 1;
                    //分發(fā)到各個客戶端 聊天消息
                    SessionList.Where(v=>v!=pack.chatSession).ToList().ForEach(v=> 
                    {
                        v.SendData(pack.chatDatas);
                    });
                    break;
            }
        }
        public void AddDataPackQue(ChatSession session, ChatDatas chatData)
        {
            lock (obj)
            {
                DataPackQue.Enqueue(new ChatDatasPack { chatSession = session, chatDatas = chatData });
            }
        }

    }
}

https://github.com/LKaiGuo/KGScriptGenerator 喜歡的給我點個星星啊
u3d萌新QQ群844087555 歡迎進來灌水=。=