public async Task Method() { _context.CurrentUser = "test"; //await _service2.Method(); //_service2.Method(); //await _mediator.Publish(new SomeEvent()); _mediator.Publish(new SomeEvent()); await Task.CompletedTask; }
见注释前后，改进地方只有一处，发布事件代码去掉了await，这样系统发布事件之后，便不会等待Service2而是继续运行并立刻响应HTTP请求。好，我们再来运行看下效果：
我们看到，系统立即响应了HTTP请求（22:40:15），5s之后，Service2才执行完成（22:40:20）。看似又没问题了。那是不是真的没问题呢？我们注意，Service1和Service2中，都注入了一个Context上下文对象，这个对象是我用来模拟一些Scope类型对象，例如DBContext的，代码如下：
public class Context : IContext, IDisposable { private bool _isDisposed = false; private string _currentUser; public string CurrentUser { get { if (_isDisposed) { throw new Exception("Context disposed"); } return _currentUser; } set { if (_isDisposed) { throw new Exception("Context disposed"); } _currentUser = value; } } public void Dispose() { _isDisposed = true; } }
里边就一个属性，当前上下文用户，并实现了Dispose模式，并且当前上下文被释放时，对该上下文对象任何操作将引发异常。从上文的Service1及Service2截图中，我们看到了，两个服务均注入了这个context对象，Service1设置，Service2中获取。现在我们将Service2的Method方法稍作调整，如下：
public async Task Method() { //_logger.LogDebug("当前用户:{0}", _context.CurrentUser); await Task.Delay(5000); _logger.LogDebug("当前用户:{0}", _context.CurrentUser); _logger.LogDebug("Service2 Method at :{0}", DateTime.Now); }
调整只有一处，就是获取当前上下文用户的操作，从5s延时之前，放到了5s延时之后。我们再来看看效果：
http请求上看，貌似没问题，立即响应了，是吧。我们再看看程序日志输出：
WFT！Service2 Method没成功执行，给了我一个异常。我们看看这个异常：
Context dispose异常，就是说上下文这时候已经被释放掉，对它任何操作都无效并引发异常。很容易想到，这里就是为了模拟DBContext这种通常为Scope类型的对象生命周期，这种吊毛它就这样。为啥会释放？因为HTTP请求结束那会儿，core运行时就会Dispose相应scope类型对象（注意，释放，不一定是销毁，具体销毁时间不确定）。那么，怎么解决？如果对基于DI生命周期比较熟悉，就会知道，这儿应该基于HTTP 的Scope之外，单独起一个Scope了，两个scope互补影响，HTTP对应的scope结束，另外的照常运行。我们将Handler处调整如下：
public async Task Handle(SomeEvent notification, CancellationToken cancellationToken) { //await _service2.Method(); using (var scope = _serviceProvider.CreateScope()) { var service2 = scope.ServiceProvider.GetService<IService2>(); await service2.Method(); } }
无非就是Handle中单独起了一个Scope。我们再看运行效果：
OK，HTTP请求23:02:58响应，Service2 Method 23:03:03执行完成。至此，问题才算得到解决。
顺便提一下，大家注意看截图，当前用户null，因为scope之后，原来的设置过CurrentUser的context已经释放掉了，新开的scope中注入的context是另外的，所以没任何信息。这里你可能会问了，那我确实需要传递上下文怎么办？答案是，订阅事件，本文中SomeEvent未定义任何信息，如果你需要传递，做对应调整即可，比较简单，也不是重点，不做赘述。
4、总结
感觉，没什么好总结的。扎实，细心，实践，没什么解决不了的。
好了，以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对脚本之家的支持。
您可能感兴趣的文章: