2. 程式人生 > >一步一步開發Game伺服器（二）完成登陸，聊天

一步一步開發Game伺服器（二）完成登陸，聊天

阿新 • • 發佈：2018-12-30

我知道這樣的文章在部落格園已經多的大家都不想看了，但是這是我的系列文章開始，請各位大神見諒了。

多執行緒，執行緒執行器，（詳見），socket通訊相關 （詳見）

本人blog相關文章測試程式碼，示例，完整版svn地址。（http://code.taobao.org/svn/flynetwork_csharp/trunk/Flynetwork/BlogTest）

提供全部原始碼功能塊。希望各位大神，提供寶貴意見。

莫倩，完成了多執行緒輔助類庫完整功能（或許後期會有bug需要修復或者優化），socket完成了tcp和http服務監聽功能，udp和websocket還在完善的狀態中。

如果有通訊願意和我一起完善這個輔助類庫，請聯絡我，開通svn授權。

所以原始碼免費提供使用，歡迎各位愛好者，加入到專案中，無論是個人，企業，商用，都不限制。唯一要求請保留以下字樣。謝謝合作~！

1 /**
2  * 
3  * @author 失足程式設計師
4  * @Blog http://www.cnblogs.com/ty408/
5  * @mail [email protected]
6  * @phone 13882122019
7  * 
8  */

好了開始我們的話題

在伺服器專案開發中，最總要的也就是登陸問題了或者說叫授權問題。

我們先建立一個console的程式

引用我的兩個庫 Sz.Network.SocketPool ，Sz.Network.ThreadPool 分別是socket 幫助庫執行緒幫助庫。

Sz表示失足的意思。請見諒。偶喜歡上這個代號了“失足程式設計師”

我們先建立一個訊息處理器 MessagePool

 1  public class MessagePool : ISocketPool
 2     {
 3         public void ActiveSocket(IOSession client)
 4         {
 5         }
 6 
 7         public void CloseSocket(IOSession client)
 8         {
 9             
10         }

 
11 
12         public void ReadMessage(IOSession client, SocketMessage message)
13         {
14             
15         }
16 
17 
18         public void ActiveHttp(HttpClient client, string bind, Dictionary<string, string> parms)
19         {
20             if (bind.Equals("/test/"))
21             {
22                 ThreadManager.GetInstance.AddTask(ServerManager.LoginThreadID, new LoginHttpHandler(client, parms));
23             }
24         }
25 
26         public void IOSessionException(IOSession client, Exception exception)
27         {
28             Logger.Error("內部錯誤", exception);
29         }
30 
31         public void HttpException(HttpClient client, Exception exception)
32         {
33             Logger.Error("內部錯誤", exception);
34         }
35     }
View Code

然後在mian函式裡面加入

1  Sz.Network.SocketPool.ListenersBox.GetInstance.SetParams(new MessagePool(), typeof(MarshalEndian));
2             Sz.Network.SocketPool.ListenersBox.GetInstance.Start("tcp:*:9527", "http://*:8001/test/");

這樣我們就開啟了伺服器的監聽，這裡簡單介紹一下為什麼我建立了tcp和http的兩個監聽呢？

這是因為經驗和工作關係，因為我是致力於遊戲開發的，伺服器端需要建立兩個tcp通常是用於正常通訊的，而http監聽的登陸模組，或者一些非總要性資料交換以及第三方登陸授權需要開啟的。同樣還因為http是短連線，無需儲存通訊物件，減少了系統消耗，和tcp數量級消耗。

如果你不理解可以不加入http的監聽的。直接看tcp的socket。

1 [2015-04-15 18:12:09:899：Info ] Start Listen Tcp Socket -> 0.0.0.0:9527
2 [2015-04-15 18:12:09:906：Info ] Start Listen Http Socket -> 0.0.0.0:8001/test/

執行程式，輸出。

開啟了tcp和http的監聽，http我們今天暫時忽略其作用吧。

我們開始準備登陸模組的開發，同學都知道登陸首先要面臨的就是多點同時登陸問題。

