netcore服務程序暴力退出導致的業務數據不一致的一種解決方案（優雅退出）

 

一： 問題提出

　　現如今大家寫的netcore程序大多部署在linux平台上，而且服務程序里面可能會做各種復雜的操作，涉及到多數據源（mysql，redis，kafka）。成功部署成后台

進程之后，你以為這樣就萬事大吉了？ 卻不知當你更新代碼時，暴力的kill掉這個進程導致你的業務出現數據不一致，業務流程被破壞等等問題。比如下面這段代碼：

 

1. TestService

    public class TestService
    {
        public static void Run()
        {
            while (true)
            {
                Console.WriteLine($"{DateTime.Now}: 1. 獲取mysql");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 2. 獲取redis");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 3. 更新monogdb");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 4. 通知kafka");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 5. 所有業務處理完畢");
                System.Threading.Thread.Sleep(2000);
            }
        }
    }

 

2. Main程序

        public static void Main(string[] args)
        {
            var bgtask = Task.Run(() => { TestService.Run(); });

            bgtask.Wait();
        }

 

      這里不考慮程序的健壯性，只表達這里可能出現的問題，當程序退出后，這里必然會遇到TestService.Run方法出現未執行完的情況，導致數據不一致，比如下

面我簡單的部署了一下，可以看到程序到了 5:03:24s之后就結束了，顯然破壞了業務邏輯。程序沒有完整的執行結束，那問題該怎么解決呢？

[root@localhost netcore]# nohup dotnet ConsoleApp4.dll &
[1] 4101
[root@localhost netcore]# nohup: ignoring input and appending output to ‘nohup.out’

[root@localhost netcore]# ps -ef | grep dotnet
root       4101   2865  0 17:03 pts/0    00:00:00 dotnet ConsoleApp4.dll
root       4118   2865  0 17:03 pts/0    00:00:00 grep --color=auto dotnet
[root@localhost netcore]# kill 4101
[root@localhost netcore]# tail nohup.out
9/2/18 5:03:06 PM: 2. 獲取redis
9/2/18 5:03:08 PM: 3. 更新monogdb
9/2/18 5:03:10 PM: 4. 通知kafka
9/2/18 5:03:12 PM: 5. 所有業務處理完畢
9/2/18 5:03:14 PM: 1. 獲取mysql
9/2/18 5:03:16 PM: 2. 獲取redis
9/2/18 5:03:18 PM: 3. 更新monogdb
9/2/18 5:03:20 PM: 4. 通知kafka
9/2/18 5:03:22 PM: 5. 所有業務處理完畢
9/2/18 5:03:24 PM: 1. 獲取mysql
[1]+  Done                    nohup dotnet ConsoleApp4.dll
[root@localhost netcore]# 

    

二：思考 kill 命令

　　要解決這個問題，大家一定要從kill命令入手， 在centos上進行kill  -x pid 的時候，不知道有多少人了解了這個命令，除了常見的 kill -9 pid ，其實還有很多其

他的數字，則代表其他的意思，可以通過kill -l 看一下。

[root@localhost ~]# kill -l
 1) SIGHUP     2) SIGINT     3) SIGQUIT     4) SIGILL     5) SIGTRAP
 6) SIGABRT     7) SIGBUS     8) SIGFPE     9) SIGKILL    10) SIGUSR1
11) SIGSEGV    12) SIGUSR2    13) SIGPIPE    14) SIGALRM    15) SIGTERM
16) SIGSTKFLT    17) SIGCHLD    18) SIGCONT    19) SIGSTOP    20) SIGTSTP
21) SIGTTIN    22) SIGTTOU    23) SIGURG    24) SIGXCPU    25) SIGXFSZ
26) SIGVTALRM    27) SIGPROF    28) SIGWINCH    29) SIGIO    30) SIGPWR
31) SIGSYS    34) SIGRTMIN    35) SIGRTMIN+1    36) SIGRTMIN+2    37) SIGRTMIN+3
38) SIGRTMIN+4    39) SIGRTMIN+5    40) SIGRTMIN+6    41) SIGRTMIN+7    42) SIGRTMIN+8
43) SIGRTMIN+9    44) SIGRTMIN+10    45) SIGRTMIN+11    46) SIGRTMIN+12    47) SIGRTMIN+13
48) SIGRTMIN+14    49) SIGRTMIN+15    50) SIGRTMAX-14    51) SIGRTMAX-13    52) SIGRTMAX-12
53) SIGRTMAX-11    54) SIGRTMAX-10    55) SIGRTMAX-9    56) SIGRTMAX-8    57) SIGRTMAX-7
58) SIGRTMAX-6    59) SIGRTMAX-5    60) SIGRTMAX-4    61) SIGRTMAX-3    62) SIGRTMAX-2
63) SIGRTMAX-1    64) SIGRTMAX    

 

 其中里面的

2.   SIGNIT  (Ctrl+C)

3.   SIGQUIT （退出）

