Merge branch 'main' into livingEntities

This commit is contained in:
bmvolf 2023-08-17 13:18:41 +03:00
commit 412239498e
16 changed files with 434 additions and 140 deletions

View file

@ -5,6 +5,7 @@ using System;
using System.Windows.Forms; using System.Windows.Forms;
using System.IO; using System.IO;
using System.Linq; using System.Linq;
using System.Reflection.Metadata;
namespace AnimationsFileCreator namespace AnimationsFileCreator
{ {
@ -62,7 +63,7 @@ namespace AnimationsFileCreator
container.TextureFrameInterval = 1; container.TextureFrameInterval = 1;
container.Id = id; container.Id = id;
string json = JsonConvert.SerializeObject(container); string json = JsonConvert.SerializeObject(container);
StreamWriter writer = new StreamWriter("../../../../DangerousD/Content/animations/" + id); StreamWriter writer = new StreamWriter("../../../../DangerousD/Content/animations/"+id);
writer.WriteLine(json); writer.WriteLine(json);
writer.Close(); writer.Close();
} }

View file

@ -0,0 +1,20 @@
{
"id": "SilasAttack",
"textureName": "MonstersAnimations",
"startSpriteRectangle": {
"X": 1,
"Y": 618,
"Width": 72,
"Height": 80
},
"frameSecond": [
{
"Item1": 0,
"Item2": 5
}
],
"textureFrameInterval": 1,
"framesCount": 2,
"isCycle": true,
"offset": "0, 0"
}

View file

@ -0,0 +1 @@
{"id":"SilasHandMove","textureName":"MonstersAnimations","startSpriteRectangle":{"X":197,"Y":618,"Width":24,"Height":24},"frameSecond":[{"Item1":0,"Item2":8}],"textureFrameInterval":1,"framesCount":2,"isCycle":true,"offset":"0, 0"}

View file

@ -0,0 +1,20 @@
{
"id": "SilasMove",
"textureName": "MonstersAnimations",
"startSpriteRectangle": {
"X": 1,
"Y": 618,
"Width": 72,
"Height": 80
},
"frameSecond": [
{
"Item1": 0,
"Item2": 60
}
],
"textureFrameInterval": 1,
"framesCount": 2,
"isCycle": true,
"offset": "0, 0"
}

View file

@ -10,6 +10,7 @@ using System.Threading.Tasks;
using DangerousD.GameCore.Managers; using DangerousD.GameCore.Managers;
using MonogameLibrary.UI.Base; using MonogameLibrary.UI.Base;
using System.Diagnostics; using System.Diagnostics;
using DangerousD.GameCore.Network;
namespace DangerousD.GameCore.GUI namespace DangerousD.GameCore.GUI
{ {
@ -32,8 +33,32 @@ namespace DangerousD.GameCore.GUI
Elements.Add(new Label(Manager) { rectangle = new Rectangle(screenWidth / 30 * 2, screenHeight / 30 * 5, Elements.Add(new Label(Manager) { rectangle = new Rectangle(screenWidth / 30 * 2, screenHeight / 30 * 5,
screenWidth / 30 * 26, screenHeight / 15 * 10) }); screenWidth / 30 * 26, screenHeight / 15 * 10) });
// Buttons // Buttons and ip textbox
{ {
TextBox searchBarTextBox = new TextBox(Manager)
{
rectangle = new Rectangle(screenWidth / 30 * 14, screenHeight / 30,
screenWidth / 30 * 10, screenHeight / 30 * 3),
text = "ip",
scale = 0.16f,
fontColor = Color.Gray,
fontName = "font2",
textAligment = TextAligment.Left
};
searchBarTextBox.TextChanged += input => {
if (searchBarTextBox.fontColor == Color.Gray)
{
searchBarTextBox.text = ""; searchBarTextBox.fontColor = Color.Black;
}
};
searchBarTextBox.StopChanging += input => {
if (input.Length == 0)
{
searchBarTextBox.fontColor = Color.Gray;
searchBarTextBox.text = "ip";
}
};
Button backButton = new ButtonText(Manager) Button backButton = new ButtonText(Manager)
{ {
rectangle = new Rectangle(screenWidth / 30, screenHeight / 30, 60, 50), rectangle = new Rectangle(screenWidth / 30, screenHeight / 30, 60, 50),
@ -55,7 +80,9 @@ namespace DangerousD.GameCore.GUI
fontName = "font2" fontName = "font2"
}; };
hostButton.LeftButtonPressed += () => { hostButton.LeftButtonPressed += () => {
AppManager.Instance.NetworkManager.HostInit(AppManager.Instance.IpAddress);
}; };
Button refreshButton = new ButtonText(Manager) Button refreshButton = new ButtonText(Manager)
@ -79,7 +106,7 @@ namespace DangerousD.GameCore.GUI
fontName = "font2" fontName = "font2"
}; };
joinSelectedButton.LeftButtonPressed += () => { joinSelectedButton.LeftButtonPressed += () => {
AppManager.Instance.NetworkManager.ClientInit(AppManager.Instance.IpAddress);
}; };
Button joinByIpButton = new ButtonText(Manager) Button joinByIpButton = new ButtonText(Manager)
{ {
@ -90,34 +117,7 @@ namespace DangerousD.GameCore.GUI
fontName = "font2" fontName = "font2"
}; };
joinByIpButton.LeftButtonPressed += () => { joinByIpButton.LeftButtonPressed += () => {
AppManager.Instance.NetworkManager.ClientInit(searchBarTextBox.text);
};
}
// SearchBar
{
TextBox searchBarTextBox = new TextBox(Manager) {
rectangle = new Rectangle(screenWidth / 30 * 14, screenHeight / 30,
screenWidth / 30 * 10, screenHeight / 30 * 3),
text = "ip",
scale = 0.16f,
fontColor = Color.Gray,
fontName = "font2",
textAligment = TextAligment.Left
};
searchBarTextBox.TextChanged += input => {
if (searchBarTextBox.fontColor == Color.Gray)
{
searchBarTextBox.text = ""; searchBarTextBox.fontColor = Color.Black;
}
};
searchBarTextBox.StopChanging += input => {
if (input.Length == 0)
{
searchBarTextBox.fontColor = Color.Gray;
searchBarTextBox.text = "ip";
}
}; };
} }
} }

