Merge pull request #19 from progtime-net/ServerBranch

Server branch
This commit is contained in:
SergoDobro 2024-08-16 12:27:40 +03:00 committed by GitHub
commit 2187bc4466
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
6 changed files with 83 additions and 57 deletions

View file

@ -27,10 +27,12 @@ namespace ZoFo.GameCore
public void GameEndedUnexpectedly(){ } public void GameEndedUnexpectedly(){ }
public void JoinRoom(){ } public void JoinRoom(string ip)
{
public void JoinYourself(){ } networkManager.JoinRoom(ip);
}
public void JoinYourself(){ networkManager.JoinYourself(); }
internal void Update(GameTime gameTime) internal void Update(GameTime gameTime)
{ {
} }

View file

@ -2,6 +2,7 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Diagnostics; using System.Diagnostics;
using System.Linq; using System.Linq;
using System.Threading;
using System.Xml; using System.Xml;
using Microsoft.Xna.Framework; using Microsoft.Xna.Framework;
using Microsoft.Xna.Framework.Content; using Microsoft.Xna.Framework.Content;
@ -25,7 +26,7 @@ public class MainMenuGUI : AbstractGUI
Elements.Add(menuBackground); Elements.Add(menuBackground);
menuBackground.LoadTexture(AppManager.Instance.Content); menuBackground.LoadTexture(AppManager.Instance.Content);
Elements.Add(new Label(Manager) { rectangle = new Rectangle(width / 2 - (int)(width / 8), height / 5, (int)(width / 4), (int)(height / 20)), text = "ZoFo", fontColor = Color.White, mainColor = Color.Transparent, scale = 0.9f, fontName = "Fonts\\Font"}); Elements.Add(new Label(Manager) { rectangle = new Rectangle(width / 2 - (int)(width / 8), height / 5, (int)(width / 4), (int)(height / 20)), text = "ZoFo", fontColor = Color.White, mainColor = Color.Transparent, scale = 0.9f, fontName = "Fonts\\Font" });
Button playButton = new Button(Manager) Button playButton = new Button(Manager)
@ -73,7 +74,6 @@ public class MainMenuGUI : AbstractGUI
} }
public override void Update(GameTime gameTime) public override void Update(GameTime gameTime)
{ {
base.Update(gameTime); base.Update(gameTime);

View file

@ -37,7 +37,7 @@ namespace ZoFo.GameCore.GameManagers
public InputManager InputManager; public InputManager InputManager;
public ItemManager.ItemManager ItemManager; public ItemManager.ItemManager ItemManager;
public AnimationBuilder animationBuilder{get;set; } public AnimationBuilder animationBuilder { get; set; }
#endregion #endregion
@ -45,7 +45,7 @@ namespace ZoFo.GameCore.GameManagers
{ {
_graphics = new GraphicsDeviceManager(this); _graphics = new GraphicsDeviceManager(this);
SetResolution(CurentScreenResolution.X, CurentScreenResolution.Y); SetResolution(CurentScreenResolution.X, CurentScreenResolution.Y);
FulscrreenSwitch(); // FulscrreenSwitch();
Content.RootDirectory = "Content"; Content.RootDirectory = "Content";
@ -68,8 +68,6 @@ namespace ZoFo.GameCore.GameManagers
debugHud.Initialize(); debugHud.Initialize();
base.Initialize(); base.Initialize();
} }
@ -160,5 +158,8 @@ namespace ZoFo.GameCore.GameManagers
{ {
_graphics.IsFullScreen = !_graphics.IsFullScreen; _graphics.IsFullScreen = !_graphics.IsFullScreen;
} }
public void SetServer(Server server) { this.server = server; }
public void SetClient(Client client) { this.client = client; }
} }
} }

View file