9.   SIGKILL   (強制終止）

15. SIGTERM （終止）

 

都可以讓程序退出，好了，線索出來了，那我能不能讓程序捕獲到kill命令發出的這Sigxxx信號呢？？？ 通過尋找資料之后的一陣渾身痙攣，你明白了原來只有

-9是不能讓程序捕獲到，其他的程序都能捕獲，那么既然能捕獲，我就可以在捕獲的事件中做程序的安全退出。 大概的腦圖就像下面這樣：

 

三：研究如何捕獲

   

         在core 2.0之后，獲取sigterm就非常簡單了，可以在當前應用程序域中掛載一個ProcessExit 事件，在ProcessExit中讓應用程序安全的退出。

 

然后還有一個問題就是，如何在ProcessExit中通知TestService結束執行呢？ 這里就用到了CancellationTokenSource 這種線程安全的取消協調機制，思考之后

畫出來的腦圖大概是這個樣子，不一定對，但是邏輯大概出來了。。。

 

四： 問題解決

    有了上面的腦圖，寫起代碼就快啦~~~

 

1. Main函數

        public static void Main(string[] args)
        {
            var cts = new CancellationTokenSource();

            var bgtask = Task.Run(() => { TestService.Run(cts.Token); });

            AppDomain.CurrentDomain.ProcessExit += (s, e) =>
            {
                Console.WriteLine($"{DateTime.Now} 后台測試服務，准備進行資源清理！");

                cts.Cancel();    //設置IsCancellationRequested=true，讓TestService今早結束 
                bgtask.Wait();   //等待 testService 結束執行

                Console.WriteLine($"{DateTime.Now} 恭喜，Test服務程序已正常退出！");

                Environment.Exit(0);
            };

            Console.WriteLine($"{DateTime.Now} 后端服務程序正常啟動！");

            bgtask.Wait();
        }

 

   Main函數中做了如上的變更，將CancellationToken傳遞給 Run方法，這樣當我執行Cancel的時候，Run方法就能感知到Token的變化，然后就是調用Wait等待

TestService執行結束。

 

2. TestService

    public class TestService
    {
        public static void Run(CancellationToken token)
        {
            while (true)
            {
                if (token.IsCancellationRequested) break;

                Console.WriteLine($"{DateTime.Now}: 1. 獲取mysql");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 2. 獲取redis");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 3. 更新monogdb");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 4. 通知kafka");
                System.Threading.Thread.Sleep(2000);
                Console.WriteLine($"{DateTime.Now}: 5. 所有業務處理完畢");
                System.Threading.Thread.Sleep(2000);
            }
        }
    }

    

      TestService的while循環里面，在周期輪訓的開頭，加上一個IsCancellationRequested的判斷，如果Cancel()方法被調用，IsCancellationRequested就會變

成true，從而讓本方法感知到外界讓我結束，所以本邏輯就不再進行下一個周期了，從而保證業務邏輯的完整。

 

五：部署

 

      為了更好的表達效果，我加了很多的日志，還是采用nohup的模式來觀察一下程序的流轉過程。

[root@localhost netcore]# nohup dotnet ConsoleApp1.dll &
[2] 4487
[root@localhost netcore]# nohup: ignoring input and appending output to ‘nohup.out’

[root@localhost netcore]# ps -ef | grep dotnet
root       4487   2865  1 17:11 pts/0    00:00:00 dotnet ConsoleApp1.dll
root       4496   2865  0 17:11 pts/0    00:00:00 grep --color=auto dotnet
[1]-  Done                    nohup dotnet ConsoleApp1.dll
[root@localhost netcore]# kill 4487
[root@localhost netcore]# tail -100 nohup.out
9/2/18 5:11:17 PM: 1. 獲取mysql
9/2/18 5:11:17 PM 后端服務程序正常啟動！
9/2/18 5:11:19 PM: 2. 獲取redis
9/2/18 5:11:21 PM: 3. 更新monogdb
9/2/18 5:11:23 PM: 4. 通知kafka
9/2/18 5:11:25 PM: 5. 所有業務處理完畢
9/2/18 5:11:27 PM: 1. 獲取mysql
9/2/18 5:11:29 PM: 2. 獲取redis
9/2/18 5:11:31 PM: 3. 更新monogdb
9/2/18 5:11:33 PM: 4. 通知kafka
9/2/18 5:11:35 PM: 5. 所有業務處理完畢
9/2/18 5:11:37 PM: 1. 獲取mysql
9/2/18 5:11:39 PM: 2. 獲取redis
9/2/18 5:11:41 PM: 3. 更新monogdb
9/2/18 5:11:43 PM: 4. 通知kafka
9/2/18 5:11:45 PM: 5. 所有業務處理完畢
9/2/18 5:11:47 PM: 1. 獲取mysql
9/2/18 5:11:49 PM: 2. 獲取redis
9/2/18 5:11:50 PM 后台測試服務，准備進行資源清理！ 30 9/2/18 5:11:51 PM: 3. 更新monogdb
9/2/18 5:11:53 PM: 4. 通知kafka
9/2/18 5:11:55 PM: 5. 所有業務處理完畢
9/2/18 5:11:57 PM 恭喜，Test服務程序已正常退出！

 

    大家可以清楚的看到，5:11:49 收到了system給過來的kill通知，但是程序還是等到了5:11:57才真正的結束自己，這樣是不是就保證了業務流程免遭破壞呢？

好了，本篇就說到這里，希望對你有幫助。