3

我正在开发一个基本上运行以下代码的 Windows 服务:

public class ServiceController
{
  private FundsEngine _fundsEngine;

  protected override void OnStart(string[] args)
  {
    var logsPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "logs");
    if (Directory.Exists(logsPath) == false)
    {
      Directory.CreateDirectory(logsPath);
    }

    _fundsEngine = new FundsEngine();
    _fundsEngine.Start();
  }
}

该服务可以启动“引擎”,这些引擎只是使用计时器以指定时间间隔执行代码的类。

下面的类是一个 Engine 示例,用于每 5 秒System.Threading.Timer调用一次回调。OnTick()

public class FundsEngine
{
  private System.Threading.Timer _timer;
  private static Logger _logger = LogManager.GetCurrentClassLogger();

  public void Start()
  {
    _logger.Trace("Begin Start");

    try
    {
      // details omitted

      _timer = new Timer(OnTick);
      _timer.Change(5000, Timeout.Infinite);
    }
    catch (Exception exception)
    {
      _logger.ErrorException("Error in Start.", exception);
    }
    finally
    {
      _logger.Trace("End Start");
    }
  }

  private void OnTick(object state)
  {
    _logger.Trace("Begin Tick");

    try
    {
      // do stuff
      _timer.Change(5000, Timeout.Infinite);
    }
    catch (Exception exception)
    {
      _logger.ErrorException("Error in Tick. ", exception);
    }
    finally
    {
      _logger.Trace("End Tick");
    }
  }
}

如下日志所示,Timer 按预期工作,OnTick()每 5 秒调用一次方法。

2013-05-14 16:27:01.2261|TRACE|Begin Start 
2013-05-14 16:27:03.8514|TRACE|End Start 
2013-05-14 16:27:08.8569|TRACE|Begin Tick 
2013-05-14 16:27:08.8709|TRACE|End Tick 
2013-05-14 16:27:13.8734|TRACE|Begin Tick 
2013-05-14 16:27:13.8734|TRACE|End Tick 
2013-05-14 16:27:18.8809|TRACE|Begin Tick 
2013-05-14 16:27:18.8809|TRACE|End Tick 
2013-05-14 16:27:23.8894|TRACE|Begin Tick 
2013-05-14 16:27:23.8894|TRACE|End Tick 
2013-05-14 16:27:28.8969|TRACE|Begin Tick 
2013-05-14 16:27:28.8969|TRACE|End Tick 
2013-05-14 16:27:33.9044|TRACE|Begin Tick 
2013-05-14 16:27:33.9044|TRACE|End Tick 

如果在方法中捕获到异常OnTick(),我的期望是它会被记录下来,并且服务将继续运行,这样该OnTick()方法将在 5 秒内再次被调用。但是,情况并非如此,因为在处理完异常后不会再次调用回调。为什么是这样?

2013-05-14 16:29:03.8574|TRACE|Begin Start 
2013-05-14 16:29:03.8574|TRACE|End Start 
2013-05-14 16:29:08.8709|TRACE|Begin Tick 
2013-05-14 16:29:09.9750|ERROR|Error in Tick.  System.Net.Sockets.SocketException (0x80004005): No connection could be made because the target machine actively refused it 127.0.0.1:22
2013-05-14 16:29:09.9750|TRACE|End Tick
4

2 回答 2

2
  _timer.Change(5000, Timeout.Infinite);

您没有创建周期计时器,将 Infinite 传递给period参数。计时器只会调用一次 OnTick()。然而,代码非常不完整,它可以工作的唯一方法是再次调用 Change() 来为计时器充电。

这个 Change() 调用被异常绕过的几率如此之高。如果你想让它继续下去,那么这个 Change() 调用属于finally块。尽管这样做实际上并不是一个好主意,但进程状态已损坏并且它会再次崩溃的非零几率。一遍又一遍。您至少应该对此采取对策,并计算连续崩溃的次数,当它反复炸弹时放弃。

于 2013-05-15T16:18:44.067 回答
1

这个 StackOverflow帖子上接受的答案指出,如果发生异常......

System.Threading.Timer将终止程序。

我相信这就是你所看到的。

于 2013-05-15T13:41:36.387 回答