private void RunCommunicationNewClient(object obj) { var client = (Socket)obj; if (client.Connected) { while (true) { { var buffer = new byte[1024]; client.Receive(buffer); foreach (var sk in _sockets) { sk.Send(buffer, buffer.Length, SocketFlags.None); } } } } }
while (true) { { var buffer = new byte[1024]; client.Receive(buffer);//An existing connection was forcibly closed by the remote host foreach (var sk in _sockets) { sk.Send(buffer, buffer.Length, SocketFlags.None); } } }
private void ButtonLoginClick(object sender, EventArgs e) { _buffer = new byte[1024]; _buffer = Encoding.ASCII.GetBytes(textUserName.Text); _socket.Send(_buffer); _buffer = new byte[1024]; _buffer = Encoding.ASCII.GetBytes(textPassword.Text); _socket.Send(_buffer); } private void ConnectToServer() { try { _ipEndPoint = new IPEndPoint(IPAddress.Parse("192.168.1.33"), 2009); _socket.Connect(_ipEndPoint); var vThreadConnect = new Thread(RecevieceData) { IsBackground = true }; vThreadConnect.Start(_socket); } catch { ConnectToServer(); } } private void RecevieceData(object obj) { var socket = (Socket)obj; while (true) { try { _buffer = new byte[1024]; socket.Receive(_buffer); var info = Encoding.ASCII.GetString(_buffer); MessageBox.Show(Application.ProductName + info); } catch { Disconnect(); MessageBox.Show(Resources.Form1_RecevieceData_da_thoat_ket_noi); break; } } } private void Form1Load(object sender, EventArgs e) { _threadConnect = new Thread(ConnectToServer) { IsBackground = true }; _threadConnect.Start(); } private void Disconnect() { _socket.Close(); _threadConnect.Abort(); Environment.Exit(0); } protected override void OnClosing(System.ComponentModel.CancelEventArgs e) { Environment.Exit(1); }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)