View file

@ -35,6 +35,7 @@ internal class MenuGUI : AbstractGui
butSingle.LeftButtonPressed += () => butSingle.LeftButtonPressed += () =>
{ {
AppManager.Instance.ChangeGameState(GameState.Game); AppManager.Instance.ChangeGameState(GameState.Game);
AppManager.Instance.SetMultiplayerState(MultiPlayerStatus.SinglePlayer);
}; };
var butMulti = new ButtonText(Manager) { rectangle = new Rectangle((wigth - 300) / 2, 190, 300, 50), text = "Multiplayer", fontName = "ButtonFont" }; var butMulti = new ButtonText(Manager) { rectangle = new Rectangle((wigth - 300) / 2, 190, 300, 50), text = "Multiplayer", fontName = "ButtonFont" };
Elements.Add(butMulti); Elements.Add(butMulti);

View file

@ -1,4 +1,8 @@
using System; using DangerousD.GameCore.Graphics;
using Microsoft.Xna.Framework;
using Microsoft.Xna.Framework.Content;
using Microsoft.Xna.Framework.Graphics;
using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Text; using System.Text;
@ -6,7 +10,60 @@ using System.Threading.Tasks;
namespace DangerousD.GameCore.GameObjects.LivingEntities.Monsters namespace DangerousD.GameCore.GameObjects.LivingEntities.Monsters
{ {
internal class SilasHands public class SilasHands : CoreEnemy
{ {
public SilasHands(Vector2 position) : base(position)
{
name = "SilasHand";
Width = 48;
Height = 48;
monster_health = 2;
monster_speed = 2;
acceleration = Vector2.Zero;
}
protected override GraphicsComponent GraphicsComponent { get; }=new GraphicsComponent(new List<string>() { "SilasHandMove" }, "SilasHandMove");
public override void Attack()
{
throw new NotImplementedException();
}
public override void Death()
{
throw new NotImplementedException();
}
public override void Move(GameTime gameTime)
{
if (Pos.Y> AppManager.Instance.GameManager.GetPlayer1.Pos.Y)
{
velocity.Y = monster_speed;
}
else
{
velocity.Y = 0;
}
if (Pos.X> AppManager.Instance.GameManager.GetPlayer1.Pos.X)
{
velocity.X = -monster_speed;
}
else
{
velocity.X = monster_speed;
}
}
public override void Update(GameTime gameTime)
{
base.Update(gameTime);
if ((Pos.X + 20 <= AppManager.Instance.GameManager.GetPlayer1.Pos.X || Pos.X - 20 >= AppManager.Instance.GameManager.GetPlayer1.Pos.X)&&(Pos.Y + 20 <= AppManager.Instance.GameManager.GetPlayer1.Pos.Y || Pos.Y - 20 >= AppManager.Instance.GameManager.GetPlayer1.Pos.Y))
{
AppManager.Instance.GameManager.GetPlayer1.Death(name);
}
GraphicsComponent.Update();
}
} }
} }

