2

我在 Azure 存储中有一个队列，我希望能够将不同的消息类型添加到队列中并将它们解析为它们的特定类型。

例如。

public class Customer
{
   public Customer()
   {
   }

   public string Name { get; set;}
   public string Email { get; set;}
   public string Address { get; set;}
}

public class Employee
{
   public Employee()
   {
   }

   public string Id { get; set;}
   public string Name { get; set;}
   public string Email { get; set;}
}

我可以将它们序列化为 JSON 并将它们添加到队列中，但是如何在不知道消息类型的情况下将它们反序列化为它们的特定类型？

我怎么知道下一条消息是客户还是员工？我可以在消息中添加某种属性说：“这是客户”或“这是员工”...

因为我有一个工作角色，它将在队列中查找消息并根据类型执行特定操作

get message from queue

If message = customer
  do this
else if message = employee
  do that
else 
  do nothing
4

3 回答 3

1

我在一个项目中做了以下事情。

将消息类型存储为（我要发送的类BrokeredMessage在哪里）的属性：entity

var msg = new BrokeredMessage(entity);
msg.ContentType = entity.GetType().AssemblyQualifiedName;
myClient.Send(msg);

在接收方，我有这个扩展方法来获取正确类型的消息：

public static object GetBodyOfType(this BrokeredMessage msg)
{
    var ofType = Type.GetType(msg.ContentType);
    var method = typeof(BrokeredMessage).GetMethod("GetBody", new Type[] { });
    var generic = method.MakeGenericMethod(ofType);
    return generic.Invoke(msg, null);
}

然后我的实际接收器执行此操作（receivedMessage是 a BrokeredMessage）：

var msg = receivedMessage.GetBodyOfType();

这给了我msg哪个是我排队的类型。

我使用它的模式与您描述的相似。我将命令排队到 ServiceBus，并有一个工作角色来处理它通过命令处理程序接收到的任何命令。到目前为止，它运行良好。

编辑：我刚刚意识到您提到了存储队列，而上面是我用于服务总线的。希望该解决方案将适用。

于 2014-07-02T12:28:54.913 回答
1

Azure 存储客户端库不提供对反序列化队列消息的显式支持。因此，请检查您为此使用的序列化程序。例如，如果您使用DataContractSerializer，则可以在序列化/反序列化期间使用已知类型来处理继承。

于 2014-07-03T05:07:58.387 回答
1

我过去是这样做的。我已经将对象的类型作为字符串记录到消息中，然后添加了一些分隔符：#然后添加了 json-serialised 字符串。

所以我的信息看起来像这样：

MyProject.Domain.Model.Product#{'Id':'42','ProductName':'SuperHumanEnchancer'}

在回来的路上，您阅读分隔符之前的任何内容并将其视为类型名称。分隔符号后的字符串将是您的 json 序列化字符串。

于 2014-07-03T22:51:16.080 回答