Azure Messaging-ServiceBus Messaging消息队列技术系列4-复杂对象消息是否需要支持序列化和消息持久化 Azure Messaging-ServiceBus Messaging消息队列技术系列3-消息顺序保证

Azure 2020-11-16

在上一篇中，我们介绍了消息的顺序收发保证：

Azure Messaging-ServiceBus Messaging消息队列技术系列3-消息顺序保证

在本文中我们主要介绍下复杂对象消息是否需要支持序列化以及消息的持久化。

在实际的业务应用开发中，我们经常会将复杂业务对象放到消息里面，实现异构系统之间的集成、模块间的解耦等等。

同时，我们还比较关注消息队列服务是否支持消息的持久化，消息队列如果宕机后持久化的消息是否可以还原？

在Azure Messaging的官方说明中，没有特地的介绍复杂对象消息是否需要支持序列化的要求，但是，我们在上篇博文中，有个消息创建方法，as following,

BrokeredMessage类的构造函数：

//
        // Summary:
             Constructor that creates a BrokeredMessage from a given object using the
             provided XmlObjectSerializer
         Parameters:
           serializableObject:
             The serializable object.
           serializer:
             The serializer object.
         Exceptions:
           System.ArgumentNullException:
             Thrown when null serializer is passed to the method with a non-null serializableObject
         Remarks:
             You should be aware of the exceptions that their provided Serializer can
             throw and take appropriate actions. Please refer to for a possible list of
             exceptions and their cause.
        public BrokeredMessage(object serializableObject,XmlObjectSerializer serializer);

看来消息的构造，支持动态传入XmlObjectSerializer,so,

 1         /// <summary>
 2         /// 构造消息
 3         </summary>
 4         <param name="serializableObject">可序列化的对象</param>
 5         <returns>消息</returns>
 6         public BrokeredMessage Create(Object serializableObject)
 7         {
 8             var serializer = new DataContractSerializer(serializableObject.GetType(), 9                 new DataContractSerializerSettings() { IgnoreExtensionDataObject = true,PreserveObjectReferences = true });
10             var message =  BrokeredMessage(serializableObject,serializer);
11             message.Properties.Add("Type",serializableObject.GetType().ToString());
12 
13             return message;
14         }

接下来，我们用上一篇中的代码，做一个复杂对象消息收发的测试，我们还是用上次的SalesOrder类，但是增加一个SalesOrderItem集合和双向关联，来描述销售订单和销售订单明细的的1：n的业务领域模型。

using System;
 System.Collections.Generic;
 System.Linq;
 System.Text;
 System.Threading.Tasks;

namespace AzureMessaging.FIFO
{
    <summary>
     销售订单类
    </summary>
    public class SalesOrder
    {
        <summary>
         订单ID
        </summary>
        string OrderID { get; set; }

         订单编号
        string Code {  创建时间
        public DateTime CreateTime {  总价格
        public Decimal TotalPrice {  产品ID
        int ProductID { ; }

        private List<SalesOrderItem> items;

         销售订单明细
        public List<SalesOrderItem> Items
        {
            get
            {
                if (items == null)
                    items = new List<SalesOrderItem>();

                 items;
            }
            
            {
                items = value;
            }
        }
    }
}

 销售订单明细
     SalesOrderItem
    {
         标识
        string ID {  客户ID
        int CustomerID {  所属的销售订单ID
        string SalesOrderID
        {
            if (Order != )
                     Order.OrderID;

                return .Empty;
            }
        }

         所属的销售订单
        public SalesOrder Order { ; }
    }
}

创建销售订单实例类方法：

  private static SalesOrder CreateSalesOrder(int i)
        {
            var order = new SalesOrder() { OrderID = i.ToString(),Code = SalesOrder_" + i,CreateTime = DateTime.Now,ProductID = 17967,TotalPrice = new decimal(19999) };
            order.Items.Add(new SalesOrderItem() { ID = Guid.NewGuid().ToString(),Order = order,CustomerID = 1234567 });

             order;
        }

在构造SalesOrder和SalesOrderItems时，我们做了双向关联。
消息顺序收发测试：

 1  Microsoft.ServiceBus.Messaging;
 2  3  4  5  6  System.Threading.Tasks;
 7 
 8  AzureMessaging.FIFO
 9 {
10      Program
11     {
12         static readonly string queueName = OrderQueue;
13         void Main([] args)
14 15             MessageSend();
16             Console.ReadKey();
17 
18             MessageReceive();
19 20         }
21 
22         23          发送消息
24         25         void MessageSend()
26 27             var sbUtils =  ServiceBusUtils();
28 
29             创建队列
30             sbUtils.CreateQueue(queueName,false);
31 
32             顺序发送消息到OrderQueue
33             var queueSendClient = sbUtils.GetQueueClient(queueName);
34             for (int i = 0; i < 10; i++)
35             {
36                 var order = CreateSalesOrder(i);
37                 var message = sbUtils.Create(order);
38                 queueSendClient.Send(message);
39                 Console.WriteLine(string.Format(Send {0} MessageID: {1}40             }
41 
42             Console.WriteLine(Send Completed!43 44 
45         46          接收消息
47         48          MessageReceive()
49 50             int index = 051             BrokeredMessage msg = 52             53             var queueReveiveClient = sbUtils.GetReceiveQueueClient(queueName,ReceiveMode.ReceiveAndDelete);
54             while ((msg = queueReveiveClient.Receive(TimeSpan.FromMilliseconds(3))) != 55 56                 Console.WriteLine(Received {0} MessageID: {1}57                 index++58 59 
60             /删除队列
61             sbUtils.DeleteQueue(queueName);
62 
63             Console.WriteLine(Receive Completed!64 65 
66          i)
67 68             ) };
69             order.Items.Add(70 
71              order;
72 73     }
74 }