View file

@ -1,4 +1,8 @@
using System; using DangerousD.GameCore.Graphics;
using Microsoft.Xna.Framework;
using Microsoft.Xna.Framework.Content;
using Microsoft.Xna.Framework.Graphics;
using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Text; using System.Text;
@ -6,7 +10,64 @@ using System.Threading.Tasks;
namespace DangerousD.GameCore.GameObjects.LivingEntities.Monsters namespace DangerousD.GameCore.GameObjects.LivingEntities.Monsters
{ {
public class SilasMaster public class SilasMaster : CoreEnemy
{ {
private int attackTime = 60;
private int moveTime = 360;
private int currentTime = 0;
public SilasMaster(Vector2 position) : base(position)
{
name = "SilasMaster";
Width = 144;
Height = 160;
monster_health = 15;
monster_speed = 4;
acceleration = Vector2.Zero;
}
protected override GraphicsComponent GraphicsComponent { get; } = new GraphicsComponent(new List<string>() { "SilasMove", "SilasAttack" }, "SilasMove");
public override void Attack()
{
if (currentTime==0)
{
GraphicsComponent.StartAnimation("SilasAttack");
}
else if (currentTime >= attackTime)
{
GraphicsComponent.StartAnimation("SilasMove");
currentTime = 0;
}
currentTime++;
}
public override void Death()
{
throw new NotImplementedException();
}
public override void Move(GameTime gameTime)
{
if (currentTime == 0)
{
GraphicsComponent.StartAnimation("SilasMove");
}
else if (currentTime >= moveTime)
{
GraphicsComponent.StartAnimation("SilasAttack");
currentTime = 0;
}
currentTime++;
}
public override void Update(GameTime gameTime)
{
base.Update(gameTime);
if (GraphicsComponent.CurrentAnimation.Id=="SilasMove")
{
Move(gameTime);
}
else
{
Attack();
}
}
} }
} }

View file

