devbox
Gausst松鼠会
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

C# NamedPipe管道的简单应用_namedpipline c#实现

作者：Gausst松鼠会 | 2024-03-12 00:10:10

赞

踩

namedpipline c#实现

用于同一台电脑两个进程之间数据交互

一、声明管道标识名serverName，服务器、客户端基于此创建

二、创建一个服务器 NamedPipeServerStream ，以此获取读取数据流（StreamReader）、写入数据流（StreamWriter）；然后等待客户端连接 serverStream_m.WaitForConnection(); 客户端连接后，用读取数据流循环读取缓存数据ReadLine();

三、创建一个客户端 NamedPipeClientStream，以此获取读取数据流（StreamReader）、写入数据流（StreamWriter）；然后客户端连接服务器Connect()

四、定义通讯协议，即接收指定数据做指定事情

五、服务器、客户端写入数据流（StreamWriter）写入数据后，一定要调用Flush()函数，把数据写入到缓存区

PS：在代码中打开另外一个进程

  1. 	Process[] processes = Process.GetProcessesByName("程序名称");
  2. 	foreach (Process process1 in processes)
  3. 	{
  4. 		process1.Kill();
  5. 	}
  6. 	Process process = Process.Start("程序名称.exe");

1、服务器代码

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  6. using System.IO;
  7. using System.IO.Pipes;
  8. using System.Threading;
  9.  
  10. namespace NamedPipeComm
  11. {
  12. 	public class PipeServer
  13. 	{
  14. 		private NamedPipeServerStream serverStream_m = null;
  15. 		private StreamReader sReader_m;
  16. 		private StreamWriter sWriter_m;
  17. 		private object lock_m = new object();
  18. 		private IRCameraControl IRCamera_m;
  19.  
  20. 		private const string TOTAL_TEMP = "TOTAL";
  21. 		private const string SINGLE_TEMP = "SINGLE";
  22. 		private const string IS_CONNECT = "CONNECT";
  23. 		private const string SHOW = "SHOW";
  24. 		private const string HIDE = "HIDE";
  25. 		private const string CLOSE = "CLOSE";
  26.  
  27. 		public PipeServer(string serverName, IRCameraControl iRCamera)
  28. 		{
  29. 			serverStream_m = new NamedPipeServerStream(serverName);
  30.  
  31. 			sReader_m = new StreamReader(serverStream_m);
  32. 			sWriter_m = new StreamWriter(serverStream_m);
  33.  
  34. 			IRCamera_m = iRCamera;
  35. 			HandleDataReceived();
  36. 		}
  37. 		
  38. 		/// <summary>
  39. 		/// 处理客户端数据
  40. 		/// </summary>
  41. 		/// <param name="ar"></param>
  42. 		private void HandleDataReceived()
  43. 		{
  44. 			Task.Run(delegate
  45. 			{
  46. 				serverStream_m.WaitForConnection();
  47. 				do
  48. 				{
  49. 					try
  50. 					{
  51. 						if (serverStream_m.IsConnected)
  52. 						{
  53. 							string[] data = sReader_m.ReadLine().Split(',');
  54.  
  55. 							switch (data[0])
  56. 							{
  57. 								case TOTAL_TEMP:
  58. 									float[] fInfo = IRCamera_m.GetTempInfoTotalROI();
  59. 									if (fInfo.Length == 3)
  60. 									{
  61. 										sWriter_m.WriteLine(string.Format("{0},{1},{2}", fInfo[0], fInfo[1], fInfo[2]));
  62. 										sWriter_m.Flush();
  63. 									}
  64. 									break;
  65. 								case SINGLE_TEMP:
  66. 									try
  67. 									{
  68. 										int count = Convert.ToInt32(data[1]);
  69. 										float[] fInfo1 = IRCamera_m.GetTempInfoROI(count);
  70. 										if (fInfo1.Length == 3)
  71. 										{
  72. 											sWriter_m.WriteLine(string.Format("{0},{1},{2}", fInfo1[0], fInfo1[1], fInfo1[2]));
  73. 											sWriter_m.Flush();
  74. 										}
  75. 									}
  76. 									catch (Exception ex)
  77. 									{
  78.  
  79. 									}
  80. 									break;
  81. 								case IS_CONNECT:
  82. 									if (IRCamera_m.IsConnect)
  83. 									{
  84. 										sWriter_m.WriteLine(IS_CONNECT);
  85. 										sWriter_m.Flush();
  86. 									}
  87. 									break;
  88. 								case SHOW:
  89. 									IRCamera_m.ShowForm();
  90. 									break;
  91. 								case CLOSE:
  92. 									if (IRCamera_m.frmIRAY_m != null)
  93. 									{
  94. 										IRCamera_m.frmIRAY_m.Close();
  95. 									}
  96. 									else
  97. 									{
  98. 										IRCamera_m.ReleaseSDK();
  99. 									}
  100. 									break;
  101. 								case HIDE:
  102. 									if (IRCamera_m.frmIRAY_m != null)
  103. 									{
  104. 										IRCamera_m.frmIRAY_m.Hide();
  105. 									}
  106. 									break;
  107. 							}
  108. 						}
  109. 					}
  110. 					catch (Exception ex)
  111. 					{
  112.  
  113. 					}
  114. 					Thread.Sleep(10);
  115. 				} while (true);
  116. 			});
  117. 		}
  118. 		public void Close()
  119. 		{
  120. 			if (sReader_m != null)
  121. 			{
  122. 				sReader_m.Close();
  123. 				sReader_m.Dispose();
  124. 				sReader_m = null;
  125. 			}
  126. 			if (sWriter_m != null)
  127. 			{
  128. 				sWriter_m.Close();
  129. 				sWriter_m.Dispose();
  130. 				sWriter_m = null;
  131. 			}
  132. 			if (serverStream_m != null)
  133. 			{
  134. 				serverStream_m.Close();
  135. 				serverStream_m.Dispose();
  136. 				serverStream_m = null;
  137. 			}
  138. 		}
  139. 	}
  140. }

