Мое приложение предотвращает закрытие окон, но только на некоторых компьютерах, а не постоянно. Его немного сложно отладить.
Я думаю, что это связано с моим TCP-сервером. Это асинхронный сервер, и мое приложение обрабатывает CloseReason == WindowsShutDown.
Когда это происходит, мое приложение все еще работает как процесс, но не доступно на панели задач / в системном трее.
Мне было интересно, если кто-нибудь может увидеть какие-либо очевидные проблемы с моим кодом сервера.
Ниже приведен код моего сервера. Метод Stop () вызывается из основного события Close () форм.
public class MantraServer
{
protected int portNumber;
private bool ShuttingDown = false;
//the main socket the server listens to
Socket listener;
//Constructor - Start a server on the given IP/port
public MantraServer(int port, IPAddress IP)
{
this.portNumber = port;
Start(IP);
}
///
/// Description: Start the threads to listen to the port and process
/// messages.
///
public void Start(IPAddress IP)
{
try
{
//We are using TCP sockets
listener = new Socket(AddressFamily.InterNetwork,
SocketType.Stream,
ProtocolType.Tcp);
//Assign the any IP of the machine and listen on port number 3000
IPEndPoint ipEndPoint = new IPEndPoint(IP, 3000);
//Bind and listen on the given address
listener.Bind(ipEndPoint);
listener.Listen(10);
//Accept the incoming clients
listener.BeginAccept(new AsyncCallback(OnAccept), listener);
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "MANTRA Network Start Error",
MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
/// Decription: Stop the threads for the port listener.
public bool Stop()
{
try
{
ShuttingDown = true;
listener.Shutdown(SocketShutdown.Both);
listener.Close();
listener = null;
System.Threading.Thread.Sleep(500); //wait for half second while the server closes
return true;
}
catch (Exception)
{
return false;
}
}
///
/// Decription: Call back method to accept new connections.
/// <param name="ar">Status of an asynchronous operation.</param>
private void OnAccept(IAsyncResult ar)
{
try
{
if (!ShuttingDown)
{
MantraStatusMessage InMsg = new MantraStatusMessage();
InMsg.Socket = ((Socket)ar.AsyncState).EndAccept(ar);
//Start listening for more clients
listener.BeginAccept(new AsyncCallback(OnAccept), listener);
//Once the client connects then start receiving the commands from them
InMsg.Socket.BeginReceive(InMsg.buffer, 0, InMsg.buffer.Length, SocketFlags.None,
new AsyncCallback(OnReceive), InMsg);
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message, "MANTRA Network Accept Error",
MessageBoxButtons.OK, MessageBoxIcon.Error);
}
}
///
/// Receives the data, puts it in a buffer and checks if we need to receive again.
public void OnReceive(IAsyncResult result)
{
MantraStatusMessage InMsg = (MantraStatusMessage)result.AsyncState;
int read = InMsg.Socket.EndReceive(result);
if (read > 0)
{
for (int i = 0; i < read; i++)
{
InMsg.TransmissionBuffer.Add(InMsg.buffer[i]);
}
//we need to read again if this is true
if (read == InMsg.buffer.Length)
{
InMsg.Socket.BeginReceive(InMsg.buffer, 0, InMsg.buffer.Length, SocketFlags.None, OnReceive, InMsg);
Console.Out.WriteLine("Message Too big!");
}
else
{
Done(InMsg);
}
}
else
{
Done(InMsg);
}
}
///
/// Deserializes and outputs the received object
public void Done(MantraStatusMessage InMsg)
{
Console.Out.WriteLine("Received: " + InMsg.msg);
MantraStatusMessage received = InMsg.DeSerialize();
Console.WriteLine(received.msg.Message);
}
}
EDIT
Благодаря Хогану, еще немного информации о звонке в Close ():
Запрос на отправку или получение данных был отклонен, поскольку сокет не подключен и (при отправке на сокет дейтаграммы с использованием вызова sendto) адрес не был указан.
Не совсем уверен, что это значит.