@ -5,6 +5,7 @@ using System.Net;
using System.Net.Sockets; using System.Net.Sockets;
using System.Security.Cryptography.X509Certificates; using System.Security.Cryptography.X509Certificates;
using System.Text; using System.Text;
using System.Text.Json;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
using ZoFo.GameCore.GameManagers.NetworkManager.Updates; using ZoFo.GameCore.GameManagers.NetworkManager.Updates;
@ -20,6 +21,12 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
List<IUpdateData> updates = new List<IUpdateData>(); List<IUpdateData> updates = new List<IUpdateData>();
public delegate void OnDataSent(string Data); public delegate void OnDataSent(string Data);
public event OnDataSent GetDataSent; // event public event OnDataSent GetDataSent; // event
public ClientNetworkManager()
{
Init();
}
public void Init() //create endPoint, socket public void Init() //create endPoint, socket
{ {
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
@ -27,11 +34,13 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
public void SendData() public void SendData()
{ {
while(socket.Connected) byte[] bytes = Encoding.UTF8.GetBytes(JsonSerializer.Serialize(updates)); //нужно сериализовать
{
byte[] bytes = Encoding.UTF8.GetBytes(updates.ToString());
socket.Send(bytes); socket.Send(bytes);
} }
public void AddData(IUpdateData UpdateData)
{
updates.Add(UpdateData);
} }
public void StopConnection() public void StopConnection()
@ -47,10 +56,9 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
/// <param name="port"></param> /// <param name="port"></param>
public void JoinRoom(string ip) // multyplayer public void JoinRoom(string ip) // multyplayer
{ {
endPoint = new IPEndPoint(IPAddress.Parse(ip), port); endPoint = new IPEndPoint(IPAddress.Parse(ip), port);
socket.Connect(endPoint); socket.Connect(endPoint);
SendData(); SendData();
Thread listen = new Thread(StartListening); Thread listen = new Thread(StartListening);
listen.Start(); listen.Start();
@ -62,9 +70,7 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
public void JoinYourself() // single player public void JoinYourself() // single player
{ {
endPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), port); endPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), port);
socket.Connect(endPoint); socket.Connect(endPoint);
SendData(); SendData();
Thread listen = new Thread(StartListening); Thread listen = new Thread(StartListening);
listen.Start(); listen.Start();

View file

@ -16,7 +16,7 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
{ {
public class ServerNetworkManager public class ServerNetworkManager
{ {
private IPAddress ip = IPAddress.Any; private IPAddress ip =IPAddress.Parse("127.0.0.1"); //IPAddress.Any
private int port = 7632; private int port = 7632;
private IPEndPoint endPoint; private IPEndPoint endPoint;
private Socket socket; private Socket socket;
@ -25,12 +25,18 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
public delegate void OnDataSend(string data); public delegate void OnDataSend(string data);
public event OnDataSend GetDataSend; // event public event OnDataSend GetDataSend; // event
Dictionary<Socket, Thread> managerThread; Dictionary<Socket, Thread> managerThread;
Thread serverTheread;
public ServerNetworkManager() { Init(); }
public void Init() //create Socket public void Init() //create Socket
{ {
endPoint = new IPEndPoint(ip, port); endPoint = new IPEndPoint(ip, port);
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
managerThread = new Dictionary<Socket, Thread>(); managerThread = new Dictionary<Socket, Thread>();
clients = new List<Socket>();
updates = new List<IUpdateData>();
managerThread = new Dictionary<Socket, Thread>();
} }
/// <summary> /// <summary>
/// отправляет клиенту Data /// отправляет клиенту Data
@ -52,7 +58,6 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
{ {
updates.Add(data); updates.Add(data);
} }
public void CloseConnection() //По сути коне игры и отключение игроков public void CloseConnection() //По сути коне игры и отключение игроков
{ {
foreach (var item in clients) foreach (var item in clients)
@ -74,6 +79,12 @@ namespace ZoFo.GameCore.GameManagers.NetworkManager
clients.Clear(); clients.Clear();
} }
public void Start(object players)
{
serverTheread = new Thread(StartWaitingForPlayers);
serverTheread.Start(players);
}
//Потоки Клиентов //Потоки Клиентов
public void StartWaitingForPlayers(object players)//Слушает игроков, которые хотят подключиться public void StartWaitingForPlayers(object players)//Слушает игроков, которые хотят подключиться
{ {

View file

@ -37,20 +37,26 @@ namespace ZoFo.GameCore
{ {
networkManager.AddData(data); networkManager.AddData(data);
} }
public void CreateRoom(int players) //Создает комнату и запускает ожидание подключений /// <summary>
/// Создает комнату и запускает ожидание подключений
/// </summary>
/// <param name="players"></param>
public void CreateRoom(int players)
{ {
networkManager.StartWaitingForPlayers(players); networkManager.Start(players);
} }
// public void StartGame() { } принудительный запуск // public void StartGame() { } принудительный запуск
public void EndGame() //Добавляет UpdateGameEnded и отключает игроков
/// <summary>
/// Добавляет UpdateGameEnded и отключает игроков
/// </summary>
public void EndGame()
{ {
UpdateGameEnded gameEnded = new UpdateGameEnded(); UpdateGameEnded gameEnded = new UpdateGameEnded();
networkManager.AddData(gameEnded); networkManager.AddData(gameEnded);
networkManager.CloseConnection(); networkManager.CloseConnection();
} }
public void Update(GameTime gameTime) public void Update(GameTime gameTime)
{ {
} }