WCF实现进程间管道通信Demo分享

2020-01-24 00:22:32

字体：大中小

来源：转载

供稿：网友

一、代码结构：

二、数据实体类：

using System;using System.Collections.Generic;using System.Linq;using System.Runtime.Serialization;using System.Text;using System.Threading.Tasks;namespace DataStruct{ /// <summary> /// 测试数据实体类 /// </summary> [DataContract] public class TestData {  [DataMember]  public double X { get; set; }  [DataMember]  public double Y { get; set; } }}

三、服务端服务接口和实现：

接口：

using System;using System.Collections.Generic;using System.Linq;using System.ServiceModel;using System.Text;using System.Threading.Tasks;using DataStruct;namespace WCFServer{ /// <summary> /// 服务接口 /// </summary> [ServiceContract] public interface IClientServer {  /// <summary>  /// 计算(测试方法)  /// </summary>  [OperationContract]  double Calculate(TestData data); }}

实现：

using System;using System.Collections.Generic;using System.Linq;using System.ServiceModel;using System.Text;using System.Threading.Tasks;using DataStruct;namespace WCFServer{ /// <summary> /// 服务实现 /// </summary> [ServiceBehavior()] public class ClientServer : IClientServer {  /// <summary>  /// 计算(测试方法)  /// </summary>  public double Calculate(TestData data)  {   return Math.Pow(data.X, data.Y);  } }}

四、服务端启动服务：

using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.ServiceModel;using System.ServiceModel.Description;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;using Utils;using WCFServer;namespace 服务端{ public partial class Form1 : Form {  public Form1()  {   InitializeComponent();  }  private void Form1_Load(object sender, EventArgs e)  {   BackWork.Run(() =>   {    OpenClientServer();   }, null, (ex) =>   {    MessageBox.Show(ex.Message);   });  }  /// <summary>  /// 启动服务  /// </summary>  private void OpenClientServer()  {   NetNamedPipeBinding wsHttp = new NetNamedPipeBinding();   wsHttp.MaxBufferPoolSize = 524288;   wsHttp.MaxReceivedMessageSize = 2147483647;   wsHttp.ReaderQuotas.MaxArrayLength = 6553600;   wsHttp.ReaderQuotas.MaxStringContentLength = 2147483647;   wsHttp.ReaderQuotas.MaxBytesPerRead = 6553600;   wsHttp.ReaderQuotas.MaxDepth = 6553600;   wsHttp.ReaderQuotas.MaxNameTableCharCount = 6553600;   wsHttp.CloseTimeout = new TimeSpan(0, 1, 0);   wsHttp.OpenTimeout = new TimeSpan(0, 1, 0);   wsHttp.ReceiveTimeout = new TimeSpan(0, 10, 0);   wsHttp.SendTimeout = new TimeSpan(0, 10, 0);   wsHttp.Security.Mode = NetNamedPipeSecurityMode.None;   Uri baseAddress = new Uri("net.pipe://localhost/pipeName1");   ServiceHost host = new ServiceHost(typeof(ClientServer), baseAddress);   ServiceMetadataBehavior smb = new ServiceMetadataBehavior();   host.Description.Behaviors.Add(smb);   ServiceBehaviorAttribute sba = host.Description.Behaviors.Find<ServiceBehaviorAttribute>();   sba.MaxItemsInObjectGraph = 2147483647;   host.AddServiceEndpoint(typeof(IClientServer), wsHttp, "");   host.Open();  } }}

五、客户端数据实体类和服务接口类与服务端相同

六、客户端服务实现：

using DataStruct;using System;using System.Collections.Generic;using System.Linq;using System.ServiceModel;using System.ServiceModel.Description;using System.Text;using System.Threading.Tasks;using WCFServer;namespace DataService{ /// <summary> /// 服务实现 /// </summary> public class ClientServer : IClientServer {  ChannelFactory<IClientServer> channelFactory;  IClientServer proxy;  public ClientServer()  {   CreateChannel();  }  /// <summary>  /// 创建连接客户终端WCF服务的通道  /// </summary>  public void CreateChannel()  {   string url = "net.pipe://localhost/pipeName1";   NetNamedPipeBinding wsHttp = new NetNamedPipeBinding();   wsHttp.MaxBufferPoolSize = 524288;   wsHttp.MaxReceivedMessageSize = 2147483647;   wsHttp.ReaderQuotas.MaxArrayLength = 6553600;   wsHttp.ReaderQuotas.MaxStringContentLength = 2147483647;   wsHttp.ReaderQuotas.MaxBytesPerRead = 6553600;   wsHttp.ReaderQuotas.MaxDepth = 6553600;   wsHttp.ReaderQuotas.MaxNameTableCharCount = 6553600;   wsHttp.SendTimeout = new TimeSpan(0, 10, 0);   wsHttp.Security.Mode = NetNamedPipeSecurityMode.None;   channelFactory = new ChannelFactory<IClientServer>(wsHttp, url);   foreach (OperationDescription op in channelFactory.Endpoint.Contract.Operations)   {    DataContractSerializerOperationBehavior dataContractBehavior = op.Behaviors.Find<DataContractSerializerOperationBehavior>() as DataContractSerializerOperationBehavior;    if (dataContractBehavior != null)    {     dataContractBehavior.MaxItemsInObjectGraph = 2147483647;    }   }  }  /// <summary>  /// 计算(测试方法)  /// </summary>  public double Calculate(TestData data)  {   proxy = channelFactory.CreateChannel();   try   {    return proxy.Calculate(data);   }   catch (Exception ex)   {    throw ex;   }   finally   {    (proxy as ICommunicationObject).Close();   }  } }}

七、客户端调用服务接口：

using DataService;using DataStruct;using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;using Utils;using WCFServer;namespace 客户端{ public partial class Form1 : Form {  public Form1()  {   InitializeComponent();  }  //测试1  private void button1_Click(object sender, EventArgs e)  {   button1.Enabled = false;   txtSum.Text = string.Empty;   IClientServer client = new ClientServer();   double num1;   double num2;   double sum = 0;   if (double.TryParse(txtNum1.Text, out num1) && double.TryParse(txtNum2.Text, out num2))   {    DateTime dt = DateTime.Now;    BackWork.Run(() =>    {     sum = client.Calculate(new TestData(num1, num2));    }, () =>    {     double time = DateTime.Now.Subtract(dt).TotalSeconds;     txtTime.Text = time.ToString();     txtSum.Text = sum.ToString();     button1.Enabled = true;    }, (ex) =>    {     button1.Enabled = true;     MessageBox.Show(ex.Message);    });   }   else   {    button1.Enabled = true;    MessageBox.Show("请输入合法的数据");   }  }  //测试2  private void button2_Click(object sender, EventArgs e)  {   button2.Enabled = false;   txtSum.Text = string.Empty;   IClientServer client = new ClientServer();   double num1;   double num2;   double sum = 0;   if (double.TryParse(txtNum1.Text, out num1) && double.TryParse(txtNum2.Text, out num2))   {    DateTime dt = DateTime.Now;    BackWork.Run(() =>    {     for (int i = 0; i < 1000; i++)     {      sum = client.Calculate(new TestData(num1, num2));     }    }, () =>    {     double time = DateTime.Now.Subtract(dt).TotalSeconds;     txtTime.Text = time.ToString();     txtSum.Text = sum.ToString();     button2.Enabled = true;    }, (ex) =>    {     button2.Enabled = true;     MessageBox.Show(ex.Message);    });   }   else   {    button2.Enabled = true;    MessageBox.Show("请输入合法的数据");   }  } }}

八、工具类BackWork类：

using System;using System.Collections.Generic;using System.ComponentModel;using System.Linq;using System.Text;/** * 使用方法：BackWork.Run(() => //DoWork{}, () => //RunWorkerCompleted{}, (ex) => //错误处理{}); */namespace Utils{ /// <summary> /// BackgroundWorker封装 /// 用于简化代码 /// </summary> public class BackWork {  /// <summary>  /// 执行  /// </summary>  /// <param name="doWork">DoWork</param>  /// <param name="workCompleted">RunWorkerCompleted</param>  /// <param name="errorAction">错误处理</param>  public static void Run(Action doWork, Action workCompleted, Action<Exception> errorAction)  {   bool isDoWorkError = false;   Exception doWorkException = null;   BackgroundWorker worker = new BackgroundWorker();   worker.DoWork += (s, e) =>   {    try    {     doWork();    }    catch (Exception ex)    {     isDoWorkError = true;     doWorkException = ex;    }   };   worker.RunWorkerCompleted += (s, e) =>   {    if (!isDoWorkError)    {     try     {      if (workCompleted != null) workCompleted();     }     catch (Exception ex)     {      errorAction(ex);     }    }    else    {     errorAction(doWorkException);    }   };   worker.RunWorkerAsync();  } }}

九、效果图示：