化零为整WCF(16) - 消息队列(MSMQ - MicroSoft Message Queue)

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
 
using System.ServiceModel; 
 
namespace WCF.ServiceLib.Message 
{ 
         /// <summary> 
         /// 演示MSMQ的接口 
         /// </summary> 
         /// <remarks> 
        /// DeliveryRequirements - 指定绑定必须提供给服务或客户端实现的功能要求 
        /// QueuedDeliveryRequirements - 指定服务的绑定是否必须支持排队协定 
        /// QueuedDeliveryRequirementsMode.Allowed - 允许排队传送 
        /// QueuedDeliveryRequirementsMode.Required - 要求排队传送 
        /// QueuedDeliveryRequirementsMode.NotAllowed - 不允许排队传送 
        /// </remarks> 
        [ServiceContract] 
        [DeliveryRequirements(QueuedDeliveryRequirements = QueuedDeliveryRequirementsMode.Required)] 
         public  interface IMSMQ 
        { 
                 /// <summary> 
                 /// 将字符串写入文本文件 
                 /// </summary> 
                 /// <param name="str">需要写入文本文件的字符串</param> 
                 /// <remarks> 
                /// 如果要使用 MSMQ 的话，则必须配置IsOneWay = true 
                /// </remarks> 
                [OperationContract(IsOneWay =  true)] 
                 void Write( string str); 
        } 
}

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
 
using System.ServiceModel; 
 
namespace WCF.ServiceLib.Message 
{ 
         /// <summary> 
         /// 演示MSMQ的类 
         /// </summary> 
         public  class MSMQ : IMSMQ 
        { 
                 /// <summary> 
                 /// 将字符串写入文本文件 
                 /// </summary> 
                 /// <param name="str">需要写入文本文件的字符串</param> 
                 public  void Write( string str) 
                { 
                        System.IO.StreamWriter sw =  new System.IO.StreamWriter( @"C:\WCF_Log_MSMQ.txt",  true); 
                        sw.Write(str); 
                        sw.WriteLine(); 
                        sw.Close(); 
                } 
        } 
}

// 队列名 
// 只能使用.\private$\YourPrivateMSMQName来访问本机的私有MSMQ队列 
string queueName =  @".\private$\SampleMSMQ"; 
 
// 没有queueName队列，则创建queueName队列 
if (!System.Messaging.MessageQueue.Exists(queueName)) 
{ 
         // 第二个参数为是否创建事务性队列 
        System.Messaging.MessageQueue.Create(queueName,  true); 
} 
 
using (ServiceHost host =  new ServiceHost( typeof(WCF.ServiceLib.Message.MSMQ))) 
{ 
        host.Open(); 
 
        Console.WriteLine( "服务已启动(WCF.ServiceLib.Message.MSMQ)"); 
        Console.WriteLine( "按<ENTER>停止服务"); 
        Console.ReadLine(); 
 
}

<?xml version="1.0" encoding="utf-8" ?> 
<configuration> 
        <system.serviceModel> 
                <services> 
                        <!--name - 提供服务的类名--> 
                        <!--behaviorConfiguration - 指定相关的行为配置--> 
                        <service name="WCF.ServiceLib.Message.MSMQ" behaviorConfiguration="MessageBehavior"> 
                                <!--address - 服务地址--> 
                                <!--binding - 通信方式--> 
                                <!--contract - 服务契约--> 
                                <!--bindingConfiguration - 指定相关的绑定配置--> 
                                <endpoint address="" binding="netMsmqBinding" contract="WCF.ServiceLib.Message.IMSMQ" bindingConfiguration="MSMQBindingConfiguration" /> 
                                <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" /> 
                                <host> 
                                        <baseAddresses> 
                                                <add baseAddress="http://localhost:12345/Message/MSMQ"/> 
                                                <add baseAddress="net.msmq://localhost/private/SampleMSMQ"/> 
                                        </baseAddresses> 
                                </host> 
                        </service> 
                </services> 
                <behaviors> 
                        <serviceBehaviors> 
                                <behavior name="MessageBehavior"> 
                                        <!--httpGetEnabled - 指示是否发布服务元数据以便使用 HTTP/GET 请求进行检索，如果发布 WSDL，则为 true，否则为 false，默认值为 false--> 
                                        <serviceMetadata httpGetEnabled="true" /> 
                                        <serviceDebug includeExceptionDetailInFaults="true"/> 
                                </behavior> 
                        </serviceBehaviors> 
                </behaviors> 
                <bindings> 
                        <netMsmqBinding> 
                                <binding name="MSMQBindingConfiguration"> 
                                        <security> 
                                                <!--msmqAuthenticationMode - 指示 MSMQ 传输必须采用什么方式对消息进行身份验证，默认值 WindowsDomain --> 
                                                <!--MsmqAuthenticationMode.None - 不使用任何安全性--> 
                                                <!--MsmqAuthenticationMode.WindowsDomain - 通过 Kerberos 进行身份验证，客户端和服务器必须连接到受信任域--> 
                                                <!--MsmqAuthenticationMode.Certificate - 客户端通过 X.509 证书进行身份验证，客户端证书必须显示在服务器的证书存储区中--> 

                                                <!--msmqProtectionLevel - 保护级别，设置与 MsmqAuthenticationMode 相关联的 ProtectionLevel，默认值 Sign --> 
                                                <!--ProtectionLevel.None - 只做身份验证--> 
                                                <!--ProtectionLevel.Sign - 对数据做签名，以确保所传输数据的完整性--> 
                                                <!--ProtectionLevel.EncryptAndSign - 对数据做加密和签名，以确保所传输数据的保密性和完整性--> 
                                                <transport msmqAuthenticationMode="None" msmqProtectionLevel="None" /> 

                                                <!--clientCredentialType - 客户端用以进行身份验证的凭据的类型，默认值 UserName --> 
                                                <!--BasicHttpMessageCredentialType.UserName - 使用用户名凭据对客户端进行身份验证--> 
                                                <!--BasicHttpMessageCredentialType.Certificate - 使用证书对客户端进行身份验证--> 
                                                <message clientCredentialType="UserName" /> 
                                        </security> 
                                </binding> 
                        </netMsmqBinding> 
                </bindings> 
        </system.serviceModel> 
