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

(0)

相关推荐

  • 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> [DataContr

  • vue与electron实现进程间的通信详情

    目录 一.配置内容 1.进程间的通信 第一种方式引入ipcRenderer 第二种方式引入ipcRenderer 2.渲染进程常用配置 3.将ipcMain封装到一个js中统一处理 三.总结 前言: 本文主要介绍electron渲染进程和主进程间的通信,以及在渲染进程和主进程中常用的配置项. 一.配置内容 1.进程间的通信 渲染进程和主进程间的通信主要通过ipcRenderer和ipcMain这两个模块实现的,其中ipcRenderer是在渲染进程中使用,ipcMain在主进程中使用. 其中,渲

  • Python进程间的通信一起来了解下

    目录 通信方式 Queue介绍: 生产者和消费者模型 为什么要使用生产者和消费者模式 什么是生产者消费者模式 实现方式一:Queue 实现方式二:利用JoinableQueue 总结 通信方式 进程彼此之间互相隔离,要实现进程间通信(IPC),multiprocessing模块主要通过队列方式 队列:队列类似于一条管道,元素先进先出 需要注意的一点是:队列都是在内存中操作,进程退出,队列清空,另外,队列也是一个阻塞的形态 Queue介绍: 创建队列的类(底层就是以管道和锁定的方式实现): Que

  • Python语法学习之进程间的通信方式

    目录 什么是进程的通信 队列的创建 - multiprocessing 进程之间通信的方法 进程间的通信 - 队列演示案例 批量给 send 函数加入数据 小节 进程间通信的其他方式 - 补充 什么是进程的通信 这里举一个例子接介绍通信的机制:通信 一词大家并不陌生,比如一个人要给他的女友打电话.当建立了通话之后,在这个通话的过程中就是建立了一条隐形的 队列 (记住这个词).此时这个人就会通过对话的方式不停的将信息告诉女友,而这个人的女友也是在倾听着.(嗯…我个人觉得大部分情况下可能是反着来的)

  • C语言中进程间通讯的方式详解

    目录 一.无名管道 1.1无名管道的原理 1.2功能 1.3无名管道通信特点 1.4无名管道的实例 二.有名管道 2.1有名管道的原理 2.2有名管道的特点 2.3有名管道实例 三.信号 3.1信号的概念 3.2发送信号的函数 3.3常用的信号 3.4实例 四.IPC进程间通信 4.1IPC进程间通信的种类 4.2查看IPC进程间通信的命令 4.3消息队列 4.4共享内存 4.5信号灯集合 一.无名管道 1.1无名管道的原理 无名管道只能用于亲缘间进程的通信,无名管道的大小是64K.无名管道是内

  • Python使用文件锁实现进程间同步功能【基于fcntl模块】

    本文实例讲述了Python使用文件锁实现进程间同步功能.分享给大家供大家参考,具体如下: 简介 在实际应用中,会出现这种应用场景:希望shell下执行的脚本对某些竞争资源提供保护,避免出现冲突.本文将通过fcntl模块的文件整体上锁机制来实现这种进程间同步功能. fcntl系统函数介绍 Linux系统提供了文件整体上锁(flock)和更细粒度的记录上锁(fcntl)功能,底层功能均可由fcntl函数实现. 首先来了解记录上锁.记录上锁是读写锁的一种扩展类型,它可用于有亲缘关系或无亲缘关系的进程间

  • Android Studio创建AIDL文件并实现进程间通讯实例

    在Android系统中,跨进程通信是非常普遍的事情,它用到了Binder机制处理进程之间的交互.Binder机制会开放一些接口给Java层,供android开发工程师调用进程之间通信.这些接口android封装到了AIDL文件里,当我们项目用到跨进程通信时可以创建.aidl文件,.aidl文件可以协助我们达到跨进程的通信.下面简单介绍用AndroidStudio创建AIDL文件的过程. a.新建AIDL文件 1.项目文件夹右键---> new --->选择AIDL 2.自定义一个接口名称 3.

  • Android基于Aidl的跨进程间双向通信管理中心

    得益于最近有点时间和精力,我想起来了一件事.那就是在上家公司,公司要求做一个APP进程间的通信的功能,并不是APP对APP的直接跨进程通信,而是通过一个服务中心,做接收,然后,再转发,避免应用之间耦合性高,不然的话,新增一个APP,其他APP也要进行升级更新(类似于有服务中心的聊天室). 我就花几个小时写点东西吧,顺便记录一下 大家都知道在Android设备上,有很多方式,比如,广播,socket,共享内存,aidl等,其中广播和aidl都是基于android中iBinder机制 广播: 广播有

  • Android进程间使用Intent进行通信

    安卓使用Intent来封装程序的“调用意图”,使用Intent可以让程序看起来更规范,更易于维护. 除此之外,使用Intent还有一个好处:有些时候我们只是想要启动具有某种特征的组件,并不想和某个具体的组件耦合,使用Intent在这种情况下有利于解耦. Action,Category属性与intent-filter配置 我们知道当需要进行Activity跳转的时候需要在manifests.xml文件中配置Activity信息.其中主Activity还需要配置<intent-filter>,并且

  • Angular ViewChild组件间通信demo

    目录 - ViewChild 通过ViewChild调用一个方法 - ViewChild 这篇文章是Angular中组件间通信系列的一部分.虽然你可以从任何地方开始,但最好还是从头开始,对吗? 我们现在进入了Angular中组件间交流的最后一个方法.这是一个我不确定是否真的应该写出来的方法.你看,在我看来,使用ViewChild来让组件之间相互交流,是最后的手段.它不是那种反应式的,而且经常遇到各种竞赛条件,因为你没有使用像EventEmitters和数据绑定这样的东西,而是直接调用方法. 由于

随机推荐