diff --git a/FunGameServer.csproj b/FunGameServer.csproj
index 997e3ee..2b0c232 100644
--- a/FunGameServer.csproj
+++ b/FunGameServer.csproj
@@ -9,7 +9,6 @@
-
diff --git a/Main.cs b/Main.cs
index 6f54f41..b459508 100644
--- a/Main.cs
+++ b/Main.cs
@@ -5,27 +5,27 @@ using System.Text.RegularExpressions;
using System;
using FunGameServer.Sockets;
using System.Net.WebSockets;
+using FunGameServer.Models.Config;
bool Running = true;
Socket? ServerSocket = null;
-string host = "127.0.0.1";
-int port = 22222;
+string host = Config.SERVER_IPADRESS;
+int port = Config.SERVER_PORT;
try
{
Task t = Task.Factory.StartNew(() =>
{
// 创建IP地址终结点对象
- IPAddress ip = IPAddress.Parse(host);
- IPEndPoint ipe = new IPEndPoint(ip, port);
+ IPEndPoint ip = new(IPAddress.Parse(host), port);
// 创建TCP Socket对象并绑定终结点
ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
- ServerSocket.Bind(ipe);
+ ServerSocket.Bind(ip);
// 开始监听连接
- ServerSocket.Listen(0);
+ ServerSocket.Listen(Config.MAX_PLAYERS);
Console.WriteLine("服务器启动成功，正在监听 . . .");
while (Running)
@@ -39,14 +39,16 @@ try
Console.WriteLine("客户端" + clientIP.ToString() + "连接 . . .");
else
Console.WriteLine("未知地点客户端连接 . . .");
- Task.Factory.StartNew(() =>
- {
- new ClientSocket(socket, Running).Start();
- });
- // 接收客户端消息
- Read(socket);
- // 发送给客户端消息
- Send(socket);
+ if (Read(socket) && Send(socket))
+ Task.Factory.StartNew(() =>
+ {
+ new ClientSocket(socket, Running).Start();
+ });
+ else
+ if (clientIP != null)
+ Console.WriteLine("客户端" + clientIP.ToString() + "连接失败。");
+ else
+ Console.WriteLine("客户端连接失败。");
}
catch (Exception e)
{
@@ -87,7 +89,7 @@ Console.WriteLine("服务器已关闭，按任意键退出程序。");
Console.ReadKey();
-void Read(Socket socket)
+bool Read(Socket socket)
{
// 接收客户端消息
byte[] buffer = new byte[2048];
@@ -95,20 +97,28 @@ void Read(Socket socket)
if (length > 0)
{
string msg = Encoding.GetEncoding("unicode").GetString(buffer, 0, length);
- Console.WriteLine("收到来自：客户端 -> " + msg);
+ Console.WriteLine("收到来自：客户端（玩家ID） -> " + msg);
+ return true;
}
else
Console.WriteLine("客户端没有回应。");
+ return false;
}
-void Send(Socket socket)
+bool Send(Socket socket)
{
// 发送消息给客户端
string msg = ">> 已连接至服务器 -> [ " + host + " ] 连接成功";
- Console.WriteLine("发送给：客户端 <- " + msg);
byte[] buffer = new byte[2048];
buffer = Encoding.GetEncoding("unicode").GetBytes(msg);
- socket.Send(buffer);
+ if (socket.Send(buffer) > 0)
+ {
+ Console.WriteLine("发送给：客户端 <- " + msg);
+ return true;
+ }
+ else
+ Console.WriteLine("无法传输数据，与客户端的连接可能丢失。");
+ return false;
}
bool IsIP(string ip)
diff --git a/Models/Config/Config.cs b/Models/Config/Config.cs
new file mode 100644
index 0000000..0d0d229
--- /dev/null
+++ b/Models/Config/Config.cs
@@ -0,0 +1,34 @@
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Linq;
+using System.Net.Sockets;
+using System.Reflection.Metadata;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FunGameServer.Models.Config
+{
+ public static class Config
+ {
+ public static int MAX_PLAYERS = 16; // 最多接受连接的玩家数量
+ public static int ONLINE_PLAYERS = 0; // 已连接的玩家数量
+ public static int CONNECTING_PLAYERS = 0; // 正在连接的玩家数量
+ public static string SERVER_IPADRESS = "127.0.0.1"; // 默认IP地址
+ public static int SERVER_PORT = 22222; // 默认端口
+
+ ///
+ /// string: 玩家标识ID
+ /// Task：玩家线程
+ ///
+ public static ConcurrentDictionary OnlinePlayers = new ConcurrentDictionary();
+
+ /**
+ * string：房间号
+ * string：玩家标识ID
+ * Task：玩家线程
+ */
+ public static ConcurrentDictionary> PlayingPlayers= new ConcurrentDictionary>();
+
+ }
+}
diff --git a/Models/Config/SocketEnums.cs b/Models/Config/SocketEnums.cs
new file mode 100644
index 0000000..acaf86b
--- /dev/null
+++ b/Models/Config/SocketEnums.cs
@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace FunGameServer.Models.Config
+{
+ public static class SocketEnums
+ {
+ public enum SendType
+ {
+ Login = 1,
+ CheckLogin = 2,
+ Logout = 3,
+ HeartBeat = 4,
+ }
+
+ public enum ReadType
+ {
+ Login = 1,
+ CheckLogin = 2,
+ Logout = 3,
+ HeartBeat = 4,
+ }
+ }
+}
diff --git a/Sockets/ClientSocket.cs b/Sockets/ClientSocket.cs
index 5594b52..8290c23 100644
--- a/Sockets/ClientSocket.cs
+++ b/Sockets/ClientSocket.cs
@@ -1,6 +1,8 @@
-using System;
+using FunGameServer.Models.Config;
+using System;
using System.Collections.Generic;
using System.Linq;
+using System.IO;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
@@ -18,6 +20,59 @@ namespace FunGameServer.Sockets
Running = running;
}
+ bool Read(Socket socket)
+ {
+ // 接收客户端消息
+ byte[] buffer = new byte[2048];
+ int length = socket.Receive(buffer);
+ if (length > 0)
+ {
+ string type = Encoding.GetEncoding("unicode").GetString(buffer, 0, length);
+ Console.Write("收到来自：客户端（" + type + "） -> ");
+ buffer = new byte[2048];
+ length = socket.Receive(buffer);
+ if (length > 0)
+ {
+ string msg = Encoding.GetEncoding("unicode").GetString(buffer, 0, length);
+ Console.WriteLine(msg);
+ int getType = Convert.ToInt32(type);
+ if (getType == (int)SocketEnums.ReadType.HeartBeat) // 检测心跳包
+ Send(socket, getType, msg);
+ return true;
+ }
+ else
+ Console.WriteLine("客户端没有回应。");
+ return false;
+ }
+ else
+ Console.WriteLine("客户端没有回应。");
+ return false;
+ }
+
+ bool Send(Socket socket, int type, string msg)
+ {
+ // 发送消息给客户端
+ byte[] buffer = new byte[2048];
+ buffer = Encoding.GetEncoding("unicode").GetBytes(Convert.ToString(type));
+ if (socket.Send(buffer) > 0)
+ {
+ Console.Write("发送给：客户端（" + type + "） <- ");
+ buffer = new byte[2048];
+ buffer = Encoding.GetEncoding("unicode").GetBytes(msg);
+ if (socket.Send(buffer) > 0)
+ {
+ Console.WriteLine("发送给：客户端（" + msg + "） <- ");
+ return true;
+ }
+ else
+ Console.WriteLine("无法传输数据，与客户端的连接可能丢失。");
+ return false;
+ }
+ else
+ Console.WriteLine("无法传输数据，与客户端的连接可能丢失。");
+ return false;
+ }
+
public void Start()
{
Task StringStream = Task.Factory.StartNew(() =>
@@ -44,7 +99,14 @@ namespace FunGameServer.Sockets
Console.WriteLine("Creating: StringStream...OK");
while (Running)
{
-
+ if (Socket != null)
+ Read(Socket);
+ else
+ {
+ Console.WriteLine("ERROR: Socket is Closed.");
+ Console.WriteLine("DONE: StringStream is Closed.");
+ break;
+ }
}
}
@@ -54,7 +116,8 @@ namespace FunGameServer.Sockets
Console.WriteLine("Creating: IntStream...OK");
while (Running)
{
-
+ Console.WriteLine("DONE: IntStream is Closed.");
+ break;
}
}
@@ -64,7 +127,8 @@ namespace FunGameServer.Sockets
Console.WriteLine("Creating: DecimalStream...OK");
while (Running)
{
-
+ Console.WriteLine("DONE: DecimalStream is Closed.");
+ break;
}
}
@@ -74,7 +138,8 @@ namespace FunGameServer.Sockets
Console.WriteLine("Creating: ObjectStream...OK");
while (Running)
{
-
+ Console.WriteLine("DONE: ObjectStream is Closed.");
+ break;
}
}
}