如果加入 lock 來防止多點同時登陸，那麼勢必照成伺服器卡頓。吞吐量不高等因素。那麼我們考慮把這一塊加入到單獨的執行緒驚喜處理。也就是幫登陸和登出，放到同一個執行緒處理。不用加鎖，也能做到防止多點同時登陸。

接下來我們需要從 Sz.Network.ThreadPool 庫中取出一個執行緒

public static readonly long LoginThreadID = ThreadManager.GetInstance.GetThreadModel("登陸處理器");

用於控制登陸和登出

建立一個 CloseTcpHandler 處理連結埠的處理程式 需要繼承 Sz.Network.ThreadPool 下面的 TaskBase

 1  public class CloseTcpHandler : TaskBase
 2     {
 3 
 4         IOSession client;
 5         SocketMessage message;
 6 
 7         public CloseTcpHandler(IOSession client)
 8             : base("Tcp登陸處理")
 9         {
10             this.client = client;
11         }
12 
13 
14         public override void TaskRun()
15         {
16                 
17         }
18     }
View Code

那麼我們修改一下 MessagePool 類

   public void ActiveSocket(IOSession client)
        {
            //client.SendMsg(new SocketMessage(1, System.Text.UTF8Encoding.Default.GetBytes("Holle Server！client")));
        }

        public void CloseSocket(IOSession client)
        {
            ThreadManager.GetInstance.AddTask(ServerManager.LoginThreadID, new CloseTcpHandler(client));
        }

這樣斷開連結處理就交到了 ServerManager.LoginThreadID 這個執行緒裡面處理了

我們再來建立一下 LoginTcpHandler 處理登陸程式 需要繼承 Sz.Network.ThreadPool 下面的 TaskBase

View Code

修改  MessagePool 類 處理登陸訊息

 1 public void ReadMessage(IOSession client, SocketMessage message)
 2         {
 3             switch (message.MsgID)
 4             {
 5                 case 1://登陸 
 6                 case 2:
 7                     ThreadManager.GetInstance.AddTask(ServerManager.LoginThreadID, new LoginTcpHandler(client, message));
 8                     break;
 9                 default:
10                     Logger.Error("未繫結訊息ID " + message.MsgID);
11                     break;
12             }
13         }

這裡是我自定義訊息ID是1和2的一個是登陸一個是登出。

這樣就把登陸的事件也交給了ServerManager.LoginThreadID 這個執行緒裡面處理了

LoginTcpHandler taskrun方法

 1  public override void TaskRun()
 2         {
 3             using (MemoryStream msReader = new MemoryStream(message.MsgBuffer))
 4             {
 5                 using (System.IO.BinaryReader srReader = new BinaryReader(msReader, UTF8Encoding.Default))
 6                 {
 7                     using (MemoryStream msWriter = new MemoryStream())
 8                     {
 9                         using (System.IO.BinaryWriter srWriter = new BinaryWriter(msWriter, UTF8Encoding.Default))
10                         {
11                             switch (message.MsgID)
12                             {
13                                 case 1://登陸 
14                                     string username = srReader.ReadString();
15                                     if (!LoginManager.GetInstance.LoginNames.Contains(username))
16                                     {
17                                         LoginManager.GetInstance.LoginNames.Add(username);
18                                         if (!LoginManager.GetInstance.LoginIPs.ContainsKey(client.ID))
19                                         {
20                                             LoginManager.GetInstance.LoginIPs[client.ID] = username;
21                                             LoginManager.GetInstance.Sessions.Add(client);
22                                         }
23                                         srWriter.Write(true);
24                                         srWriter.Write(username + " 登陸聊天室");
25                                         Logger.Info(client.RemoteEndPoint + " " + username + " 登陸成功");
26                                         SocketMessage sm = new SocketMessage(message.MsgID, msWriter.GetBuffer());
27                                         ServerManager.GetInstance.Tell_All(sm);
28                                     }
29                                     else
30                                     {
31                                         srWriter.Write(false);
32                                         srWriter.Write("登入名稱重複，請換一個");
33                                         Logger.Info(client.RemoteEndPoint + " " + username + " 登入名稱重複!");
34                                         SocketMessage sm = new SocketMessage(message.MsgID, msWriter.GetBuffer());
35                                         client.SendMsg(sm);
36                                     }
37                                     break;
38                                 case 2:// 退出登陸
39 
40                                     break;
41                                 default:
42 
43                                     break;
44                             }
45                         }
46                     }
47                 }
48             }
49         }
View Code 

