public class DemoServer : NetwInterface{
public override int StartMain(){
IPEndPoint MyServerIPPoint = new IPEndPoint(IPAddress.Loopback,1100);
MySocket = new Socket (MyServerIPPoint.Address.AddressFamily,SocketType.Stream,ProtocolType.Tcp);
//MessageServiceClass.MessageProcessing ("<=========Demo Server Try to bind "+MyServerIPPoint.Address.ToString());
Debug.Log("<=========Demo Server Try to bind "+MyServerIPPoint.Address.ToString());
try{
MySocket.Bind(MyServerIPPoint);
}
catch(SocketException exc){
MessageServiceClass.MessageProcessing("Socket exception: " + exc.SocketErrorCode.ToString());
}
MessageServiceClass.MessageProcessing ("<=========Demo Server binded and Try to begin listen");
MySocket.Listen(1); // Wait only 1 connections
// Waiting for connect & set other side socket
MySocket.BeginAccept(new AsyncCallback(AcceptCallback), MySocket);
MessageServiceClass.MessageProcessing ("Demo Server begin to listen from address "+MyServerIPPoint.Address.AddressFamily.ToString());
return 0;
}
private void AcceptCallback(IAsyncResult result)
{
try
{
// Завершение операции Accept
Socket s = (Socket)result.AsyncState;
MySocket = s.EndAccept(result);
MessageServiceClass.MessageProcessing ("SERVER: Demo Server Connected");
ConnectionStatus = true;
BeginReceive();
}
catch (SocketException exc)
{
SentDoneFlag = true;
MessageServiceClass.MessageProcessing("Socket exception: " + exc.SocketErrorCode.ToString());
}
catch (Exception exc)
{
SentDoneFlag = true;
Debug.Log("Exception: " + exc);
}
} // AcceptCallback
/// <summary>
/// Receives the callback.
/// </summary>
/// <param name='result'>
/// Result.
/// </param>
public override void Disconnect(){
ConnectionStatus = false;
MySocket.Close();
}
} //demoserver class