</configuration>

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
 
using System.Windows.Forms; 
using System.ServiceModel; 
 
namespace Client2.Message 
{ 
         /// <summary> 
         /// 演示Message.MSMQ的类 
         /// </summary> 
         public  class MSMQ 
        { 
                 /// <summary> 
                 /// 用于测试 MSMQ 的客户端 
                 /// </summary> 
                 /// <param name="str">需要写入文本文件的字符串</param> 
                 public  void HelloMSMQ( string str) 
                { 
                         using (var proxy =  new MessageSvc.MSMQ.MSMQClient()) 
                        { 
                                proxy.Write(str); 
                        } 
                }             
        } 
}

<?xml version="1.0" encoding="utf-8" ?> 
<configuration> 
        <system.serviceModel> 
                <client> 
                        <!--address - 服务地址--> 
                        <!--binding - 通信方式--> 
                        <!--contract - 服务契约--> 
                        <!--bindingConfiguration - 指定相关的绑定配置--> 
                        <endpoint address="net.msmq://localhost/private/SampleMSMQ" binding="netMsmqBinding" 
                                contract="MessageSvc.MSMQ.IMSMQ" bindingConfiguration="MSMQBindingConfiguration" /> 
                </client> 
                <bindings> 
                        <netMsmqBinding> 
                                <binding name="MSMQBindingConfiguration"> 
                                        <security> 
                                                <!--msmqAuthenticationMode - 指示 MSMQ 传输必须采用什么方式对消息进行身份验证，默认值 WindowsDomain --> 
                                                <!--MsmqAuthenticationMode.None - 不使用任何安全性--> 
                                                <!--MsmqAuthenticationMode.WindowsDomain - 通过 Kerberos 进行身份验证，客户端和服务器必须连接到受信任域--> 
                                                <!--MsmqAuthenticationMode.Certificate - 客户端通过 X.509 证书进行身份验证，客户端证书必须显示在服务器的证书存储区中--> 

                                                <!--msmqProtectionLevel - 保护级别，设置与 MsmqAuthenticationMode 相关联的 ProtectionLevel，默认值 Sign --> 
                                                <!--ProtectionLevel.None - 只做身份验证--> 
                                                <!--ProtectionLevel.Sign - 对数据做签名，以确保所传输数据的完整性--> 
                                                <!--ProtectionLevel.EncryptAndSign - 对数据做加密和签名，以确保所传输数据的保密性和完整性--> 
                                                <transport msmqAuthenticationMode="None" msmqProtectionLevel="None" /> 

                                                <!--clientCredentialType - 客户端用以进行身份验证的凭据的类型，默认值 UserName --> 
                                                <!--BasicHttpMessageCredentialType.UserName - 使用用户名凭据对客户端进行身份验证--> 
                                                <!--BasicHttpMessageCredentialType.Certificate - 使用证书对客户端进行身份验证--> 
                                                <message clientCredentialType="UserName" /> 
                                        </security> 
                                </binding> 
                        </netMsmqBinding> 
                </bindings> 
        </system.serviceModel> 
</configuration>