RabbitMQ 似乎有两个非常相似的属性，我并不完全理解其中的区别。ConversationId and CorrelationId.
我的用例如下。我有一个网站，可以生成Guid。该网站调用 API，将该唯一标识符添加到HttpRequest标头。这又会向 RabbitMQ 发布一条消息。该消息由第一个消费者处理，然后传递给其他消费者，依此类推。
出于记录目的，我想记录一个将初始请求与所有后续操作联系在一起的标识符。对于整个应用程序不同部分的旅程来说，这应该是唯一的。因此。当记录到像 Serilog/ElasticSearch 这样的东西时，就可以很容易地看到哪个请求触发了初始请求，并且整个应用程序中该请求的所有日志条目都可以关联在一起。
我创建了一个提供者来查看传入的HttpRequest为标识符。我将其称为“CorrelationId”，但我开始怀疑这是否真的应该命名为“ConversationId”。就 RabbitMQ 而言，“ConversationId”的想法更适合该模型，还是“CorrelationId”更好？
这两个概念有什么区别？
在代码方面，我希望执行以下操作。首先在我的API中注册总线并配置SendPublish使用CorrelationId来自提供商。
// bus registration in the API
var busSettings = context.Resolve<BusSettings>();
// using AspNetCoreCorrelationIdProvider
var correlationIdProvider = context.Resolve<ICorrelationIdProvider>();
var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
cfg.Host(
new Uri(busSettings.HostAddress),
h =>
{
h.Username(busSettings.Username);
h.Password(busSettings.Password);
});
cfg.ConfigurePublish(x => x.UseSendExecute(sendContext =>
{
// which one is more appropriate
//sendContext.ConversationId = correlationIdProvider.GetCorrelationId();
sendContext.CorrelationId = correlationIdProvider.GetCorrelationId();
}));
});
作为参考，这是我的简单提供者界面
// define the interface
public interface ICorrelationIdProvider
{
Guid GetCorrelationId();
}
以及 AspNetCore 实现，它提取调用客户端（即网站）设置的唯一 ID。
public class AspNetCoreCorrelationIdProvider : ICorrelationIdProvider
{
private IHttpContextAccessor _httpContextAccessor;
public AspNetCoreCorrelationIdProvider(IHttpContextAccessor httpContextAccessor)
{
_httpContextAccessor = httpContextAccessor;
}
public Guid GetCorrelationId()
{
if (_httpContextAccessor.HttpContext.Request.Headers.TryGetValue("correlation-Id", out StringValues headers))
{
var header = headers.FirstOrDefault();
if (Guid.TryParse(header, out Guid headerCorrelationId))
{
return headerCorrelationId;
}
}
return Guid.NewGuid();
}
}
最后，我的服务主机是简单的 Windows 服务应用程序，它们坐着并使用已发布的消息。他们使用以下内容来获取 CorrelationId，并且很可能会发布给其他消费者以及其他服务主机中的其他消费者。
public class MessageContextCorrelationIdProvider : ICorrelationIdProvider
{
/// <summary>
/// The consume context
/// </summary>
private readonly ConsumeContext _consumeContext;
/// <summary>
/// Initializes a new instance of the <see cref="MessageContextCorrelationIdProvider"/> class.
/// </summary>
/// <param name="consumeContext">The consume context.</param>
public MessageContextCorrelationIdProvider(ConsumeContext consumeContext)
{
_consumeContext = consumeContext;
}
/// <summary>
/// Gets the correlation identifier.
/// </summary>
/// <returns></returns>
public Guid GetCorrelationId()
{
// correlationid or conversationIs?
if (_consumeContext.CorrelationId.HasValue && _consumeContext.CorrelationId != Guid.Empty)
{
return _consumeContext.CorrelationId.Value;
}
return Guid.NewGuid();
}
}
然后，我的消费者中有一个记录器，它使用该提供程序来提取CorrelationId:
public async Task Consume(ConsumeContext<IMyEvent> context)
{
var correlationId = _correlationProvider.GetCorrelationId();
_logger.Info(correlationId, $"#### IMyEvent received for customer:{context.Message.CustomerId}");
try
{
await _mediator.Send(new SomeOtherRequest(correlationId) { SomeObject: context.Message.SomeObject });
}
catch (Exception e)
{
_logger.Exception(e, correlationId, $"Exception:{e}");
throw;
}
_logger.Info(correlationId, $"Finished processing: {DateTime.Now}");
}
正在阅读docs http://masstransit-project.com/MassTransit/usage/correlation.html，它对“ConversationId”说了以下内容：
对话由发送的第一条消息创建或
已发布，其中没有可用的现有上下文（例如当
消息通过使用 IBus.Send 或 IBus.Publish 发送或发布）。如果
现有上下文用于发送或发布消息，
ConversationId 被复制到新消息中，确保一组
同一对话中的消息具有相同的标识符。
现在我开始认为我的术语混淆了，从技术上讲，这是一次对话（尽管“对话”就像“电话游戏”）。
So, CorrelationId在此用例中，或ConversationId？请帮助我正确理解我的术语！！
