Witam,
najpierw zamieszczę fragmenty kodu, a na dole dokładniejszy opis problemu.
Kod serwera:
namespace SnakeServer
{
public struct DataClients
{
public DataClients(int Id, TcpClient Socket)
{
this.Id = Id;
this.Socket = Socket;
}
public int Id {get; set;}
public TcpClient Socket {get; set;}
}
public class Program
{
private static TcpListener _serverListener = null;
private static Int32 _port = 8888;
private static IPAddress _localAddr = IPAddress.Parse("127.0.0.1");
public static List<DataClients> _clientSockets = new List<DataClients>();
static void Main(string[] args)
{
_serverListener = new TcpListener(_localAddr, _port);
_serverListener.Start();
Console.WriteLine(" >> " + "Server Started");
Console.WriteLine("The local End point is :" + _serverListener.LocalEndpoint);
while (true)
{
TcpClient _clientSocketNew = _serverListener.AcceptTcpClient();
DataClients data = new DataClients(_clientSockets.Count + 1, _clientSocketNew);
_clientSockets.Add(data);
handleClient client = new handleClient();
client.startClient(_clientSocketNew);
}
}
public class handleClient
{
private TcpClient clientSocket;
public void startClient(TcpClient inClientSocket)
{
clientSocket = inClientSocket;
Thread clientThread = new Thread(doChat);
clientThread.Start();
}
private void doChat()
{
while (true)
{
try
{
String toSend;
BinaryReader reader = new BinaryReader(clientSocket.GetStream());
toSend = reader.ReadString();
if(toSend[0] == '!')
{
foreach(DataClients ct in _clientSockets)
{
if(ct.Id == (int)Char.GetNumericValue(toSend[1]))
{
_clientSockets.RemoveAt(ct.Id - 1);
break;
}
}
break;
}
if (_clientSockets.Count > 1)
{
for (int i = 0; i < _clientSockets.Count; i++)
{
if (_clientSockets[i].Socket != clientSocket)
{
BinaryWriter writer = new BinaryWriter(_clientSockets[i].Socket.GetStream());
writer.Write(_clientSockets[i].Id.ToString() + "*" + toSend);
}
}
}
else
{
BinaryWriter writer = new BinaryWriter(clientSocket.GetStream());
writer.Write(_clientSockets[0].Id.ToString() + "*" + "0");
}
}
catch (Exception ex)
{
Console.WriteLine(" >> " + ex.ToString());
}
}
}
}
}
Kod klienta:
namespace SnakeGame
{
public partial class GamePlay : UserControl
{
TcpClient clientSocket = new TcpClient();
NetworkStream serverStream;
private DispatcherTimer timer;
private int snakeSpeed = 80;
private string coordinatesToSend;
Snake snake;
List<Food> food;
Random rd = new Random();
//Here I have some other variables but they have no meant in this case (there aren't related to connection)
public GamePlay()
{
InitializeComponent();
snake = new Snake(x, y);
snake.InitSnake();
}
private void UserControl_Loaded(object sender, RoutedEventArgs e)
{
this.KeyDown += UserControl_KeyDown;
this.Focusable = true;
this.Focus();
addfoodincanvas();
addsnakeincanvas();
clientSocket.Connect("127.0.0.1", 8888);
InitTimer();
}
void InitTimer()
{
timer = new DispatcherTimer();
timer.Tick += new EventHandler(TimerTick);
timer.Interval = new TimeSpan(0, 0, 0, 0, snakeSpeed);
timer.Start();
}
void TimerTick(object sender, EventArgs e)
{
//Here some code responsible for movement of snake
//Here is some code to check collision snake with food
//snake is composed of objects SnakePart class
foreach(SnakePart part in snake.Parts)
{
coordinatesToSend += part.X.ToString();
coordinatesToSend += ",";
coordinatesToSend += part.Y.ToString();
coordinatesToSend += ";";
}
serverStream = clientSocket.GetStream();
BinaryWriter writer = new BinaryWriter(serverStream);
writer.Write(coordinatesToSend);
string fromServer;
BinaryReader reader = new BinaryReader(serverStream);
fromServer = reader.ReadString();
//I receive some strings from server (each of that strings contains the id of client and coordinates of his snake)
//I split that strings by separators and draw snakes of the enemies in my canvas based on this coordinates.
}
}
Piszę grę snake typu klient-serwer (jeden serwer - aplikacja konsolowa i wielu klientów (graczy)), gra jest aplikacją WPF. No i zrobiłem to z użyciem klas TcpListener i TcpClient, w kodzie serwera dla każdego akceptowanego klienta tworzę nowy wątek i w tym nowym wątku obługuję połączenie z danym klientem (wysyłam i odbieram odpowiednie dane). Jednak mam problem z synchronizacją, tzn. jeśli jest tylko dwóch graczy (dwóch klientów), to wszystko działa ok, jednak gdy połączy się 3, to zaczynają się problemy, węże nie są odpowiednio rysowane na planszach, wygląda to tak jakby dane które serwer odsyła do klientów się jakoś mieszały. Ogólnie to działa w ten sposób, że mam tę główną klasę klienta (GamePlay) i tam tworzę obiekt klasy Snake (który składa się z obiektów klasy SnakeParts, każda część to prostokąt) no i w klasie GamePlay mam całą mechanikę (kolizje, dodawanie węża do Canvas i obsługę połączenia). Skoro wąż składa się z części (ich liczba zależy oczywiście od długości węża i zmienia się dynamicznie podczas gry), to przechodzę po całej liście zawierającej poszczególne części, współrzędne każdej z nich parsuje do stringa, ogólnie wszystko łączę w jednego stringa i taki napis wysyłam do serwera, on odsyła to do pozostałych klientów (graczy), oni odbierają te napisy, odpowiednio splitują po separatorach i rysują na swojej planszy węże innych graczy na otrzymanych od serwera pozycjach. Jednak nie wiem jak to wszystko w sposób właściwy zorganizować, bo tak jak wspomniałem te dane podczas odbierania bądź wysyłania się mieszają, gdy jest 3 klientów bądź więcej, przez co wszystko jest źle rysowane. Druga kwestia to dodanie odpowiedniej obsługi błędów, np. gdy klient się rozłączy itd (w tej chwili zrobiłem, że jak wcisnę przycisk "Back to menu", to klient wysyła do serwera napis " string msg = "!" + "id_danego_klienta" ", jeśli serwer odbierze dane i pierwszy znak to właśnie "!", to usuwa socket danego klienta z listy, a klient wykonuje "serverStream.Close(); clientSocket.Close();", czyli zamyka odpowiedni strumień i gniazdo, jednak to nie działa ... poza tym muszę też jakoś dodać mechanizm wykrywania kolizji z innymi graczami (wężami), jak to zrobić najlepiej w tym przypadku. Ogólnie jestem początkujący jeśli chodzi o C#, zdaje sobie sprawę, że powinienem, to jakoś lepiej napisać, użyć wzorca MVC, bądź MVVM, jednak póki co chciałbym naprawić, to co już mam. Wei ktoś w jaki sposób naprawić mój kod, aby to połączenie działało poprawnie?