Пример реализации службы

Пример результата вызова

Пример запроса

Реализация собственного протокола взаимодействия клиента и службы

REST

Веб-службы на основе REST

REST (Representational State Transfer, «передача состояния представления» или «передача репрезентативного состояния») — стиль построения архитектуры распределенного приложения. Был описан и популяризован в 2000 году Роем Филдингом, одним из создателей протокола HTTP. Самой известной системой, построенной в значительной степени по архитектуре REST, является современная Всемирная паутина.

Данные в REST должны передаваться в виде небольшого количества стандартных форматов (например, HTML, XML, JSON). Сетевой протокол (как и HTTP) должен поддерживать кэширование, не должен зависеть от сетевого слоя, не должен сохранять информацию о состоянии между парами «запрос-ответ». Утверждается, что такой подход обеспечивает масштабируемость системы и позволяет ей эволюционировать с новыми требованиями.

WCF предоставляет высокоуровневые средства, позволяющие выбрать тип привязки для службы (протокол и формат передаваемых данных).

Используем IWeatherService интерфейс (был рассмотрен ранее) и реализуем возможность приема параметров и выдачи результата в текстовом формате. Пусть результатом работы метода будет XML.

Один из способов получить результат в виде XML – это определить необходимые атрибуты: для класса – XmlRoot, для данных класса, которые необходимо преобразовать – XmlAttribute или XmlElement (отличаются видом формируемых в XML сущностей).

[XmlRoot]

public class WeatherInfo

{

public WeatherInfo()

{

}

[XmlAttribute]

public double Temperature { get; set; }

[XmlAttribute]

public double Humidity { get; set; }

[XmlAttribute]

public double Pressure { get; set; }

}

Ожидаемый службой запрос будет выглядеть следующим образом:

<?xml version="1.0" encoding="utf-8"?>

<ServiceRequest>

<EntryPoint ClassName="WeatherService" MethodName="GetTemperature"/>

<Parameters>

<Parameter Value="Minsk"/>

</Parameters>

</ServiceRequest>

EntryPoint – точка доступа, которая содержит имя класса, вызываемый метод класса и параметры метода.

<?xml version="1.0" encoding="utf-8"?>

<ServiceResponse>15</ServiceResponse>

class Program

{

static Dictionary<string, Type> Services;

static void Main(string[] args)

{

Services = new Dictionary<string, Type>();

Type type = typeof(WeatherService);

Services.Add(type.Name, type);

IPAddress address = IPAddress.Parse("127.0.0.1");

int port = 8338;

TcpListener listener = new TcpListener(address, port);

listener.Start();

try

{

while (true)

{

TcpClient client = listener.AcceptTcpClient();

try

{

ReceiveRequestAndSendResponse(client);

}

finally

{

client.Close();

}

}

}

finally

{

listener.Stop();

}

}

private static void ReceiveRequestAndSendResponse(TcpClient client)

{

NetworkStream stream = client.GetStream();

XElement request = XElement.Load(stream);

XElement entryPoint = request.XPathSelectElement("./EntryPoint");

string className = entryPoint.Attribute("ClassName").Value;

string methodName = entryPoint.Attribute("MethodName").Value;

XElement parametersXml = request.XPathSelectElement("./Parameters");

string[] parameters = parametersXml.Descendants().Select(

x => x.Attribute(XName.Get("Value")).Value).ToArray();

Type serviceType;

if (Services.TryGetValue(className, out serviceType))

{

ConstructorInfo constructor = serviceType.GetConstructor(

new Type[0]);

object serviceInstance = constructor.Invoke(null);

MethodInfo method = serviceType.GetMethod(methodName);

if (method!= null)

{

object result = method.Invoke(

serviceInstance, parameters);

var response = new XElement("ServiceResponse", result);

response.Save(stream);

client.Client.Shutdown(SocketShutdown.Send);

}

}

}

}

После записи вызывается Shutdown для окончания операции и закрытия потока, чтобы клиент получил результат, прочитав признак конца файла.

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

Дата добавления: 2014-11-16