当前位置:编程学习 > 网站相关 >>

化零为整WCF(6) - 消息处理(异步调用OneWay, 双向通讯Duplex)

作者:webabcd


介绍
WCF(Windows Communication Foundation) - 消息处理:通过操作契约的IsOneWay参数实现异步调用,基于Http, TCP, Named Pipe, MSMQ的双向通讯。


示例(异步调用OneWay)
1、服务
IOneWay.cs
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using System.ServiceModel;

namespace WCF.ServiceLib.Message
{
   /**//// <summary>
    /// IOneWay接口
    /// </summary>
    [ServiceContract]
    public inte易做图ce IOneWay
    {
        /**//// <summary>
        /// 不使用OneWay(同步调用)
        /// </summary>
        [OperationContract]
        void WithoutOneWay();

        /**//// <summary>
        /// 使用OneWay(异步调用)
        /// </summary>
        [OperationContract(IsOneWay=true)]
        void WithOneWay();
    }
}

OneWay.cs
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using System.ServiceModel;

namespace WCF.ServiceLib.Message
{
    /**//// <summary>
    /// OneWay类
    /// </summary>
    public class OneWay : IOneWay
    {
        /**//// <summary>
        /// 不使用OneWay(同步调用)
        /// 抛出Exception异常
        /// </summary>
        public void WithoutOneWay()
        {
            throw new System.Exception("抛出Exception异常");
        }

        /**//// <summary>
        /// 使用OneWay(异步调用)
        /// 抛出Exception异常
        /// </summary>
        public void WithOneWay()
        {
            throw new System.Exception("抛出Exception异常");
        }
    }
}


2、宿主
OneWay.cs
using (ServiceHost host = new ServiceHost(typeof(WCF.ServiceLib.Message.OneWay)))
{
    host.Open();

    Console.WriteLine("服务已启动(WCF.ServiceLib.Message.OneWay)");
    Console.WriteLine("按<ENTER>停止服务");
    Console.ReadLine();

}
App.config
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <system.serviceModel>
    <services>
      <!--name - 提供服务的类名-->
      <!--behaviorConfiguration - 指定相关的行为配置-->
      <service name="WCF.ServiceLib.Message.OneWay" behaviorConfiguration="MessageBehavior">
        <!--address - 服务地址-->
        <!--binding - 通信方式-->
        <!--contract - 服务契约-->
        <endpoint address="" binding="basicHttpBinding" contract="WCF.ServiceLib.Message.IOneWay" />
        <endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />
        <host>
          <baseAddresses>
            <add baseAddress="http://localhost:12345/Message/OneWay/"/>
          </baseAddresses>
        </host>
      </service>
    </services>
    <behaviors>
      <serviceBehaviors>
        <behavior name="MessageBehavior">
          <!--httpGetEnabled - 使用get方式提供服务-->
          <serviceMetadata httpGetEnabled="true" />
          <serviceDebug includeExceptionDetailInFaults="true"/>
        </behavior>
      </serviceBehaviors>
    </behaviors>
  </system.serviceModel>
</configuration>

3、客户端
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

using System.Windows.Forms;
using System.ServiceModel;

namespace Client2.Message
{
    /**//// <summary>
    /// 演示Message.OneWay的类
    /// </summary>
    public class OneWay
    {
        /**//// <summary>
        /// 调用IsOneWay=true的操作契约(异步操作)
        /// </summary>
        public void HelloWithOneWay()
        {
            try
            {
                var proxy = new MessageSvc.OneWay.OneWayClient();

                proxy.WithOneWay();

                proxy.Close();
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        /**//// <summary>
        /// 调用IsOneWay=false的操作契约(同步操作)
        /// </summary>
        public void HelloWithoutOneWay()
        {
            try
            {
                var proxy = new MessageSvc.OneWay.OneWayClient

补充:综合编程 , 其他综合 ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,