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();
 }

}
}

九、效果图示：

来源：http://www.cnblogs.com/s0611163/archive/2017/12/15/8043157.html