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

View Code

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

接口：

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

View Code

实现：

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

View Code

四、服务端启动服务：

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

View Code

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

六、客户端服务实现：

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

View Code

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

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("请输入合法的数据");
            }
        }
    }
}

View Code

八、工具类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();
        }

    }
}

View Code

九、效果图示：