WCF實(shí)現(xiàn)進(jìn)程間管道通信Demo分享
更新時(shí)間：2017年12月15日 15:43:33 作者：秋荷雨翔
下面小編就為大家分享一篇WCF實(shí)現(xiàn)進(jìn)程間管道通信Demo，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
一、代碼結(jié)構(gòu)：
二、數(shù)據(jù)實(shí)體類：
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.Text;
using System.Threading.Tasks;
namespace DataStruct
{
/// <summary>
/// 測(cè)試數(shù)據(jù)實(shí)體類
/// </summary>
[DataContract]
public class TestData
{
[DataMember]
public double X { get; set; }
[DataMember]
public double Y { get; set; }
}
}
三、服務(wù)端服務(wù)接口和實(shí)現(xiàn)：
接口：
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
using DataStruct;
namespace WCFServer
{
/// <summary>
/// 服務(wù)接口
/// </summary>
[ServiceContract]
public interface IClientServer
{
/// <summary>
/// 計(jì)算(測(cè)試方法)
/// </summary>
[OperationContract]
double Calculate(TestData data);
}
}
實(shí)現(xiàn)：
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
using DataStruct;
namespace WCFServer
{
/// <summary>
/// 服務(wù)實(shí)現(xiàn)
/// </summary>
[ServiceBehavior()]
public class ClientServer : IClientServer
{
/// <summary>
/// 計(jì)算(測(cè)試方法)
/// </summary>
public double Calculate(TestData data)
{
return Math.Pow(data.X, data.Y);
}
}
}
四、服務(wù)端啟動(dòng)服務(wù)：
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 服務(wù)端
{
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>
/// 啟動(dòng)服務(wù)
/// </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();
}
}
}
五、客戶端數(shù)據(jù)實(shí)體類和服務(wù)接口類與服務(wù)端相同
六、客戶端服務(wù)實(shí)現(xiàn)：
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>
/// 服務(wù)實(shí)現(xiàn)
/// </summary>
public class ClientServer : IClientServer
{
ChannelFactory<IClientServer> channelFactory;
IClientServer proxy;
public ClientServer()
{
CreateChannel();
}
/// <summary>
/// 創(chuàng)建連接客戶終端WCF服務(wù)的通道
/// </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>
/// 計(jì)算(測(cè)試方法)
/// </summary>
public double Calculate(TestData data)
{
proxy = channelFactory.CreateChannel();
try
{
return proxy.Calculate(data);
}
catch (Exception ex)
{
throw ex;
}
finally
{
(proxy as ICommunicationObject).Close();
}
}
}
}
七、客戶端調(diào)用服務(wù)接口：
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();
}
//測(cè)試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("請(qǐng)輸入合法的數(shù)據(jù)");
}
}
//測(cè)試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("請(qǐng)輸入合法的數(shù)據(jù)");
}
}
}
}
八、工具類BackWork類：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Text;
/**
* 使用方法：
BackWork.Run(() => //DoWork
{
}, () => //RunWorkerCompleted
{
}, (ex) => //錯(cuò)誤處理
{
});
*/
namespace Utils
{
/// <summary>
/// BackgroundWorker封裝
/// 用于簡(jiǎn)化代碼
/// </summary>
public class BackWork
{
/// <summary>
/// 執(zhí)行
/// </summary>
/// <param name="doWork">DoWork</param>
/// <param name="workCompleted">RunWorkerCompleted</param>
/// <param name="errorAction">錯(cuò)誤處理</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實(shí)現(xiàn)進(jìn)程間管道通信Demo分享就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章介紹了C#使用RestClient調(diào)用Web API的方法，文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-05-05
C# WinForm控件對(duì)透明圖片重疊時(shí)出現(xiàn)圖片不透明的簡(jiǎn)單解決方法
這篇文章主要介紹了C# WinForm控件對(duì)透明圖片重疊時(shí)出現(xiàn)圖片不透明的簡(jiǎn)單解決方法,結(jié)合實(shí)例形式分析了WinForm圖片重疊后造成圖片不透明的原因與相應(yīng)的解決方法,需要的朋友可以參考下2016-06-06
這篇文章主要介紹了C# 調(diào)用騰訊即時(shí)通信 IM的示例，幫助大家更好的理解和使用c#，感興趣的朋友可以了解下2020-11-11
winform dateTime數(shù)據(jù)類型轉(zhuǎn)換方法
這篇文章主要介紹了winform dateTime數(shù)據(jù)類型轉(zhuǎn)換方法,需要的朋友可以參考下2017-02-02
這篇文章主要介紹了C#中的 == 和equals()的區(qū)別，對(duì)不同點(diǎn)進(jìn)行了闡述，感興趣的小伙伴們可以參考一下2015-11-11
C#制作多線程處理強(qiáng)化版網(wǎng)絡(luò)爬蟲
這篇文章主要介紹了C#制作多線程處理強(qiáng)化版網(wǎng)絡(luò)爬蟲的相關(guān)代碼，有想學(xué)習(xí)C#多線程編程的小伙伴可以參考下2016-09-09
Unity shader實(shí)現(xiàn)百葉窗特效
這篇文章主要為大家詳細(xì)介紹了Unity shader實(shí)現(xiàn)百葉窗特效，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-11-11
這篇文章介紹了C#實(shí)現(xiàn)線性查找的算法，文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-08-08
淺談C#9.0新特性之參數(shù)非空檢查簡(jiǎn)化
這篇文章主要介紹了淺談C#9.0新特性之參數(shù)非空檢查簡(jiǎn)化，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
2020-06-06