當前位置：首頁 > 运维知识 > linux >内容正文

linux

.NET跨平台实践：再谈用C#开发Linux守护进程 — 完整篇

發布時間：2023/12/4 linux 57 豆豆

生活随笔收集整理的這篇文章主要介紹了 .NET跨平台实践：再谈用C#开发Linux守护进程 — 完整篇小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

Linux守護進程是Linux的后臺服務進程，相當于Windows服務，對于為Linux開發服務程序的朋友來說，Linux守護進程相關技術是必不可少的，因為這個技術不僅僅是為了開發守護進程，還可以拓展到多進程，父子進程文件描述符共享，父子進程通訊、控制等方面，是實現Linux大型服務的基礎技術之一。

去年我也曾寫了一篇關于守護進程的帖子，名字叫《.NET跨平臺實踐：用C#開發Linux守護進程》，這篇文章的的確確實現了一個Daemon，不過，它有一個弱點，不能運行多線程！

這篇帖子的目的就是進一步完善，讓我們寫出一個功能完整，可以用于生產環節的基本的守護進程。

先帖代碼（假設項目名是daemon）：

using System;

using System.Threading;

using System.Timers;

using System.Runtime.InteropServices;

using System.IO;

using System.Text;

/********************************************

?* 一個完整的linux daemon示例，作者宇內流云 *

?********************************************/

namespace daemon

{

? ? class Program

? ? {

? ? ? ? const string DaemonTag = "--daemon.";

? ? ? ? static void Main(string[] args)

? ? ? ? {

? ? ? ? ? ? // 判斷是否已經進入Daemon狀態，如果是，就直接執行后臺主函數

? ? ? ? ? ? if (string.IsNullOrEmpty(Environment.GetEnvironmentVariable(DaemonTag)) == false)

? ? ? ? ? ? {

? ? ? ? ? ? ? ? Environment.SetEnvironmentVariable(DaemonTag, null);

? ? ? ? ? ? ? ? DaemonMain(args);

? ? ? ? ? ? ? ? return;

? ? ? ? ? ? }

? ? ? ? ? ? // 如果還沒有進入daemon狀態，就作daemon處理

? ? ? ? ? ? /

? ? ? ? ? ? int pid = fork();

? ? ? ? ? ? if (pid != 0) exit(0);

? ? ? ? ? ? setsid();

? ? ? ? ? ? pid = fork();

? ? ? ? ? ? if (pid != 0) exit(0);

? ? ? ? ? ? umask(0);

? ? ? ? ? ? // 這兒已經進入“守護進程”工作狀態了!

? ? ? ? ? ? // 關閉所有打開的文件描述符

? ? ? ? ? ? int max = open("/dev/null", 0);

? ? ? ? ? ? for (var i = 0; i <= max; i++) { close(i); }

? ? ? ? ? ? // 設置標記，防止重復運行進入

? ? ? ? ? ? Environment.SetEnvironmentVariable(DaemonTag,"yes");

? ? ? ? ? ? //為execp參數重組參數

? ? ? ? ? ? var args1 = args == null ? new string[2] : new string[args.Length + 2];

? ? ? ? ? ? args1[0] = "MyDaemon";

? ? ? ? ? ? args1[1] = Path.Combine(Environment.CurrentDirectory, Thread.GetDomain().FriendlyName);

? ? ? ? ? ? if (args1.Length > 2)

? ? ? ? ? ? {

? ? ? ? ? ? ? ? for (var i = 0; i < args.Length; i++)

? ? ? ? ? ? ? ? { args1[i + 2] = args[i]; }

? ? ? ? ? ? }

? ? ? ? ? ? //守護狀態下重新加載和運行本程序

? ? ? ? ? ? execvp("mono", args1);

? ? ? ? }

? ? ? ? /// <summary>

? ? ? ? /// Daemon工作狀態的主方法

? ? ? ? /// </summary>

? ? ? ? /// <param name="aargs"></param>

? ? ? ? static void DaemonMain(string[] aargs)

? ? ? ? {

? ? ? ? ? ? //啟動一個線程去處理一些事情

? ? ? ? ? ? (new Thread(DaemonWorkFunct) { IsBackground = true }).Start();

? ? ? ? ? ? //daemon時，控制臺輸入、輸出流已經關閉

? ? ? ? ? ? //請不要再用Console.Write/Read等方法

? ? ? ? ? ? //阻止daemon進程退出

? ? ? ? ? ? (new AutoResetEvent(false)).WaitOne();

? ? ? ? }

? ? ? ? static FileStream fs;

? ? ? ? static int count = 0;

? ? ? ? static void DaemonWorkFunct() {

? ? ? ? ? ? fs = File.Open("/tmp/daemon.txt", FileMode.OpenOrCreate);

? ? ? ? ? ? var t = new System.Timers.Timer() { Interval = 1000 };

? ? ? ? ? ? t.Elapsed += OnElapsed;

? ? ? ? ? ? t.Start();

? ? ? ? }

? ? ? ? private static void OnElapsed(object sender, ElapsedEventArgs e)

? ? ? ? {

? ? ? ? ? ? var s = DateTime.Now.ToString("yyy-MM-dd HH:mm:ss") + "\n";

? ? ? ? ? ? var b = Encoding.ASCII.GetBytes(s);

? ? ? ? ? ? fs.Write(b, 0, b.Length);

? ? ? ? ? ? fs.Flush();

? ? ? ? ? ? count++;

? ? ? ? ? ? if (count > 100) {

? ? ? ? ? ? ? ? fs.Close();

? ? ? ? ? ? ? ? fs.Dispose();

? ? ? ? ? ? ? ? exit(0);

? ? ? ? ? ? }

? ? ? ? }