利用C#守护Python进程的方法
背景#
目前我主要负责的一个项目是一个 C/S 架构的客户端开发,前端主要是通过 WPF 相关技术来实现,后端是通过 Python 来实现,前后端的数据通信则是通过 MQ 的方式来进行处理。由于 Python 进程是需要依赖客户端进程来运行,为了保证后端业务进程的稳定性,就需要通过一个 守护进程 来守护 Python 进程,防止其由于未知原因而出现进程退出的情况。这里简单记录一下我的一种实现方式。
实现#
对于我们的系统而言,我们的 Python 进程只允许存在一个,因此,对应的服务类型要采用单例模式,这一部分代码相对简单,就直接贴出来了,示例代码如下所示:
public partial class PythonService { private static readonly object _locker = new object(); private static PythonService _instance; public static PythonService Current { get { if (_instance == null) { lock (_locker) { if (_instance == null) { _instance = new PythonService(); } } } return _instance; } } private PythonService() { } }
创建独立进程#
由于后端的 Python 代码运行需要安装一些第三方的扩展库,所以为了方便,我们采用的方式是总结将 python 安装文件及扩展包和他们的代码一并打包到我们的项目目录中,然后创建一个 Python 进程,在该进程中通过设置环境变量的方式来为 Python 进程进行一些环境配置。示例代码如下所示:
public partial class PythonService { private string _workPath => Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "scripts"); private string _pythonPath => Path.Combine(_workPath, "python27"); private bool isRunning = false; private int taskPID = -1; public void Start() { taskPID = CreateProcess(); isRunning = taskPID != -1; var msg = isRunning ? "服务启动成功..." : "服务启动失败..."; Trace.WriteLine(msg); } public void Stop() { KillProcessAndChildren(taskPID); isRunning = false; taskPID = -1; } private int CreateProcess() { KillProcessAndChildren(taskPID); int pid = -1; var psi = new ProcessStartInfo(Path.Combine(_pythonPath, "python.exe")) { UseShellExecute = false, WorkingDirectory = _workPath, ErrorDialog = false }; psi.CreateNoWindow = true; var path = psi.EnvironmentVariables["PATH"]; if (path != null) { var array = path.Split(new[] { ';' }).Where(p => !p.ToLower().Contains("python")).ToList(); array.AddRange(new[] { _pythonPath, Path.Combine(_pythonPath, "Scripts"), _workPath }); psi.EnvironmentVariables["PATH"] = string.Join(";", array); } var ps = new Process { StartInfo = psi }; if (ps.Start()) { pid = ps.Id; } return pid; } private static void KillProcessAndChildren(int pid) { // Cannot close 'system idle process'. if (pid <= 0) { return; } ManagementObjectSearcher searcher = new ManagementObjectSearcher("Select * From Win32_Process Where ParentProcessID=" + pid); ManagementObjectCollection moc = searcher.Get(); foreach (ManagementObject mo in moc) { KillProcessAndChildren(Convert.ToInt32(mo["ProcessID"])); } try { Process proc = Process.GetProcessById(pid); proc.Kill(); } catch (ArgumentException) { // Process already exited. } catch (Win32Exception) { // Access denied } } }
这里有一点需要注意一下,建议使用 PID 来标识我们的 Python 进程,因为如果你使用进程实例或其它方式来对当前运行的进程设置一个引用,当该进程出现一些未知退出,这个时候你通过哪个引用来进行相关操作是会出问题的。
创建守护进程#
上面我们的通过记录当前正在运行的进程的 PID 来标识我们的进程,那对应守护进程,我们就可以通过进程列表查询的方式来进行创建,在轮询的过程中,如果未找到对应 PID 的进程则表明该进程已经退出,需要重新创建该进程,否则就不执行任何操作,示例代码如下所示:
public partial class PythonService { private CancellationTokenSource cts; private void StartWatch(CancellationToken token) { Task.Factory.StartNew(() => { while (!token.IsCancellationRequested) { var has = Process.GetProcesses().Any(p => p.Id == taskPID); Trace.WriteLine($"MQ状态:{DateTime.Now}-{has}"); if (!has) { taskPID = CreateProcess(_reqhost, _subhost, _debug); isRunning = taskPID > 0; var msg = isRunning ? "MQ重启成功" : "MQ重启失败,等待下次重启"; Trace.WriteLine($"MQ状态:{DateTime.Now}-{msg}"); } Thread.Sleep(2000); } }, token); } }
这里我使用的是 Thread.Sleep(2000) 方式来继续线程等待,你也可以使用 await Task.Delay(2000,token),但是使用这种方式在发送取消请求时会产生一个 TaskCanceledException 的异常。所以为了不产生不必要的异常信息,我采用第一种解决方案。
接着,完善我们的 Start 和 Stop 方法,示例代码如下所示:
public void Start() { taskPID = CreateProcess(); isRunning = taskPID != -1; if (isRunning) { cts = new CancellationTokenSource(); StartWatch(cts.Token); } var msg = isRunning ? "服务启动成功..." : "服务启动失败..."; Trace.WriteLine(msg); } public void Stop() { cts?.Cancel(false); cts?.Dispose(); KillProcessAndChildren(taskPID); taskPID = -1; isRunning = false; }
最后,上层调用就相对简单一下,直接调用 Start 方法和 Stop 方法即可。
总结#
在我们的实际项目代码中,PythonService 的代码要比上面的代码稍微复杂一些,我们内部还添加了一个 MQ 的 消息队列。所以为了演示方便,我这里只列出了和本文相关的核心代码,在具体的使用过程中,可以依据本文提供的一种实现方法来进行加工处理。
好了,以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对猪先飞的支持。
相关参考#
- Kill a one-file Python process in C#
- 用c#实现通用守护进程
相关文章
- 这篇文章主要介绍了python-opencv-画外接矩形框的实例代码,代码简单易懂,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-04
Python astype(np.float)函数使用方法解析
这篇文章主要介绍了Python astype(np.float)函数使用方法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-06-08- 2022虎年新年即将来临,小编为大家带来了一个利用Python编写的虎年烟花特效,堪称全网最绚烂,文中的示例代码简洁易懂,感兴趣的同学可以动手试一试...2022-02-14
- 在本篇文章里小编给大家分享的是一篇关于python中numpy.empty()函数实例讲解内容,对此有兴趣的朋友们可以学习下。...2021-02-06
python-for x in range的用法(注意要点、细节)
这篇文章主要介绍了python-for x in range的用法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-05-10- 这篇文章主要介绍了Python 图片转数组,二进制互转操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-09
- 这篇文章主要介绍了Python中的imread()函数用法说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-16
- 这篇文章主要介绍了python如何实现b站直播自动发送弹幕,帮助大家更好的理解和学习使用python,感兴趣的朋友可以了解下...2021-02-20
python Matplotlib基础--如何添加文本和标注
这篇文章主要介绍了python Matplotlib基础--如何添加文本和标注,帮助大家更好的利用Matplotlib绘制图表,感兴趣的朋友可以了解下...2021-01-26- 这篇文章主要介绍了解决python 使用openpyxl读写大文件的坑,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-13
- 今天小编就为大家分享一篇python 计算方位角实例(根据两点的坐标计算),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-04-27
- 这篇文章主要介绍了使用Python的pencolor函数实现渐变色功能,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-03-09
- 在本篇文章里小编给大家整理的是一篇关于python中使用np.delete()的实例方法,对此有兴趣的朋友们可以学习参考下。...2021-02-01
- 这篇文章主要为大家详细介绍了python实现双色球随机选号,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-05-02
Python getsizeof()和getsize()区分详解
这篇文章主要介绍了Python getsizeof()和getsize()区分详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-11-20- 这篇文章主要介绍了python自动化办公操作PPT的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-05
- 这篇文章主要介绍了解决python 两个时间戳相减出现结果错误的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-12
- 这篇文章主要为大家详细介绍了python实现学生通讯录管理系统,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-02-25
- 这篇文章主要介绍了PyTorch一小时掌握之迁移学习篇,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-08
- 这篇文章主要介绍了python进行相关性分析并绘制散点图,具有一定借鉴价值,需要的朋友可以参考下,希望能够给你带来帮助...2021-09-18