JMS微服务开发示例（六）安全退出进程

默认情况下，如果在linux，需要关闭微服务进程，请务必使用 kill -15 进程id 命令，其他命令可能会直接关闭进程，造成数据丢失。

例如，有个后台任务，执行了一半，这时候进程突然关闭了，会形成一些无法预计的后果。

Kill -15 命令的安全性

默认情况下，当发出kill -15命令，JMS会自动需要按顺序，做完以下事情后，才让进程关闭：

1、执行IProcessExitHandler添加的任务

2、断开网关连接

3、等待事务托管中心事务清零

4、等待定时任务执行完毕（指 MicroServiceHost.RegisterScheduleTask 注册的任务）

5、等待客户端请求数清零

但是，可能有些后台任务，是你用其他方式启动的，所以，为了保证数据完整性，对于一些后台执行的任务，如果不是使用MicroServiceHost.RegisterScheduleTask开启的定时任务，那么，你需要手动写一些代码保证你的任务执行完毕后，进程才会退出。

可以参考以下示例：

    /// <summary>
    /// 事件处理队列
    /// </summary>
    class MyActionQueue:IDisposable
    {
        System.Threading.AutoResetEvent _waitObj = new System.Threading.AutoResetEvent(false);
        ConcurrentQueue<Action> Actions { get; }
        IProcessExitHandler _processExitHandler;
        bool _exited;
        public MyActionQueue(JMS.IProcessExitHandler processExitHandler)//依赖注入IProcessExitHandler实例
        {
            this.Actions = new ConcurrentQueue<Action>();
            
            _processExitHandler = processExitHandler;

            //指定当进程退出时，调用onProcessExit()
            _processExitHandler.AddHandler(onProcessExit);

            //启动一个后台任务
            new Thread(run).Start();
        }

        private void onProcessExit()
        {
            try
            {
                var obj = _waitObj;
                _waitObj = null;
                obj.Set();
                obj.Dispose();
                while(!_exited) //只有_exited = true时，才表示任务执行完毕，不会有任务执行了一半
                {
                    Thread.Sleep(100);
                }
            }
            catch
            {

            }
        }

        /// <summary>
        /// 添加一个任务到队列当中
        /// </summary>
        /// <param name="action"></param>
        public void AddAction(Action action)
        {
            this.Actions.Enqueue(action);
            //通知队列马上执行
            _waitObj.Set();
        }

        void run()
        {
            while (!_processExitHandler.ProcessExited)
            {
                try
                {
                    _waitObj.WaitOne();
                    if (_waitObj == null)
                        break;

                    //执行队列里面的任务
                    if (this.Actions.TryDequeue(out Action o))
                    {
                        o();
                    }
                }
                catch
                {

                }
            }
            _exited = true;
        }

        public void Dispose()
        {
            onProcessExit();
        }
    }