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分享就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。