NetMsmqBinding Класс
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Представляет привязку с очередью, подходящую для обмена данными между компьютерами.
public ref class NetMsmqBinding : System::ServiceModel::MsmqBindingBase
public class NetMsmqBinding : System.ServiceModel.MsmqBindingBase
type NetMsmqBinding = class
inherit MsmqBindingBase
Public Class NetMsmqBinding
Inherits MsmqBindingBase
- Наследование
Примеры
В следующем примере показано, как настроить службу для использования привязки NetMsmqBinding .
Во-первых, файл конфигурации.
Затем фактический код службы.
// Define a service contract.
[ServiceContract(Namespace="http://Microsoft.ServiceModel.Samples")]
public interface IQueueCalculator
{
[OperationContract(IsOneWay=true)]
void Add(double n1, double n2);
[OperationContract(IsOneWay = true)]
void Subtract(double n1, double n2);
[OperationContract(IsOneWay = true)]
void Multiply(double n1, double n2);
[OperationContract(IsOneWay = true)]
void Divide(double n1, double n2);
}
' Define a service contract.
<ServiceContract(Namespace:="http://Microsoft.ServiceModel.Samples")> _
Public Interface IQueueCalculator
<OperationContract(IsOneWay:=True)> _
Sub Add(ByVal n1 As Double, ByVal n2 As Double)
<OperationContract(IsOneWay := True)> _
Sub Subtract(ByVal n1 As Double, ByVal n2 As Double)
<OperationContract(IsOneWay := True)> _
Sub Multiply(ByVal n1 As Double, ByVal n2 As Double)
<OperationContract(IsOneWay := True)> _
Sub Divide(ByVal n1 As Double, ByVal n2 As Double)
End Interface
// Service class that implements the service contract.
// Added code to write output to the console window
public class CalculatorService : IQueueCalculator
{
[OperationBehavior]
public void Add(double n1, double n2)
{
double result = n1 + n2;
Console.WriteLine("Received Add({0},{1}) - result: {2}", n1, n2, result);
}
[OperationBehavior]
public void Subtract(double n1, double n2)
{
double result = n1 - n2;
Console.WriteLine("Received Subtract({0},{1}) - result: {2}", n1, n2, result);
}
[OperationBehavior]
public void Multiply(double n1, double n2)
{
double result = n1 * n2;
Console.WriteLine("Received Multiply({0},{1}) - result: {2}", n1, n2, result);
}
[OperationBehavior]
public void Divide(double n1, double n2)
{
double result = n1 / n2;
Console.WriteLine("Received Divide({0},{1}) - result: {2}", n1, n2, result);
}
}
' Service class that implements the service contract.
' Added code to write output to the console window
Public Class CalculatorService
Implements IQueueCalculator
<OperationBehavior> _
Public Sub Add(ByVal n1 As Double, ByVal n2 As Double) Implements IQueueCalculator.Add
Dim result As Double = n1 + n2
Console.WriteLine("Received Add({0},{1}) - result: {2}", n1, n2, result)
End Sub
<OperationBehavior> _
Public Sub Subtract(ByVal n1 As Double, ByVal n2 As Double) Implements IQueueCalculator.Subtract
Dim result As Double = n1 - n2
Console.WriteLine("Received Subtract({0},{1}) - result: {2}", n1, n2, result)
End Sub
<OperationBehavior> _
Public Sub Multiply(ByVal n1 As Double, ByVal n2 As Double) Implements IQueueCalculator.Multiply
Dim result As Double = n1 * n2
Console.WriteLine("Received Multiply({0},{1}) - result: {2}", n1, n2, result)
End Sub
<OperationBehavior> _
Public Sub Divide(ByVal n1 As Double, ByVal n2 As Double) Implements IQueueCalculator.Divide
Dim result As Double = n1 / n2
Console.WriteLine("Received Divide({0},{1}) - result: {2}", n1, n2, result)
End Sub
End Class
// This is the hosting application. This code can appear directly in the service class as well.
class HostApp
{
// Host the service within this EXE console application.
public static void Main()
{
// Get MSMQ queue name from appsettings in configuration.
string queueName = ConfigurationManager.AppSettings["queueName"];
// Create the transacted MSMQ queue if necessary.
if (!MessageQueue.Exists(queueName))
MessageQueue.Create(queueName, true);
// Get the base address that is used to listen for WS-MetaDataExchange requests.
// This is useful to generate a proxy for the client.
string baseAddress = ConfigurationManager.AppSettings["baseAddress"];
// Create a ServiceHost for the CalculatorService type.
using (ServiceHost serviceHost = new ServiceHost(typeof(CalculatorService), new Uri(baseAddress)))
{
// Open the ServiceHostBase to create listeners and start listening for messages.
serviceHost.Open();
// The service can now be accessed.
Console.WriteLine("The service is ready.");
Console.WriteLine("Press <ENTER> to terminate service.");
Console.WriteLine();
Console.ReadLine();
// Close the ServiceHostBase to shutdown the service.
serviceHost.Close();
}
}
}
' This is the hosting application. This code can appear directly in the service class as well.
Friend Class HostApp
' Host the service within this EXE console application.
Public Shared Sub Main()
' Get MSMQ queue name from appsettings in configuration.
Dim queueName As String = ConfigurationManager.AppSettings("queueName")
' Create the transacted MSMQ queue if necessary.
If (Not MessageQueue.Exists(queueName)) Then
MessageQueue.Create(queueName, True)
End If
' Get the base address that is used to listen for WS-MetaDataExchange requests.
' This is useful to generate a proxy for the client.
Dim baseAddress As String = ConfigurationManager.AppSettings("baseAddress")
' Create a ServiceHost for the CalculatorService type.
Using serviceHost As New ServiceHost(GetType(CalculatorService), New Uri(baseAddress))
' Open the ServiceHostBase to create listeners and start listening for messages.
serviceHost.Open()
' The service can now be accessed.
Console.WriteLine("The service is ready.")
Console.WriteLine("Press <ENTER> to terminate service.")
Console.WriteLine()
Console.ReadLine()
' Close the ServiceHostBase to shutdown the service.
serviceHost.Close()
End Using
End Sub
End Class
Комментарии
NetMsmqBinding Привязка обеспечивает поддержку очереди с помощью очереди сообщений (MSMQ) в качестве транспорта и обеспечивает поддержку слабо связанных приложений, изоляции сбоев, выравнивания нагрузки и отключенных операций. Сведения об этих функциях см. в разделе "Общие сведения о очередях".
Это одна из системных привязок, предоставляемых Windows Communication Foundation (WCF). Рекомендуемая процедура — определить привязку с помощью значений конфигурации, а не использовать подход на основе кода, за исключением некоторых расширенных сценариев, в которых значения конфигурации должны быть инициализированы в качестве службы.
Конструкторы
| Имя | Описание |
|---|---|
| NetMsmqBinding() |
Инициализирует новый экземпляр класса NetMsmqBinding. |
| NetMsmqBinding(NetMsmqSecurityMode) |
Инициализирует новый экземпляр класса с помощью указанного NetMsmqBinding режима безопасности. |
| NetMsmqBinding(String) |
Инициализирует новый экземпляр NetMsmqBinding класса из параметров указанного элемента привязки конфигурации. |
Свойства
| Имя | Описание |
|---|---|
| CloseTimeout |
Возвращает или задает интервал времени, предоставленный для закрытия соединения перед тем, как транспорт вызывает исключение. (Унаследовано от Binding) |
| CustomDeadLetterQueue |
Возвращает или задает универсальный код ресурса (URI), содержащий расположение очереди недоставленных писем для каждого приложения, в котором сообщения с истекшим сроком действия, или сбой передачи или доставки. (Унаследовано от MsmqBindingBase) |
| DeadLetterQueue |
Возвращает или задает значение перечисления, указывающее тип очереди недоставленных букв для использования. (Унаследовано от MsmqBindingBase) |
| Durable |
Возвращает или задает значение, указывающее, являются ли сообщения, обработанные этой привязкой, устойчивыми или переменными. (Унаследовано от MsmqBindingBase) |
| EnvelopeVersion |
Возвращает версию SOAP, которая используется для сообщений, обработанных этой привязкой. |
| ExactlyOnce |
Возвращает или задает значение, указывающее, получаются ли сообщения, обработанные этой привязкой, ровно один раз. (Унаследовано от MsmqBindingBase) |
| MaxBufferPoolSize |
Возвращает или задает максимальный объем памяти, выделенной для использования диспетчером буферов сообщений, который получает сообщения из канала. |
| MaxReceivedMessageSize |
Возвращает или задает максимальный размер сообщения в байтах, обрабатываемого этой привязкой. (Унаследовано от MsmqBindingBase) |
| MaxRetryCycles |
Возвращает или задает максимальное количество циклов повтора для попытки доставки сообщений в принимающее приложение. (Унаследовано от MsmqBindingBase) |
| MessageVersion |
Возвращает версию сообщения, используемую клиентами и службами, настроенными с привязкой. (Унаследовано от Binding) |
| Name |
Возвращает или задает имя привязки. (Унаследовано от Binding) |
| Namespace |
Возвращает или задает пространство имен XML привязки. (Унаследовано от Binding) |
| OpenTimeout |
Возвращает или задает интервал времени, предоставленный для открытия подключения, прежде чем транспорт вызывает исключение. (Унаследовано от Binding) |
| QueueTransferProtocol |
Возвращает или задает значение перечисления, указывающее транспорт канала связи очереди, который использует эта привязка. |
| ReaderQuotas |
Возвращает или задает связанный XmlDictionaryReaderQuotas с этой привязкой объект. |
| ReceiveContextEnabled |
Возвращает или задает значение, указывающее, запрашивается ли поведение контекста получения. (Унаследовано от MsmqBindingBase) |
| ReceiveErrorHandling |
Возвращает или задает значение перечисления, указывающее способ обработки подозрительных сообщений. (Унаследовано от MsmqBindingBase) |
| ReceiveRetryCount |
Возвращает или задает максимальное количество немедленных попыток доставки сообщения, считываемого из очереди приложения. (Унаследовано от MsmqBindingBase) |
| ReceiveTimeout |
Возвращает или задает интервал времени, в течение которого соединение не может оставаться неактивным, в течение которого сообщения приложения не будут получены до удаления. (Унаследовано от Binding) |
| RetryCycleDelay |
Возвращает или задает значение, указывающее задержку времени между циклами повторных попыток при попытке доставки сообщения, которое не может быть доставлено немедленно. (Унаследовано от MsmqBindingBase) |
| Scheme |
Возвращает схему для этой привязки. (Унаследовано от MsmqBindingBase) |
| Security |
Возвращает или задает связанный NetMsmqSecurity с этой привязкой объект. |
| SendTimeout |
Возвращает или задает интервал времени, предоставленный для выполнения операции записи перед тем, как транспорт вызывает исключение. (Унаследовано от Binding) |
| TimeToLive |
Возвращает или задает интервал времени, указывающий, сколько времени сообщения, обработанные этой привязкой, могут находиться в очереди до истечения срока их действия. (Унаследовано от MsmqBindingBase) |
| UseActiveDirectory |
Возвращает или задает значение, указывающее, следует ли преобразовать адреса очередей с помощью Active Directory. |
| UseMsmqTracing |
Возвращает или задает значение, указывающее, следует ли отслеживать сообщения, обработанные этой привязкой. (Унаследовано от MsmqBindingBase) |
| UseSourceJournal |
Возвращает или задает значение, указывающее, должны ли копии сообщений, обработанных этой привязкой, храниться в очереди исходного журнала. (Унаследовано от MsmqBindingBase) |
| ValidityDuration |
Возвращает или задает значение, указывающее длительность блокировки сообщения функцией контекста получения. (Унаследовано от MsmqBindingBase) |
Методы
| Имя | Описание |
|---|---|
| BuildChannelFactory<TChannel>(BindingParameterCollection) |
Создает стек фабрики каналов на клиенте, который создает указанный тип канала и удовлетворяет функциям, указанным в коллекции параметров привязки. (Унаследовано от Binding) |
| BuildChannelFactory<TChannel>(Object[]) |
Создает стек фабрики каналов на клиенте, который создает указанный тип канала и удовлетворяет функциям, указанным массивом объектов. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(BindingParameterCollection) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет функциям, указанным в коллекции параметров привязки. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(Object[]) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет указанным функциям. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(Uri, BindingParameterCollection) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет указанным функциям. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(Uri, Object[]) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет указанным функциям. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(Uri, String, BindingParameterCollection) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет указанным функциям. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(Uri, String, ListenUriMode, BindingParameterCollection) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет указанным функциям. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(Uri, String, ListenUriMode, Object[]) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет указанным функциям. (Унаследовано от Binding) |
| BuildChannelListener<TChannel>(Uri, String, Object[]) |
Создает прослушиватель каналов в службе, которая принимает указанный тип канала и удовлетворяет указанным функциям. (Унаследовано от Binding) |
| CanBuildChannelFactory<TChannel>(BindingParameterCollection) |
Возвращает значение, указывающее, может ли текущая привязка создавать стек фабрики каналов на клиенте, который удовлетворяет коллекции указанных параметров привязки. (Унаследовано от Binding) |
| CanBuildChannelFactory<TChannel>(Object[]) |
Возвращает значение, указывающее, может ли текущая привязка создавать стек фабрики каналов на клиенте, удовлетворяющим требованиям, заданным массивом объектов. (Унаследовано от Binding) |
| CanBuildChannelListener<TChannel>(BindingParameterCollection) |
Возвращает значение, указывающее, может ли текущая привязка создать стек прослушивателя каналов в службе, которая удовлетворяет коллекции указанных параметров привязки. (Унаследовано от Binding) |
| CanBuildChannelListener<TChannel>(Object[]) |
Возвращает значение, указывающее, может ли текущая привязка создавать стек прослушивателя каналов в службе, удовлетворяющей критериям, указанным в массиве объектов. (Унаследовано от Binding) |
| CreateBindingElements() |
Возвращает упорядоченную коллекцию элементов привязки, содержащихся в текущей привязке. |
| Equals(Object) |
Определяет, равен ли указанный объект текущему объекту. (Унаследовано от Object) |
| GetHashCode() |
Служит хэш-функцией по умолчанию. (Унаследовано от Object) |
| GetProperty<T>(BindingParameterCollection) |
Возвращает типизированный объект, запрошенный, если он присутствует, из соответствующего слоя в стеке привязки. (Унаследовано от Binding) |
| GetType() |
Возвращает Type текущего экземпляра. (Унаследовано от Object) |
| MemberwiseClone() |
Создает неглубокую копию текущей Object. (Унаследовано от Object) |
| ShouldSerializeName() |
Возвращает, следует ли сериализовать имя привязки. (Унаследовано от Binding) |
| ShouldSerializeNamespace() |
Возвращает, следует ли сериализовать пространство имен привязки. (Унаследовано от Binding) |
| ShouldSerializeReaderQuotas() |
Возвращает значение, указывающее, изменилось ли ReaderQuotas свойство со значения по умолчанию и должно быть сериализовано. |
| ShouldSerializeSecurity() |
Возвращает значение, указывающее, изменилось ли Security свойство со значения по умолчанию и должно быть сериализовано. |
| ToString() |
Возвращает строку, представляющую текущий объект. (Унаследовано от Object) |
Явные реализации интерфейса
| Имя | Описание |
|---|---|
| IBindingRuntimePreferences.ReceiveSynchronously |
Возвращает значение, указывающее, можно ли обрабатывать входящие запросы более эффективно синхронно или асинхронно. (Унаследовано от MsmqBindingBase) |