Myujth

I am trying to create network application in C# by establishing communication
by creating TCP server and client application.

But I am keep getting the Exception:

"An existing connection was forcibly closed by the remote host"
on the line:
int bytesReceived = clientsocket.Receive(dataRecieved);

Can Anyone help me resolve this error.
Here is My code:

Client Code:

namespace Client
 
/// <summary>
/// Interaction logic for MainWindow.xaml
/// </summary>
public partial class MainWindow : Window

 string text;
 public static Socket clientsocket;
 public MainWindow()
 
 InitializeComponent();
 

 private void connectbutton_Click(object sender, RoutedEventArgs e)
 
 IPAddress ipaddress = IPAddress.Parse("127.0.0.1");
 int port = 11000;
 IPEndPoint remoteEndPoint = new IPEndPoint(ipaddress, port);
 clientsocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 clientsocket.Connect(remoteEndPoint);
 

 private void search_btn_Click(object sender, RoutedEventArgs e)
 
 text = ((TextBox)grid.FindName("search")).Text;
 byte datasent = Encoding.ASCII.GetBytes(text);
 int bytesent = clientsocket.Send(datasent);
 byte dataRecieved = new byte[10 * 1024];
 int bytesReceived = clientsocket.Receive(dataRecieved);
 DataTable table = Deserailize(dataRecieved);
 
 private static DataTable Deserailize(byte dataRecieved)
 
 System.IO.MemoryStream stream = new System.IO.MemoryStream(dataRecieved);
 System.Runtime.Serialization.IFormatter formatter = new System.Runtime.
 Serialization.Formatters.Binary.BinaryFormatter();
 DataTable table = (DataTable)formatter.Deserialize(stream);
 return table;
 

Server Code:

 namespace Server
 
class Program

 static void Main(string args)
 
 IPAddress ipaddress = IPAddress.Parse("127.0.0.1");
 int port = 11000;
 IPEndPoint localEndPoint = new IPEndPoint(ipaddress, port);
 Socket connectionsocket = null;
 try
 
 Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
 serverSocket.Bind(localEndPoint);
 serverSocket.Listen(1);
 Console.WriteLine("Waiting For Connection");
 connectionsocket = serverSocket.Accept();
 Console.WriteLine("Connection Accepted");
 while(true)
 
 byte bytes = new byte[1024];
 int byterecieved = connectionsocket.Receive(bytes);
 string text = Encoding.ASCII.GetString(bytes, 0, byterecieved);
 DataTable table = DB.getCustomer(text);
 byte bytessent= serailize(table);
 connectionsocket.Send(bytessent);
 
 
 catch (Exception e)
 

 
 
 private static byte serailize(DataTable table)
 
 System.IO.MemoryStream stream = new System.IO.MemoryStream();
 System.Runtime.Serialization.IFormatter formatter = new System.Runtime.
 Serialization.Formatters.Binary.BinaryFormatter();
 formatter.Serialize(stream, table);
 byte byteArray = stream.GetBuffer();
 return byteArray;
 

DataBase class:

class DB

 public static SqlConnection con = new SqlConnection();
 public static string ConnectionString = @"Data Source=DESKTOP-9CG0F5H;Initial Catalog=worksheet3;Integrated Security=True";
 static DB()
 
 con = new SqlConnection(ConnectionString);
 con.Open();
 
 public static DataTable getCustomer(string text)
 
 SqlCommand command = new SqlCommand();
 command.Connection = con;
 command.CommandText = "Select * from Student where StudentName=@StudentName";
 SqlDataAdapter adaptor = new SqlDataAdapter(command);
 DataTable table = new DataTable();
 adaptor.Fill(table);
 return table;
 

}