CloseTcpHandler taskrun方法

 1 public override void TaskRun()
 2         {
 3             if (LoginManager.GetInstance.LoginIPs.ContainsKey(client.ID))
 4             {
 5                 string username = LoginManager.GetInstance.LoginIPs[client.ID];
 6                 LoginManager.GetInstance.LoginIPs.Remove(client.ID);
 7                 LoginManager.GetInstance.LoginIPs.Remove(username);
 8                 LoginManager.GetInstance.Sessions.Remove(client);
 9                 using (MemoryStream msWriter = new MemoryStream())
10                 {
11                     using (System.IO.BinaryWriter srWriter = new BinaryWriter(msWriter, UTF8Encoding.Default))
12                     {
13                         srWriter.Write(username + "退出聊天室");
14                         SocketMessage sm = new SocketMessage(3, msWriter.GetBuffer());//3表示傳送訊息
15                         ServerManager.GetInstance.Tell_All(sm);
16                     }
17                 }
18             }
19         }
View Code

這裡由於程式碼沒有貼全，有興趣的可以下載原始碼試試

啟動兩個客戶端後，看到建立了兩個連結，並且登陸到伺服器。

由於聊天和登陸所以不同的兩個模組，為了提高效率 我們再次建立一個聊天執行緒

public static readonly long ChatThreadID = ThreadManager.GetInstance.GetThreadModel("聊天處理器");

接下來我們在 MessagePool 的 ReadMessage 方法的switch裡面加入

case 3://聊天
                    ThreadManager.GetInstance.AddTask(ServerManager.ChatThreadID, new Chat.ChatHandler(client, message));
                    break;

這樣我們就把所有的聊天訊息轉發的ServerManager.ChatThreadID這個執行緒處理。就是卡頓情況，也不會影響客戶端聊天傳送訊息和新客戶端請求登陸。

這裡我們還可以考慮分組，聊天分組功能。比如私聊，群聊等分組執行緒進行執行。

建立一個 ChatHandler  需要繼承 Sz.Network.ThreadPool 下面的 TaskBase

 1 public class ChatHandler : TaskBase
 2     {
 3         IOSession client;
 4 
 5         SocketMessage message;
 6 
 7 
 8         public ChatHandler(IOSession client, SocketMessage message)
 9             : base("聊天處理任務")
10         {
11             this.client = client;
12             this.message = message;
13         }
14 
15 
16         public override void TaskRun()
17         {
18             using (MemoryStream msWriter = new MemoryStream())
19             {
20                 using (System.IO.BinaryWriter srWriter = new BinaryWriter(msWriter, UTF8Encoding.Default))
21                 {
22                     //構建輸入buffer
23                     //驗證登陸情況
24                     if (LoginManager.GetInstance.LoginIPs.ContainsKey(client.ID))
25                     {
26                         string username = LoginManager.GetInstance.LoginIPs[client.ID];
27                         using (MemoryStream msReader = new MemoryStream(message.MsgBuffer))
28                         {
29                             using (System.IO.BinaryReader srReader = new BinaryReader(msReader, UTF8Encoding.Default))
30                             {
31                                 string msg = srReader.ReadString();
32                                 msg = client.RemoteEndPoint + " " + username + " " + msg;
33                                 Logger.Info(msg);
34                                 srWriter.Write(msg);
35                                 SocketMessage sm = new SocketMessage(message.MsgID, msWriter.GetBuffer());
36                                 ServerManager.GetInstance.Tell_All(sm);
37                             }
38                         }
39                     }
40                     else
41                     {
42                         srWriter.Write("尚未登陸");
43                         SocketMessage sm = new SocketMessage(message.MsgID, msWriter.GetBuffer());
44                         client.SendMsg(sm);
45                     }
46                 }
47             }
48         }
49     }
View Code

發個訊息試試