2、客户端代码

  1. using System;
  2. using System.Collections.Generic;
  3. using System.IO;
  4. using System.IO.Pipes;
  5. using System.Linq;
  6. using System.Text;
  7. using System.Threading.Tasks;
  8.  
  9. namespace NamedPipeComm
  10. {
  11. 	public class PipeClient
  12. 	{
  13. 		public bool IsConnect
  14. 		{
  15. 			get;
  16. 			set;
  17. 		}
  18.  
  19. 		private NamedPipeClientStream clientStream_m = null;
  20. 		//private BinaryReader sReader_m;
  21. 		//private BinaryWriter sWriter_m;
  22. 		private StreamReader sReader_m;
  23. 		private StreamWriter sWriter_m;
  24.  
  25. 		private const string TOTAL_TEMP = "TOTAL";
  26. 		private const string SINGLE_TEMP = "SINGLE";
  27. 		private const string IS_CONNECT = "CONNECT";
  28. 		private const string SHOW = "SHOW";
  29. 		private const string HIDE = "HIDE";
  30. 		private const string CLOSE = "CLOSE";
  31.  
  32. 		public PipeClient(string serverName)
  33. 		{
  34. 			clientStream_m = new NamedPipeClientStream(serverName);
  35. 			//sReader_m = new BinaryReader(clientStream_m);
  36. 			//sWriter_m = new BinaryWriter(clientStream_m);
  37. 			sReader_m = new StreamReader(clientStream_m);
  38. 			sWriter_m = new StreamWriter(clientStream_m);
  39. 			try
  40. 			{
  41. 				clientStream_m.Connect(3000);
  42. 			}
  43. 			catch (Exception ex)
  44. 			{
  45.  
  46. 			}
  47. 		}
  48.  
  49. 		public bool Open()
  50. 		{
  51. 			IsConnect = false;
  52. 			if (QueryLine(IS_CONNECT) == IS_CONNECT)
  53. 			{
  54. 				IsConnect = true;
  55. 				return IsConnect;
  56. 			}
  57. 			return IsConnect;
  58. 		}
  59. 		public void Close()
  60. 		{
  61. 			if (sReader_m != null)
  62. 			{
  63. 				sReader_m.Close();
  64. 				sReader_m.Dispose();
  65. 				sReader_m = null;
  66. 			}
  67. 			if (sWriter_m != null)
  68. 			{
  69. 				sWriter_m.Close();
  70. 				sWriter_m.Dispose();
  71. 				sWriter_m = null;
  72. 			}
  73. 			if (clientStream_m != null)
  74. 			{
  75. 				clientStream_m.Close();
  76. 				clientStream_m.Dispose();
  77. 				clientStream_m = null;
  78. 			}
  79. 		}
  80. 		public string QueryLine(string str)
  81. 		{
  82. 			string result = "";
  83. 			try
  84. 			{
  85. 				sWriter_m.WriteLine(str);
  86. 				sWriter_m.Flush();
  87. 				DateTime start = DateTime.Now;
  88. 				do
  89. 				{
  90. 					result = sReader_m.ReadLine();
  91.  
  92. 					if (start.Subtract(DateTime.Now).TotalSeconds > 5 || result != "")
  93. 					{
  94. 						break;
  95. 					}
  96. 				} while (true);
  97. 			}
  98. 			catch (Exception ex)
  99. 			{
  100. 			}
  101. 			return result;
  102. 		}
  103.  
  104. 		/// <summary>
  105. 		/// 获取ROI温度信息，返回值索引：0=均值，1=最小值，2=最大值
  106. 		/// </summary>
  107. 		/// <param name="index">ROI索引0~，注意需小于选择的ROI个数，否则返回错误数据</param>
  108. 		/// <returns></returns>
  109. 		public float[] GetTempInfoROI(int index)
  110. 		{
  111. 			float[] value = new float[3];
  112. 			string write = SINGLE_TEMP + "," + index.ToString();
  113. 			string[] reads = QueryLine(write).Split(',');
  114. 			try
  115. 			{
  116. 				value[0] = Convert.ToSingle(reads[0]);
  117. 				value[1] = Convert.ToSingle(reads[1]);
  118. 				value[2] = Convert.ToSingle(reads[2]);
  119. 			}
  120. 			catch (Exception ex)
  121. 			{
  122.  
  123. 			}
  124. 			return value;
  125. 		}
  126.  
  127. 		/// <summary>
  128. 		/// 获取ROI合计温度信息，返回值索引：0=均值，1=最小值，2=最大值
  129. 		/// </summary>
  130. 		/// <returns></returns>
  131. 		public float[] GetTempInfoTotalROI()
  132. 		{
  133. 			float[] value = new float[3];
  134. 			string write = TOTAL_TEMP;
  135. 			string[] reads = QueryLine(write).Split(',');
  136. 			try
  137. 			{
  138. 				value[0] = Convert.ToSingle(reads[0]);
  139. 				value[1] = Convert.ToSingle(reads[1]);
  140. 				value[2] = Convert.ToSingle(reads[2]);
  141. 			}
  142. 			catch (Exception ex)
  143. 			{
  144.  
  145. 			}
  146. 			return value;
  147. 		}
  148.  
  149. 		public void ShowForm()
  150. 		{
  151. 			try
  152. 			{
  153. 				sWriter_m.WriteLine(SHOW);
  154. 				sWriter_m.Flush();
  155. 			}
  156. 			catch (Exception ex)
  157. 			{
  158. 			}
  159. 		}
  160. 		public void HideForm()
  161. 		{
  162. 			try
  163. 			{
  164. 				sWriter_m.WriteLine(HIDE);
  165. 				sWriter_m.Flush();
  166. 			}
  167. 			catch (Exception ex)
  168. 			{
  169. 			}
  170. 		}
  171. 		public void ReleaseSDK()
  172. 		{
  173. 			try
  174. 			{
  175. 				sWriter_m.WriteLine(CLOSE);
  176. 				sWriter_m.Flush();
  177. 			}
  178. 			catch (Exception ex)
  179. 			{
  180. 			}
  181. 		}
  182. 	}
  183. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Gausst松鼠会/article/detail/220887
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号