WCF实现进程间管道通信Demo分享
作者:秋荷雨翔
下面小编就为大家分享一篇WCF实现进程间管道通信Demo,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
一、代码结构:
二、数据实体类:
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(); } } }
九、效果图示:
以上这篇WCF实现进程间管道通信Demo分享就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。