欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

WCF实现进程间管道通信Demo

程序员文章站 2022-06-23 09:37:08
一、代码结构: 二、数据实体类: using System; using System.Collections.Generic; using System.Linq; using System.Runtime.Serialization; using System.Text; using Syste ......

一、代码结构:

WCF实现进程间管道通信Demo

二、数据实体类:

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

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

接口:

WCF实现进程间管道通信Demo
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

实现:

WCF实现进程间管道通信Demo
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

四、服务端启动服务:

WCF实现进程间管道通信Demo
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

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

六、客户端服务实现:

WCF实现进程间管道通信Demo
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

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

WCF实现进程间管道通信Demo
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类:

WCF实现进程间管道通信Demo
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

九、效果图示:

 WCF实现进程间管道通信Demo