Я написал свой СМТП-сервис (windows-сервис), который через сетки после запуска и работы скушал 96% мощности сервака, где размещен.
Вопрос - подскажите, как уменьшить потребляемые ресурсы?
Вот код:
protected override void OnStart(string[] args)
{
try
{
SmtpHelper s = new SmtpHelper(this);
Thread listen = new Thread(new ThreadStart(s.Listen));
listen.Start();
}
catch (Exception ex)
{
EventLog.WriteEntry( ServiceName + " error: \n" + ex.ToString());
}
}
потом:
public void Listen()
{
try
{
l.WriteEvent("***************START*******************");
l.WriteEvent("SMTP server started " + DateTime.Now.ToString());
SMTP_Listener = new TcpListener(IPAddress.Any, port);
SMTP_Listener.Start();
while (true)
{
/*
Создадим сначала номер потока и файл логов для него
*/
Socket clientSocket = SMTP_Listener.AcceptSocket();
//номер сессии(клиента)
_sessionId = clientSocket.GetHashCode().ToString();
_email.sessionId = Convert.ToInt32(_sessionId);
l.WriteEvent("Создан поток для обработки клиента: " + _sessionId);
//запускаем обработку клиента
var processor = new ClientProcessor(clientSocket, m_ConnectedIp, m_ConnectedHostName, _email,
MaxMessageSize, CommandIdleTimeOut);
processor._sessionId = _sessionId;
UserSessionController.AddSession(Convert.ToInt32(_sessionId));
Thread newClient = new Thread(processor.StartProcessing);
newClient.Name = _sessionId;
//newClient.IsBackground = true; // ???
newClient.Start();
// l.WriteEvent("*********************************************************");
}
}
catch (ThreadInterruptedException e)
{
l.WriteEvent("SMTP Listen ThreadInterruptedException: " + e.ToString());
l.WriteLogEvent("SMTP Listen ThreadInterruptedException: " + e.ToString(), _email);
Thread.CurrentThread.Abort();
}
catch (Exception ex)
{
l.WriteEvent("SMTP Listen Error: " + ex.ToString());
l.WriteLogEvent("SMTP Listen Error: " + ex.ToString(), _email);
throw;
}
}
Каждый клиент обрабатывается в своем потоке.
public void StartProcessing()
{
try
{
string namethread = _sessionId;
_connectedIp = ParseIP_from_EndPoint(_clientSocket.RemoteEndPoint.ToString());
_connectedHostName = GetHostName(_connectedIp);
l.WriteEvent(String.Format("Клиент {0}: _connectedIp = {1}, _connectedHostName = {2}", _sessionId, _connectedIp,
_connectedHostName), namethread);
_email.ip = _connectedIp;
_email.port = 25;
SendData("220 " + Dns.GetHostName() + " Service ready\r\n");// l.WriteEvent("'220 " + Dns.GetHostName() + " Service ready' были отправлены клиенту", namethread);
//ЦИКЛ ПРИЕМА КОМАНД ОТ КОНКРЕТНОГО КЛИЕНТА
while (true){
//если есть данные, то считаем их
if (_clientSocket.Available > 0)
{
//чтение команды клиента
string lastCmd = ReadLine();
//парсим команду
if (lastCmd.Trim() != String.Empty)
ProceedCommand(lastCmd, namethread);
}
}
}
catch (Exception ex)
{
l.WriteEvent("SMTP StartProcessing Error: " + ex.ToString());
throw;
}
}
Обработка команд клиента:
/// <summary>
/// Обработка команд сервиса
/// </summary>
/// <param name="SMTP_commandTxt">текст команды клиента </param>
private void ProceedCommand(string SMTP_commandTxt, string threadName)
{
//обработчик клиентских команд
CommandWorking _commandWorking = new CommandWorking(_connectedIp, _maxMessageSize, _connectedHostName, _clientSocket, _commandIdleTimeOut, _email, l);
//парсим команду
string[] cmdParts = SMTP_commandTxt.TrimStart().Split(new char[] { ' ' });
//текст команды
string SMTP_command = cmdParts[0].ToUpper().Trim();
//аргументы команды
string argsText = GetArgsText(SMTP_commandTxt, SMTP_command);
//debug:
//l.WriteEvent("SMTP комманда: " + SMTP_command + " " + argsText, threadName);
//Ответ нашего сервера на каждую команду клиента
string answer = String.Empty;
switch (SMTP_command)
{
case "HELO":
answer = _commandWorking.HELO();
SendData(answer);
break;
case "EHLO":
answer = _commandWorking.EHLO();
SendData(answer);
break;
case "AUTH":
answer = _commandWorking.AUTH();
SendData(answer);
break;
case "MAIL":
answer = _commandWorking.MAIL();
SendData(answer);
break;
case "RCPT":
answer = _commandWorking.RCPT(argsText, threadName);
if (answer.Split('|').Count() == 2)
{
string sendData = answer.Split('|')[0].ToString();
SendData(sendData);
//получатель почты:
_email.recipient = answer.Split('|')[1].ToString();
}
else
{
//возвращаем ошибку
SendData(answer);
// l.WriteEvent("<<<" + answer + "\n Получателя почты не удалось определить", threadName);
}
break;
case "DATA":
_commandWorking.DATA(argsText, threadName);
//отправить СМС
Finish(threadName);
break;
case "BDAT":
_commandWorking.BDAT(argsText, threadName);
//отправить СМС
Finish(threadName);
break;
case "RSET":
answer = _commandWorking.RSET();
SendData(answer);
break;
case "VRFY":
answer = _commandWorking.VRFY();
SendData(answer);
break;
case "EXPN":
answer = _commandWorking.EXPN();
SendData(answer);
break;
case "HELP":
answer = _commandWorking.HELP();
SendData(answer);
break;
case "NOOP":
answer = _commandWorking.NOOP();
SendData(answer);
break;
case "QUIT":
answer = _commandWorking.QUIT();
SendData(answer);
// l.WriteEvent("***************** Закрыта сессия " + _email.sessionId.ToString() + " *****************\n", threadName);
l.WriteEvent(">>> Закрыта сессия: " + _email.sessionId.ToString(), threadName);
_clientSocket.Disconnect(true);
// _clientSocket.Dispose();
break;
default:
SendData("500 command unrecognized\r\n");
l.WriteEvent("500 command unrecognized: " + SMTP_command, threadName);
_clientSocket.Close();
// _clientSocket.Dispose();
//Thread.Sleep(100);
break;
}
}
По моему схема простая, но где-то просчет у меня. Мне подсказали, что может я потоки "размножаю", но по идее не так.
Как можно увеличить производительность?
UPD - так я считываю команды клиента
/// <summary>
/// Считываем команду клиента
/// </summary>
/// <returns></returns>
private string ReadLine()
{
try
{
long lastDataTime = DateTime.Now.Ticks;
ArrayList lineBuf = new ArrayList();
byte prevByte = 0;
while (true)
{
if (_clientSocket.Available > 0)
{
// Read next byte
byte[] currByte = new byte[1];
int countRecieved = _clientSocket.Receive(currByte, 1, SocketFlags.None);
// Count must be equal. Eg. some computers won't give byte at first read attempt
if (countRecieved == 1)
{
lineBuf.Add(currByte[0]);
// Line found
if ((prevByte == (byte)'\r' && currByte[0] == (byte)'\n'))
{
byte[] retVal = new byte[lineBuf.Count - 2]; // Remove <CRLF>
lineBuf.CopyTo(0, retVal, 0, lineBuf.Count - 2);
return Encoding.Default.GetString(retVal).Trim();
}
// Store byte
prevByte = currByte[0];
// reset last data time
lastDataTime = DateTime.Now.Ticks;
}
}
else
{
//---- Time out stuff -----------------------//
if (DateTime.Now.Ticks > lastDataTime + ((long)(60000)) * 10000)
{
return "";
}
//Thread.Sleep(100);
//------------------------------------------//
}
}
}
catch (Exception x)
{
l.WriteEvent("EROR ReadLine(): " + x.ToString());
throw new Exception(x.Message);
}
}