這裡一個簡單的聊天伺服器，登陸到聊天就算完成了，客戶端是wpf的程式，沒有貼出原始碼和過程，有需要或者要研究的親請下載svn原始碼，自行檢視情況。

相關推薦

一步一步開發Game伺服器（二）完成登陸，聊天

我知道這樣的文章在部落格園已經多的大家都不想看了，但是這是我的系列文章開始，請各位大神見諒了。 多執行緒，執行緒執行器，（詳見），socket通訊相關 （詳見） 本人blog相關文章測試程式碼，示例，完整版svn地址。（http://code.taobao.org/svn/flynetwork_cshar

一步一步開發Game伺服器（二）登陸2

上一篇文章，講解了簡單的登陸情況。接下來我們繼續講解登陸模組。 在正常的遊戲伺服器情況下。在尚未登入前可以檢視伺服器大區情況，登陸後也可以檢視伺服器大區情況，然後選擇大區伺服器。進行登入操作。 這樣的情況就需要我們有一個登入伺服器來負責，目前大區伺服器的狀態，是正常。擁擠，爆滿。還是停服維護。那麼這樣登入

一步一步開發Game伺服器（三）載入指令碼和伺服器熱更新

大家可能對遊戲伺服器的執行不太理解或者說不太清楚一些機制。 但是大家一定會明白一點，當程式在執行的時候出現一些bug，必須及時更新，但是不能重啟程式的情況下。 這裡牽涉到一個問題。比如說在遊戲裡面，，如果一旦開服，錯非完全致命性bug，否則是不能頻繁重啟伺服器程式的， 你重啟一次就可能流失一部分玩家。那

一步一步開發Game伺服器（四）地圖執行緒

時隔這麼久 才再一次的迴歸正題繼續講解遊戲伺服器開發。 開始講解前有一個問題需要修正。之前講的執行緒和定時器執行緒的時候是分開的。 但是真正地圖執行緒與之前的執行緒模型是有區別的。 為什麼會有區別呢？一個地圖肯定有執行執行緒，但是每一個地圖都有不同的時間任務。比如檢測玩家身上的buffer，檢測玩家

一步一步開發Game伺服器（五）地圖尋路

目前大多數使用的尋路演算法有哪些？ 目前市面上大部分遊戲的尋路演算法是A*，或者B*。 A*通常所說的是最優演算法也就是尋找最短路徑。B*碰撞式演算法也就是，也就是不斷的去碰撞能走就走，不管是不是繞路。當然以上都是我的理解。 我這裡只描述一下A*演算法的一部分。 通常A*演算法分為四方向和八方向計算。

一步一步開發Game伺服器（三）載入指令碼和伺服器熱更新（二）完整版

可是在使用過程中，也許有很多會發現，動態載入dll其實不方便，應為需要預先編譯程式碼為dll檔案。便利性不是很高。 那麼有麼有辦法能做到動態實時更新呢？？？？ 官方提供了這兩個物件，動態編譯原始檔。 提供對 C# 程式碼生成器和程式碼編譯器的例項的訪問。 CSharpCodeProvider

VUE 爬坑之旅-- 從零開始一步一步構建 VUE 單頁應用（二）

上篇 從零開始一步一步構建 VUE 單頁應用（一） 對單頁應用做了簡單的介紹並建立了一個單頁應用的模版。這篇就先來看看這個專案的檔案結構，然後再看看要怎麼修改才能實現我們自己的頁面。 檔案結構 用官方的 vue-cli 生成的專案檔案結構如上圖所示

微專案：一步一步帶你使用SpringBoot入門（二）

今天我們來使用JPA做分頁專案並且做講解 如果是新來的朋友請回上一篇 上一篇:微專案(一) maven整合 在pom檔案的dependencies依賴中匯入以下依賴 <dependency> <groupId>org.springframewor

.Net異步編程進階之（二）

con mage ack 問題 eth 情況 情況下 core https 　　避免使用Task.Result和Task.Wait 　　只有極少方法可以正確的使用Task.Result和Task.Wait，一般情況下建議是完全避免在代碼上出現。 　 　同步異步 　　

PTA 陣列迴圈左移 （20 分） 本題要求實現一個對陣列進行迴圈左移的簡單函式：一個數組a中存有n（>0）個整數，在不允許使用另外陣列的前提下，將每個整數迴圈向左移m（≥0）個位置，即將a中的

