WCF实现进程之中管道通信DemoWCF实现进程中管道通信Demo

by admin on 2018年10月5日

同一、代码结构:

一样、代码结构:

图片 1

图片 2

亚、数据实体类:

老二、数据实体类:

图片 3图片 4

图片 5图片 6

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.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

View Code

老三、服务端服务接口及实现:

其三、服务端服务接口和兑现:

接口:

接口:

图片 7图片 8

图片 9图片 10

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>
    [ServiceContract]
    public interface IClientServer
    {
        /// <summary>
        /// 计算(测试方法)
        /// </summary>
        [OperationContract]
        double Calculate(TestData data);
    }
}

View Code

View Code

实现:

实现:

图片 11图片 12

图片 13图片 14

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.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

View Code

季、服务端启动服务:

季、服务端启动服务:

图片 15图片 16

图片 17图片 18

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

View Code

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

五、客户端数据实体类以及劳动接口类与服务端相同

六、客户端服务实现:

六、客户端服务实现:

图片 19图片 20

图片 21图片 22

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

View Code

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

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

图片 23图片 24

图片 25图片 26

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

View Code

八、工具类BackWork类:

八、工具类BackWork类:

图片 27图片 28

图片 29图片 30

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

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

View Code

九、效果图示:

九、效果图示:

 图片 31

 图片 32

 

 

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图