0

我们需要从数据库发布多个事件作为 json 字符串。像这样通过公共交通发布这个 json 事件：

   using var scope = _serviceScopeFactory.CreateScope();
            var sendEndpointProvider = scope.ServiceProvider.GetService<ISendEndpointProvider>();
            var endpoint = await sendEndpointProvider.GetSendEndpoint(new System.Uri("exchange:IntegrationEvents.DynamicEvent:DynamicEvent"))
            var json = JsonConvert.SerializeObject(dynamicObject, Newtonsoft.Json.Formatting.None);// sample 
            var obj = JsonConvert.DeserializeObject(json, new JsonSerializerSettings { });
            await endpoint.Send(obj,i=>i.Serializer.ContentType.MediaType= "application/json");

在配置中我们使用这个配置：

   cfg.UseRawJsonSerializer();

使用此配置时，json 事件已成功发布，但我们有一个奇怪的问题：“all”事件使用者被空消息数据调用！...在Rabbitmq jsut 中发布了我们的“动态事件”，但在masstrasit 中，所有消费者都调用了！感谢您让我们知道我们是否犯了错误

4

2 回答 2

0

我像这样使用 ExpandoObject 并得到这个异常“消息类型不能在系统命名空间中：System.Dynamic.ExpandoObject ”：

dynamic dynamicObject = new ExpandoObject();
dynamicObject.Id = 1;
dynamicObject.Name = "NameForName";

await endpoint.Send(dynamicObject);

并像这样使用我们得到与“所有消费者称为”相同的结果：

 var dynamicObject = new ExpandoObject() as IDictionary<string, object>;
 dynamicObject.Add("Id", 1);
 dynamicObject.Add("Name", "NameForName");

我观看了您的精彩视频，您直接从 rabbitmq 使用 .. 如何在 C# 代码中“使用带有为 RawJson 配置的序列化程序的端点发送消息对象”。

于 2021-10-13T14:14:11.590 回答
0

您不需要所有的 JSON 操作，只需使用为 RawJson 配置的序列化程序的端点发送消息对象。我在此视频中介绍了 JSON 互操作性。

此外，MassTransit 不允许发布匿名类型。您可能能够发布动态或 Expando 对象。

于 2021-10-13T12:51:48.810 回答