陣列迴圈左移 （20 分） 本題要求實現一個對陣列進行迴圈左移的簡單函式：一個數組a中存有n（>0）個整數，在不允許使用另外陣列的前提下，將每個整數迴圈向左移m（≥0）個位置，即將a中的資料由（a​0​​a​1​​⋯a​n−1​​）變換為（a​m​​⋯a​n−

工作一年多的感慨與總結（二）

前言 　　前一篇（工作一年多的感慨與總結（一））算是對自己對這一年不如意的地方的一些抱怨與吐槽吧，那麼今天這一篇就總結記錄下那些正能量的事吧（自己能把自己感動的故事），廢話不多說，趁著有足夠的時間回憶，抓緊記錄！ 2018/7-2018/9  跳槽準備 （1）人總是要有點資本的 　　其實從當時的公司入職

windows下利用Node.js開發後臺伺服器（三）

三.為前端做資料介面 1.在專案資料夾下新建app.js檔案作為專案主入口檔案2.專案需要用到koa\koa-bodbparser\kou-router\kou-cors模組，先requrie進去 const Koa = require('koa'); const body

多執行緒程式設計（二）——面試題，每個執行緒只打印一種字元，多個執行緒協同順序列印n次字串（求大神的其他實現方案）

（這個是歡聚時刻（YY）的筆試題，在筆試的時候沒有寫出來，後來自己寫了出來，希望大神能給出更優秀的解決方案……ps：現在面試官總有面試時問筆試程式設計題思路的習慣，呵呵） 題目簡述： 輸入一個字串以

【一起來學React】- Reudx學習（二）

上篇文章我們說到redux一些基礎和在react中如何運用。本文講解在react中如何更加優雅的編寫redux！ 上一篇文章地址：https://blog.csdn.net/Fakin/article/details/85287116 非同步Action 在redu

Mysql叢集和一主多從的方案實現（二）

4、改進方式三：MyCat資料庫中介軟體 在上文中我們介紹了MySQL讀寫分離叢集的持續優化方式。按照這樣的方式，叢集中負責讀寫分離的MySQL節點基本上能夠分別實現真對上層業務系統訪問的透明化。這樣的MySQL叢集方式已經可以承載讀者遇到的大部分業務系統的結構化資料規模，但整個叢集方案還有一些明顯的問

[Vue原始碼]一起來學Vue模板編譯原理（二）-AST生成Render字串

本文我們一起通過學習Vue模板編譯原理（二）-AST生成Render字串來分析Vue原始碼。預計接下來會圍繞Vue原始碼來整理一些文章，如下。 一起來學Vue雙向繫結原理-資料劫持和釋出訂閱 一起來學Vue模板編譯原理(一)-Template生成AST 一起來學Vue模板編譯原理(二)-AST生成Rende

Python開發簡單爬蟲（二）---爬取百度百科頁面數據

class 實例 實例代碼 編碼 mat 分享 aik logs title 一、開發爬蟲的步驟 1.確定目標抓取策略： 打開目標頁面，通過右鍵審查元素確定網頁的url格式、數據格式、和網頁編碼形式。 ①先看url的格式, F12觀察一下鏈接的形式;② 再看目標文本信息的

Spring Data 開發環境搭建（二）

是不是 lns utf-8 void ext for 實體類 connect domain 首先咱們先創建一個maven工程 在pom.xml加入以下 依賴 <!--Mysql 驅動包--> <dependency> <

vue2開發常見問題（二）

eve turn nta 事件委托 def methods con div 方法 1.使用v-html顯示一段html代碼，但是裏面綁定的click事件不生效 ？ 原代碼： <div v-html="test"></div> export de

4.前端基於react,後端基於.net core2.0的開發之路（4） 前端打包，編譯，路由，模型，服務

hub 解決 路徑 export routes run 部署 service 後端 1.簡要的介紹 學習react，首先學習的就是javascript,然後ES6,接著是jsx，通常來說如果有javascript的基礎，上手非常快，但是真正要搭建一個前端工程化項目，還是有很