Симон Робинсон - C# для профессионалов. Том II

Как предполагает название, служебная управляющая программа управляет службой. Для остановки, приостановки и возобновления работы службы ей посылаются управляющие коды, а обработчик должен реагировать на эти события. Также можно запрашивать службу о реальном статусе, при этом реализуется специальный обработчик, который отвечает на специальные управляющие коды.

Мы не можем использовать для установки службы хсору, так как службы должны конфигурироваться в реестре. Можно задать тип запуска как автоматический, ручной или отключенный. Необходимо сконфигурировать пользователя служебной программы и зависимости службы, например службы, которые должны начать работу перед тем, как запускается эта служба. Все конфигурации производятся внутри конфигурационной программа службы. Установка программы использует программу для конфигурирования службы, но эта программа может также использоваться позже для изменения параметров конфигурации службы.

В .NET Framework находятся классы служб в пространстве имен System.ServiceProcess, которые запускают три части службы:

□ Для реализации службы мы наследуем из класса ServiceBaseкоторый используется для регистрации служб и отвечает на запросы запуска и останова.

□ Класс ServiceControllerиспользуется для реализации служебной управляющей программы. С помощью этого класса можно посылать запросы службам.

□ Классы ServiceProcessInstallerи ServiceInstallerявляются, как предполагают их имена, классами для установки и конфигурирования служебных программ.

Давайте посмотрим, как создается новая служба

Создаваемая служба будет содержать сервер цитирования (quote server). Для каждого сделанного клиентом запроса сервер цитирования возвращает случайную цитату файла цитат. Первая часть решения будет сделана с помощью трех сборок: одна для клиента и две — для сервера. Сборка QuoteServerсодержит реальную функциональность. Мы прочитаем файл цитат в кэш памяти и будем отвечать на запросы цитат с помощью сервера сокета.

QuoteСlientявляется клиентским приложением Windows Forms. Это приложение создает клиентский сокет для коммуникации с QuoteServer. Третья сборка является реальной службой. QuoteServiceзапускает и останавливает QuoteServer, служба будет управлять сервером:

Прежде чем разработать служебную часть программы, создадим простой сервер сокета в дополнительной библиотеке классов C#, которая будет использоваться из процесса службы.

В системе Windows 2000 Server можно установить службы простого TCP/IP как компоненты Windows. Частью служб простого TCP/IP является сервер TCP/IP "цитата дня" ("quote of the day", кратко называемая "qotd"). Эта простая служба слушает порт 17 и отвечает на каждый запрос случайным сообщением из файла c:\winnt\system32\drivers\etc\quotes. Здесь будет создан аналогичный сервер. Только этот сервер возвращает строку Unicode, в отличие от старого qotd, который возвращает код ASCII.

Постепенно начнем создавать исходный код класса QuoteServerв файле QuoteServer.cs:

using System;

using System.IO;

using System.Threading;

using System.Net.Sockets;

using System.Text;

using System.Collections.Specialized;

namespace Wrox.ProfessionalCSharp {

///

/// Пример сервера сокета.

///

public class QuoteServer {

private TcpListener listener;

private int port;

private string filename;

private StringCollection quotes;

private Random random;

private Thread listenerThread;

Конструктор QuoteServer()является перезагруженным, чтобы имя файла и порт можно было передать в вызове. Конструктор, где передается только имя файла, использует для сервера по умолчанию порт 7890. Конструктор по умолчанию определяет имя файла по умолчанию для цитат как quotes.txt:

public QuoteServer() : this("quotes.txt") {}

public QuoteServer(string filename) : this(filename, 7890) {}

public QuoteServer(string filename, int port) {

this.filename = filename;

this.Port = port;

}

ReadQuotes()является вспомогательным методом, который читает все цитаты из файла, который был определен в конструкторе. Все цитаты добавляются в StringCollection quotes. Кроме того создается экземпляр класса Random, который будет использоваться для возврата случайных цитат:

protected void ReadQuotes() {

quotes = new StringCollection();

Stream stream = File.OpenRead(filename);

StreamReader StreamReader = new StreamReader(stream);

string quote;

while ((quote = streamReader.ReadLine()) != null) {

quotes.Add(quote);

}

streamReader.Close(); stream.Close();

random = new Random();

}

Другим вспомогательным методом является GetRandomQuoteOfTheDay(). Этот метод возвращает случайную цитату из цитат StringCollection quotes:

protected string GetRandomQuoteOfTheDay() {

int index = random.Next(0, quotes.Count); return quotes[index];

}

В методе Start()весь файл, содержащий цитаты, в StringCollection quotesсчитывается с помощью вспомогательной функции ReadQuotes(). После этого запускается новый поток выполнения, который незамедлительно вызывает метод Listener(). Мы используем поток выполнения, так как метод Start()не может блокироваться и ждать клиента, он должен сразу же вернуть управление вызывающей стороне (SCM). SCM предположит, что запуск отказал, если метод не вернет своевременно управление вызывающей стороне.

public void Start() {

ReadQuotes();

listenerThread = new Thread(new ThreadStart(this.Listener));

listenerThread.Start();

}

Функция потока выполнения Listener()создает экземпляр TCPListener. В методе AcceptSocket()ожидается соединение клиента. Как только клиент соединяется, AcceptSocket()возвращает управление с сокетом, связанным с клиентом. Метод GetRandomQuoteOfTheDay()вызывается для отправки возвращаемой случайной цитаты клиенту с помощью socket.Send():

protected void Listener() {

listener = new TcpListener(port);

listener.Start();

while (true); {

Socket socket = listener.AcceptSocket();

if (socket == null) {

return;

}

string message = GetRandomQuoteOfTheDay();

UnicodeEncoding encoder = new UnicodeEncoding();

byte [] buffer = encoder.GetBytes(message);

socket.Send(buffer, buffer.Length, 0);

socket.Close();

}

}

Помимо Start()существуют другие методы для управления службой: Stop(), Suspend()и Resume():

public void Stop() {

listener.Stop();

}

public void Suspend() {

listenerThread.Suspend();

}

public void Resume() {

listenerThread.Resume();

}

Методом, который будет открыто доступным, является RefreshQuotes(). Если содержащий цитаты файл изменяется, то запускается повторное чтение данного файла с помощью этого метода: