-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathProgram.cs
89 lines (75 loc) · 1.97 KB
/
Program.cs
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
using PathfindingDedicatedServer.Nav;
using PathfindingDedicatedServer.Src.Data;
using PathfindingDedicatedServer.Src.Network;
using System.Net;
using System.Net.Sockets;
using static PathfindingDedicatedServer.Src.Constants.ServerConstants;
namespace PathfindingDedicatedServer;
public class Program
{
public static void Main()
{
Init();
// Start the TCP server
StartTcpServer();
}
private static void Init()
{
Console.WriteLine("----- INIT START -----");
Console.WriteLine();
DateTime startTime = DateTime.UtcNow;
// Load all NavMeshes
NavMeshLoader.LoadAllNavMeshAssets();
// Initialize Storage
Storage.InitStorage();
DateTime endTime = DateTime.UtcNow;
Console.WriteLine();
Console.WriteLine($"Elapsed time: {(endTime - startTime).TotalSeconds}s");
Console.WriteLine("----- INIT END -----");
}
private static void StartTcpServer()
{
// Set up the TCP listener on port 5000
IPAddress localhost = IPAddress.Parse(HOST);
TcpListener tcpListener = new(localhost, PORT);
tcpListener.Start();
Console.WriteLine($"TCP Server started on port {PORT}");
while (true)
{
try
{
// Accept a pending client connection
TcpClient tcpClient = tcpListener.AcceptTcpClient();
Console.WriteLine("Client connected.");
_ = Task.Run(async () =>
{
await HandleClient(tcpClient);
});
}
catch (Exception ex)
{
Console.WriteLine($"Error: {ex.Message}");
}
}
}
private static async Task HandleClient(object? obj)
{
try
{
if (obj is not TcpClient tcpClient)
{
return;
}
TcpClientHandler handler = new(tcpClient);
handler.OnDataReceived += (data) =>
{
Console.WriteLine($"Received: {data}");
};
await handler.StartHandlingClientAsync();
}
catch (Exception e)
{
Console.WriteLine("HandleClient Error:" + e.Message);
}
}
}