@ -16,7 +16,14 @@ namespace DangerousD.GameCore.Graphics
private List<Texture2D> textures; private List<Texture2D> textures;
private List<string> texturesNames; private List<string> texturesNames;
private AnimationContainer currentAnimation; private AnimationContainer currentAnimation;
public AnimationContainer CurrentAnimation
{
get
{
return currentAnimation;
}
}
public string LastAnimation { get; set; }
public string GetCurrentAnimation public string GetCurrentAnimation
{ {
get { return currentAnimation.Id; } get { return currentAnimation.Id; }
@ -26,6 +33,13 @@ namespace DangerousD.GameCore.Graphics
//private SpriteBatch _spriteBatch; //private SpriteBatch _spriteBatch;
private int currentFrame; private int currentFrame;
public int CurrentFrame
{
get
{
return currentFrame;
}
}
private int interval; private int interval;
private int lastInterval; private int lastInterval;
private Rectangle sourceRectangle; private Rectangle sourceRectangle;

View file

@ -13,13 +13,13 @@ namespace DangerousD.GameCore.Levels
new Player(new Vector2(80,0)); new Player(new Vector2(80,0));
var Zombie = new Zombie(new Vector2(250, 128)); var Zombie = new Zombie(new Vector2(250, 128));
//var Frank = new Frank(new Vector2(384, 128)); //var Frank = new Frank(new Vector2(384, 128));
//var Spider = new Spider(new Vector2(112, 0)); //var Spider = new Spider(new Vector2(112, 0));
//var FlameSkull = new FlameSkull(new Vector2(512, 0)); //var FlameSkull = new FlameSkull(new Vector2(512, 0));
//var Werewolf = new Werewolf(new Vector2(640, 0)); //var Werewolf = new Werewolf(new Vector2(640, 0));
//var Ghost = new Ghost(new Vector2(730, 0)); //var Ghost = new Ghost(new Vector2(730, 0));
//var FrankBalls = new FrankBalls(new Vector2(Frank.Pos.X, Frank.Pos.Y)); //var FrankBalls = new FrankBalls(new Vector2(Frank.Pos.X, Frank.Pos.Y));
//var SilasHand = new SilasHands(new Vector2(200,64));
//var SilasMaster = new SilasMaster(new Vector2(400, 64));
new GrassBlock(new Vector2(0, 224)); new GrassBlock(new Vector2(0, 224));
for (int i = 0; i < 50; i++) for (int i = 0; i < 50; i++)
{ {

View file

@ -14,12 +14,15 @@ using DangerousD.GameCore.Managers;
namespace DangerousD.GameCore namespace DangerousD.GameCore
{ {
public enum GameState { Menu, Options, Lobby, Game, Login, GameOver } public enum GameState { Menu, Options, Lobby, Game, Login, GameOver }
public enum MultiPlayerStatus { SinglePlayer, Host, Client }
public class AppManager : Game public class AppManager : Game
{ {
public static AppManager Instance { get; private set; } public static AppManager Instance { get; private set; }
public string IpAddress { get; private set; } = "127.0.0.1";
private GraphicsDeviceManager _graphics; private GraphicsDeviceManager _graphics;
private SpriteBatch _spriteBatch; private SpriteBatch _spriteBatch;
GameState gameState; public GameState gameState { get; private set; }
public MultiPlayerStatus multiPlayerStatus { get; private set; } = MultiPlayerStatus.SinglePlayer;
IDrawableObject MenuGUI; IDrawableObject MenuGUI;
IDrawableObject OptionsGUI; IDrawableObject OptionsGUI;
IDrawableObject LoginGUI; IDrawableObject LoginGUI;
@ -45,6 +48,8 @@ namespace DangerousD.GameCore
SettingsManager = new SettingsManager(); SettingsManager = new SettingsManager();
SettingsManager.LoadSettings(); SettingsManager.LoadSettings();
NetworkManager.GetReceivingMessages += NetworkSync;
resolution = SettingsManager.Resolution; resolution = SettingsManager.Resolution;
_graphics.PreferredBackBufferWidth = resolution.X; _graphics.PreferredBackBufferWidth = resolution.X;
_graphics.PreferredBackBufferHeight = resolution.Y; _graphics.PreferredBackBufferHeight = resolution.Y;
@ -169,5 +174,34 @@ namespace DangerousD.GameCore
} }
} }
public void NetworkSync(NetworkTask networkTask)
{
//TODO
return;
switch (networkTask.operation)
{
case NetworkTaskOperationEnum.TakeDamage:
break;
case NetworkTaskOperationEnum.SendSound:
SoundManager.StartSound(networkTask.name, networkTask.position, GameManager.GetPlayer1.Pos);
break;
case NetworkTaskOperationEnum.CreateEntity:
break;
case NetworkTaskOperationEnum.SendPosition:
break;
case NetworkTaskOperationEnum.ChangeState:
break;
case NetworkTaskOperationEnum.ConnectToHost:
break;
case NetworkTaskOperationEnum.GetClientPlayerId:
break;
default:
break;
}
}
public void SetMultiplayerState(MultiPlayerStatus multiPlayerStatus)
{
this.multiPlayerStatus = multiPlayerStatus;
}
} }
} }

View file

