如何在微服务架构中包含 CorrelationId？

Question

我正在使用 ASP.NET Core Web api 创建一个微服务架构。所有的服务都是相互解耦的，可以部署在不同的环境中。每个服务都有自己的日志记录。当请求流经这些服务时，任何服务都可能失败，我们需要一种将一系列事件追溯到源头的方法，即使这意味着要遍历多个服务。
因此，为了处理这个问题，发起请求的服务会创建一个 CorrelationId 并将其传递给下一个服务。第二服务将其传递给第三服务，依此类推。如果发生异常，相应的服务会将异常消息与 CorrelationId 一起记录。

我想知道服务调用者传递相关 ID 的最佳位置是什么？

调用者应该在 HttpHeader 中传递相关 ID 还是应该将其作为部分方法参数传递，如下所示

这是被调用的服务

 public class RequestDTO
 {
    public string CorrelationId {get;set;}
    public string SomeOtherData {get;set;}
 }

 public Service2Controller:Controller
 {
    public Task<in> DoSomething(RequestDTO request)
    {
         // add the correlationid in current request Items collection
         // So global exception handling can access it and log it 
         // along with the exception

         HttpContext.Items.Add("CorrelationId", request.CorrelationId);
    }
 }

在上述方法中，如果在调用此方法之前出现异常，则 CorrelationId 将无法用于全局异常处理程序进行日志记录。

有什么建议吗？或替代方法

Answer 1

相关标识符不应该是你自己添加的东西，一些发送消息的框架应该这样做。这样开发人员就不会忘记它，并且它在所有地方都有一致的行为。

在邮件标题中添加MessageId 和CorrelationId。在第一条消息上，两者都是相同的。在第二条消息中，CorrelationId 设置为上一条消息的 MessageId。

您还可以设置一个永远不会更改的唯一ConversationId，以跟踪来自一个发起者的所有消息。在使用 pub/sub 和/或回调消息的发起者时很有用。