基于WCF通信的C/S系统快速开发框架的部分架构设计

C# Code:

namespace CSFrameworkV5.WCFContract
{
   [ServiceContract(Namespace = "http://www.csframework.com")]
   public interface ICommonService
   {
      [OperationContract]
      byte[] GetAttachedFiles(byte[] loginTicket, string docID);
      
      [OperationContract]
      byte[] GetBackupHistory(byte[] loginTicket, int topList);
      
      [OperationContract]
      byte[] GetBusinessTables(byte[] loginTicket);
      
      //.....省略很多接口的代码.....      
   }
}

//来源:C/S框架网(www.csframework.com) QQ:23404761

C# Code:


namespace CSFrameworkV5.WCFContract.WCF_Class
{
   [ServiceBehavior(IncludeExceptionDetailInFaults = true)]
   [WCF_ExceptionBehaviour(typeof(WCF_ExceptionHandler))]
   public class CommonService : ICommonService
   {
      
      public byte[] GetAttachedFiles(byte[] loginTicket, string docID)
      {
         try
         {
            Loginer loginer = WebSecurity.ValidateLoginer(loginTicket);
            
            DataTable data = new dalAttachFile(loginer).GetData(docID);
            return ZipTools.CompressionDataSet(ServerLibrary.TableToDataSet(data));
         }
         catch (Exception ex)
         {
            throw new FaultException(ex.Message);
         }
      }
      
      public byte[] GetBackupHistory(byte[] loginTicket, int topList)
      {
         try
         {
            Loginer loginer = WebSecurity.ValidateLoginer(loginTicket);
            DataTable data = new dalCommon(null).GetBackupHistory(topList);
            return ZipTools.CompressionDataSet(ServerLibrary.TableToDataSet(data));
         }
         catch (Exception ex)
         {
            throw new FaultException(ex.Message);
         }
      }
      
      
      public byte[] GetBusinessTables(byte[] loginTicket)
      {
         try
         {
            Loginer loginer = WebSecurity.ValidateLoginer(loginTicket);
            
            DataTable data = new dalCommon(loginer).GetBusinessTables();
            return ZipTools.CompressionDataSet(ServerLibrary.TableToDataSet(data));
         }
         catch (Exception ex)
         {
            throw new FaultException(ex.Message);
         }
      }      //.....省略很多接口的代码.....      
   }
   
}


//来源:C/S框架网(www.csframework.com) QQ:23404761

C# Code:

/// <summary>
/// 启动WCF服务
/// </summary>
/// <param name="args"></param>
protected override void OnStart(string[] args)
{
   //this.WriteLog("准备启动服务...");
   
   Debugger.Launch(); //运行调试程序！！！必须
   
   LogUserOperate.Write("准备启动服务...");
   ServiceHost host = null;
   
   //获取WCF服务清单s
   List<Type> list = WCFServiceProvider.GetWCFServiceType();
   foreach (Type type in list)
   {
      //this.WriteLog("准备启动服务..." + type.FullName);
      
      try
      {
         //根据服务名称从app.config文件取URL地址
         Uri address = new Uri(ConfigurationManager.AppSettings[type.Name]);
         host = new ServiceHost(type, address);
         
         Binding myBinding = WCFServiceProvider.CreateBinding(BindingType.NetTcpBinding);
         host.AddServiceEndpoint(WCFServiceProvider.GetWCFInterfaceType(type), myBinding, address);
         host.UnknownMessageReceived += Host_UnknownMessageReceived;
         host.Closing += Host_Closing;
         host.Faulted += Host_Faulted;
         
         host.CloseTimeout = new TimeSpan(24, 0, 0);
         host.Open();
         
         
         //添加到服务列表
         _HostList.Add(host);
         
         LogUserOperate.Write("启动" + type.Name + "服务成功：" + address.AbsoluteUri);
      }
      catch (Exception ex)
      {
         LogUserOperate.Write("启动" + type.Name + "服务失败!" + ex.Message);
         if (host != null) host.Abort();
      }
      
      host = null;//初始null,准备下一次实例化
   }
}

//来源:C/S框架网(www.csframework.com) QQ:23404761

C# Code:

/// <summary>
/// 测试客户端访问WCF接口
/// </summary>
private void TestCommonService()
{
   string uri = "net.tcp://localhost:8585/CommonService";
   
   //创建透明代理
   ICommonService svc = WCFInvokeContext.CreateWCFService<ICommonService>(uri, BindingType.NetTcpBinding);
   try
   {
      (svc as ICommunicationObject).Open();//打开WCF通道
      
      //模拟用户登陆信息
      byte[] loginTicket = new byte[] { 22, 141, 34, 123, 55, 2, 23, 73, 22 };
      
      //调用WCF接口
      byte[] bs = svc.GetAttachedFiles(loginTicket, "PO201805130002");
      
      //将byte数组转换为DataSet
      DataSet ds = ZipTools.DecompressionDataSet(bs);
   }
   finally
   {
      (svc as ICommunicationObject).Close();//关闭通道
   }
}

//来源:C/S框架网(www.csframework.com) QQ:23404761