@ -12,7 +12,7 @@ namespace DangerousD.GameCore
{ {
public class GameManager public class GameManager
{ {
public List<GameObject> GetAllGameObjects { get; private set; }
public List<LivingEntity> livingEntities; public List<LivingEntity> livingEntities;
public List<Entity> entities; public List<Entity> entities;
public List<MapObject> mapObjects; public List<MapObject> mapObjects;
@ -23,6 +23,7 @@ namespace DangerousD.GameCore
public Player GetPlayer1 { get; private set; } public Player GetPlayer1 { get; private set; }
public GameManager() public GameManager()
{ {
GetAllGameObjects = new List<GameObject>();
livingEntities = new List<LivingEntity>(); livingEntities = new List<LivingEntity>();
mapObjects = new List<MapObject>(); mapObjects = new List<MapObject>();
entities = new List<Entity>(); entities = new List<Entity>();

View file

@ -144,32 +144,31 @@ namespace DangerousD.GameCore.Managers
{ {
rectangle.X = (int)(entity2.Pos.X + (i / length) * distance.X); rectangle.X = (int)(entity2.Pos.X + (i / length) * distance.X);
rectangle.Y = (int)(entity2.Pos.Y + (i / length) * distance.Y); rectangle.Y = (int)(entity2.Pos.Y + (i / length) * distance.Y);
for (int j = 0; j < AppManager.Instance.GameManager.entities.Count; j++)
{
if (AppManager.Instance.GameManager.entities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.entities[i];
}
}
for (int r = 0; r < AppManager.Instance.GameManager.mapObjects.Count; r++)
{
if (AppManager.Instance.GameManager.mapObjects[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.mapObjects[i];
}
}
for (int w = 0; w < AppManager.Instance.GameManager.livingEntities.Count; w++)
{
if (AppManager.Instance.GameManager.livingEntities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.livingEntities[i];
}
}
} }
for (int i = 0; i < AppManager.Instance.GameManager.entities.Count; i++)
{ return null;
if (AppManager.Instance.GameManager.entities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.entities[i];
}
}
for (int i = 0; i < AppManager.Instance.GameManager.mapObjects.Count; i++)
{
if (AppManager.Instance.GameManager.mapObjects[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.mapObjects[i];
}
}
for (int i = 0; i < AppManager.Instance.GameManager.livingEntities.Count; i++)
{
if (AppManager.Instance.GameManager.livingEntities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.livingEntities[i];
}
}
return gameObject;
} }
public GameObject RayCast(LivingEntity entity1, Vector2 targetCast) public GameObject RayCast(LivingEntity entity1, Vector2 targetCast)
{ {
@ -182,29 +181,47 @@ namespace DangerousD.GameCore.Managers
{ {
rectangle.X = (int)(targetCast.X + (i / k) * direction.X); rectangle.X = (int)(targetCast.X + (i / k) * direction.X);
rectangle.Y = (int)(targetCast.Y + (i / k) * direction.X); rectangle.Y = (int)(targetCast.Y + (i / k) * direction.X);
for (int j = 0; j < AppManager.Instance.GameManager.entities.Count; j++)
{
if (AppManager.Instance.GameManager.entities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.entities[i];
}
}
for (int r = 0; r < AppManager.Instance.GameManager.mapObjects.Count; r++)
{
if (AppManager.Instance.GameManager.mapObjects[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.mapObjects[i];
}
}
for (int w = 0; w < AppManager.Instance.GameManager.livingEntities.Count; w++)
{
if (AppManager.Instance.GameManager.livingEntities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.livingEntities[i];
}
}
} }
for (int i = 0; i < AppManager.Instance.GameManager.entities.Count; i++)
{
if (AppManager.Instance.GameManager.entities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.entities[i];
}
}
for (int i = 0; i < AppManager.Instance.GameManager.mapObjects.Count; i++)
{
if (AppManager.Instance.GameManager.mapObjects[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.mapObjects[i];
}
}
for (int i = 0; i < AppManager.Instance.GameManager.livingEntities.Count; i++)
{
if (AppManager.Instance.GameManager.livingEntities[i].Rectangle.Intersects(rectangle))
{
return AppManager.Instance.GameManager.livingEntities[i];
}
}
return null; return null;
} }
public List<GameObject> CheckRectangle(Rectangle rectangle, Type type)
{
var gameObjects = AppManager.Instance.GameManager.GetAllGameObjects;
List<GameObject> intersected = new List<GameObject>();
for (int i = 0; i < gameObjects.Count; i++)
{
if (gameObjects[i].GetType() == type)
{
if (gameObjects[i].Rectangle.Intersects(rectangle))
{
intersected.Add(gameObjects[i]);
}
}
}
return intersected;
}
} }
} }

View file

@ -33,8 +33,11 @@ namespace DangerousD.GameCore
sound.SoundEffect.IsLooped = false; sound.SoundEffect.IsLooped = false;
sound.SoundEffect.Play(); sound.SoundEffect.Play();
PlayingSounds.Add(sound); PlayingSounds.Add(sound);
if (AppManager.Instance.multiPlayerStatus == MultiPlayerStatus.Host)
{
AppManager.Instance.NetworkManager.SendMsg(new Network.NetworkTask(Vector2.Zero, soundName));
}
} }
public void StartSound(string soundName, Vector2 soundPos, Vector2 playerPos) // запустить звук у которого есть позиция public void StartSound(string soundName, Vector2 soundPos, Vector2 playerPos) // запустить звук у которого есть позиция
{ {
var sound = new Sound(Sounds[soundName], soundPos); var sound = new Sound(Sounds[soundName], soundPos);
@ -42,6 +45,10 @@ namespace DangerousD.GameCore
sound.SoundEffect.Volume = (float)sound.GetDistance(playerPos) / MaxSoundDistance; sound.SoundEffect.Volume = (float)sound.GetDistance(playerPos) / MaxSoundDistance;
sound.SoundEffect.Play(); sound.SoundEffect.Play();
PlayingSounds.Add(sound); PlayingSounds.Add(sound);
if (AppManager.Instance.multiPlayerStatus == MultiPlayerStatus.Host)
{
AppManager.Instance.NetworkManager.SendMsg(new Network.NetworkTask(soundPos, soundName));
}
} }
public void StopAllSounds() // остановка всех звуков public void StopAllSounds() // остановка всех звуков
{ {

View file

@ -21,20 +21,27 @@ namespace DangerousD.GameCore.Network
private void Init(string IpAddress) private void Init(string IpAddress)
{ {
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); try
IPAddress address = IPAddress.Parse(IpAddress); {
int port = 8000; socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
endPoint = new IPEndPoint(address, port); IPAddress address = IPAddress.Parse(IpAddress);
int port = 8000;
endPoint = new IPEndPoint(address, port);
}
catch { }
} }
private void AcceptSockets() private void AcceptSockets()
{ {
while (true) while (true)
{ {
Socket clientSocket = socket.Accept(); try
clientSockets.Add(clientSocket); {
Thread receiveThread = new Thread(BeginHostReceive); Socket clientSocket = socket.Accept();
receiveThread.Start(clientSocket); clientSockets.Add(clientSocket);
Console.WriteLine("Connected"); Thread receiveThread = new Thread(BeginHostReceive);
receiveThread.Start(clientSocket);
}
catch { }
} }
} }
@ -43,77 +50,106 @@ namespace DangerousD.GameCore.Network
Socket clientSocket = clSocket as Socket; Socket clientSocket = clSocket as Socket;
while (clientSocket != null) while (clientSocket != null)
{ {
byte[] bytesCount = new byte[4]; try
clientSocket.Receive(bytesCount); {
byte[] Data = new byte[BitConverter.ToInt32(bytesCount)]; byte[] bytesCount = new byte[4];
StateObject so = new StateObject(clientSocket, Data); clientSocket.Receive(bytesCount);
IAsyncResult count = clientSocket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, AsyncReceiveCallback, so); byte[] Data = new byte[BitConverter.ToInt32(bytesCount)];
StateObject so = new StateObject(clientSocket, Data);
IAsyncResult count = clientSocket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, AsyncReceiveCallback, so);
}
catch { }
} }
} }
public void HostInit(string IpAddress) public void HostInit(string IpAddress)
{ {
Init(IpAddress); try
socket.Bind(endPoint); {
socket.Listen(4); Init(IpAddress);
Thread acceptThread = new Thread(AcceptSockets); socket.Bind(endPoint);
acceptThread.Start(); socket.Listen(4);
state = "Host"; Thread acceptThread = new Thread(AcceptSockets);
Console.WriteLine("Start Accept"); acceptThread.Start();
state = "Host";
}
catch { }
} }
public void ClientInit(string IpAddress) public void ClientInit(string IpAddress)
{ {
Init(IpAddress); try
socket.Connect(endPoint); {
state = "Client"; Init(IpAddress);
Thread.Sleep(10); socket.Connect(endPoint);
Thread ReceivingThread = new Thread(ReceiveMsgFromHost); state = "Client";
ReceivingThread.Start(); Thread.Sleep(10);
Thread ReceivingThread = new Thread(ReceiveMsgFromHost);
ReceivingThread.Start();
}
catch { }
} }
public void SendMsg(NetworkTask networkTask) public void SendMsg(NetworkTask networkTask)
{ {
//TODO
return;
byte[] Data = Encoding.Unicode.GetBytes(JsonConvert.SerializeObject(networkTask)); byte[] Data = Encoding.Unicode.GetBytes(JsonConvert.SerializeObject(networkTask));
int count = Data.Length; int count = Data.Length;
if (state == "Host") if (state == "Host")
{ {
foreach (Socket socket in clientSockets) try
{
foreach (Socket socket in clientSockets)
{
socket.Send(BitConverter.GetBytes(count));
socket.Send(Data);
}
}
catch { }
}
else
{
try
{ {
socket.Send(BitConverter.GetBytes(count)); socket.Send(BitConverter.GetBytes(count));
socket.Send(Data); socket.Send(Data);
} }
} catch { }
else
{
socket.Send(BitConverter.GetBytes(count));
socket.Send(Data);
} }
} }
private void ReceiveMsgFromHost() private void ReceiveMsgFromHost()
{ {
while (true) while (true)
{ {
byte[] bytesCount = new byte[4]; try
socket.Receive(bytesCount); {
byte[] Data = new byte[BitConverter.ToInt32(bytesCount)]; byte[] bytesCount = new byte[4];
StateObject so = new StateObject(socket, Data); socket.Receive(bytesCount);
IAsyncResult count = socket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, AsyncReceiveCallback, so); byte[] Data = new byte[BitConverter.ToInt32(bytesCount)];
StateObject so = new StateObject(socket, Data);
IAsyncResult count = socket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, AsyncReceiveCallback, so);
}
catch { }
} }
} }
private void AsyncReceiveCallback(IAsyncResult ar) private void AsyncReceiveCallback(IAsyncResult ar)
{ {
StateObject so = ar.AsyncState as StateObject; try
Socket clientSocket = so.workSocket;
int readCount = clientSocket.EndReceive(ar);
so.UploadedBytesCount += readCount;
so.sb.Append(Encoding.Unicode.GetString(so.buffer, 0, readCount));
if (so.UploadedBytesCount < so.bufferSize)
{ {
clientSocket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, new AsyncCallback(AsyncReceiveCallback), so); StateObject so = ar.AsyncState as StateObject;
} Socket clientSocket = so.workSocket;
else int readCount = clientSocket.EndReceive(ar);
{ so.UploadedBytesCount += readCount;
GetReceivingMessages(JsonConvert.DeserializeObject<NetworkTask>(so.sb.ToString())); so.sb.Append(Encoding.Unicode.GetString(so.buffer, 0, readCount));
if (so.UploadedBytesCount < so.bufferSize)
{
clientSocket.BeginReceive(so.buffer, 0, so.bufferSize, SocketFlags.None, new AsyncCallback(AsyncReceiveCallback), so);
}
else
{
GetReceivingMessages(JsonConvert.DeserializeObject<NetworkTask>(so.sb.ToString()));
}
} }
catch { }
} }
} }
} }

View file

@ -13,6 +13,7 @@ namespace DangerousD.GameCore.Network
public NetworkTaskOperationEnum operation { get; set; } public NetworkTaskOperationEnum operation { get; set; }
public string name { get; set; } public string name { get; set; }
public int value { get; set; } public int value { get; set; }
public bool isParam { get; set; }
public int objId { get; set; } public int objId { get; set; }
public Vector2 position { get; set; } public Vector2 position { get; set; }
public Vector2 velocity { get; set; } public Vector2 velocity { get; set; }
@ -102,5 +103,28 @@ namespace DangerousD.GameCore.Network
operation = NetworkTaskOperationEnum.GetClientPlayerId; operation = NetworkTaskOperationEnum.GetClientPlayerId;
objId = PlayerId; objId = PlayerId;
} }
/// <summary>
/// Универсальный конструктор для нестандартных операций. То, что не нужно(кроме операции) делать null.
/// </summary>
/// <param name="operation"></param>
/// <param name="name"></param>
/// <param name="value"></param>
/// <param name="isParam"></param>
/// <param name="objId"></param>
/// <param name="position"></param>
/// <param name="velocity"></param>
/// <param name="type"></param>
public NetworkTask(NetworkTaskOperationEnum operation, string name, int value, bool isParam, int objId, Vector2 position, Vector2 velocity, Type type)
{
this.operation = operation;
this.name = name;
this.value = value;
this.isParam = isParam;
this.objId = objId;
this.position = position;
this.velocity = velocity;
this.type = type;
}
} }
} }