复杂消息的消息队列实现及空间下的三种序列化器介绍
先做一个例子
1定义Customer类
public class Customer
{
public int Unid { get; set; }
public string CustomerName { get; set; }
public DateTime CreateTime { get; set; }
}
3个属性
2向队列发送
public void SendMessage(Customer customer)
{
MessageQueue _queue = CreateQueue();
Message _message = new Message(customer);
_message.Formatter =
new XmlMessageFormatter(new Type[] {typeof(Customer) });
_queue.Send(_message);
}
这里因为用到复杂消息传递不是简单的基元类型所以要用到序列化。序列化为了传输和存储进行的转换。.net提供了一些序列化工具同时还能利用其它的第三方的工具来序列化和反序列化复杂对象。
对于消息队列的序列化系统提供了三种工具
·XmlMessageFormatter 对象使用可读的 XML 字符串将对象和基元数据类型保持到消息中和从消息中取消保持。这是 MessageQueue 组件的默认格式化程序设置。
·BinaryMessageFormatter 对象将一个或多个连接的对象保持到序列化流中。其结果分析起来非常简洁快速但人们无法阅读。
·ActiveXMessageFormatter 对象保持基元数据类型从而实现与使用“消息队列”早期版本的组件的交互。产生的序列化非常简洁。此格式化程序在设计时考虑了 Windows并且不会产生人们可以阅读的结果。但它却是一种极为快捷的序列化方法。
这个后边说。
3从队列中得到消息并解析
有了序列化还要有反序列化从传输和存储中得到想要的对象。例如Customer对象
public Customer GetMessage()
{
MessageQueue _queue = CreateQueue();
_queue.Formatter =
new XmlMessageFormatter(new Type[] { typeof(Customer) });
Message _message = new Message();
_message = _queue.Peek();
return _message.Body as Customer;
}
对于XmlMessageFormatter的用法构造器请见相关帮助文档。这里为MessageQueue对象的Formatter属性指定序列化器。
这里从队列中读取消息我用的是Peek方法它在读取后不改动队列。这样便于测试。
4测试
发送
Customer _customer = new Customer
{ Unid = 2,
CustomerName = "Song江",
CreateTime = Convert.ToDateTime("2010-2-2")
};
mm.SendMessage(_customer);
接收并打印信息
Console.WriteLine(mm.GetMessage().CustomerName);
这里给出在XmlMessageFormatter序列化器的使用下的MSMQ包的内容在默认情况下也就是创建消息队列对象MessageQueue对象下如果不指定序列化器则在创建MessageQueue时同时创建XmlMessageFormatter并将两者关联
<?xml version="1.0" ?>
<Customer
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:xsd="http://www.w3.org/2001/XMLSchema">
<Unid>2</Unid>
<CustomerName>Son gæ±</CustomerName>
<CreateTime>2 010-02-02 T00:00:00</CreateTime>
</Customer>
因为之中用到了中文文字编码的原因这里看来是乱码。
5三种序列化器
1》XmlMessageFormatter
默认的序列化器在创建MessageQueue对象时同时创建并关联到消息队列对象。这里这个简称为xml序列化器。
xml序列化器可用于写入队列但如果要从队列中读取先要对设置TargetTypes或TargetTypeNames属性可以同时设置这两个属性。也可以创建xml序列化器的实例然后通过值参方式创建xml序列化器。
XmlMessageFormatter.TargetTypes
指定可能的类型集这些类型将由格式化程序从提供的消息进行反序列化。
定义
public Type[] TargetTypes { get; set; }
XmlMessageFormatter.TargetTypeNames
指定可能的类型集这些类型将由格式化程序从提供的消息进行反序列化。
定义
public string[] TargetTypeNames { get; set; }
在默认情况下xml序列化器被创建并使用可以用来传递消息。但如果要从队列中读取消息需要在读取之前显示对序列化器进行设置
·设置xml序列化器的TargetTypes属性或TargetTypeNames属性。
MessageQueue _queue = CreateQueue();
_queue.Formatter =
new XmlMessageFormatter(new Type[] { typeof(Customer) });
·通过值参数来创建xml序列化器。
MessageQueue _queue = CreateQueue();
XmlMessageFormatter _formatter = new XmlMessageFormatter();
_formatter.TargetTypes = new Type[] { typeof(Customer)};
_queue.Formatter = _formatter;
2》BinaryMessageFormatter
使用二进制将对象进行序列化和反序列化。这个简称二进制序列化器。
二进制序列化器非常有效且可用于大多数对象的序列化。序列化后的结果紧凑且可以快速分析但不允许进行松耦合消息处理。松耦合意味着客户端和服务端可以独立控制发送和接收的类型的版本。这个二进制速度快。二进制我最爱
这里给出一段经过二进制序列化器序列化的消息的包内容
.....ÿÿÿÿ......... ....?Self MSMQ,
Ver sion=1.0. 0.0, Culture=neutral,
PublicKeyToken=null....
..SelfMSMQ.Customer.....
<Unid>k__Bac kingField .
<CustomerName>k__ BackingField.
<CreateTime>k__BackingField...................Song æ±
...̱qÌ..
在使用时将上例中的xml序列化器换成二进制序列化器就可以了。二进制速度快吞吐量大。
3》ActiveXMessageFormatter
使用与 MSMQ ActiveX 组件兼容的格式将基元数据类型和其他对象序列化成“消息队列”消息体或从“消息队列”消息体反序列化基元数据类型和其他对象。与使用消息队列 COM 组件发送的消息兼容并允许与使用消息队列 COM 控件的应用程序进行互操作。
它的序列化与反序列化有要求可以序列化大多数基元类型以及实现 IPersistStream OLE 接口的对象。它可以反序列化相同的基元类型集但在反序列化实现 IPersistStream 的 COM 对象例如使用 Visual Basic 6.0 创建的对象时需要进行更多的工作。要反序列化的对象必须处于内存中通过首先将对象导入到 .NET Framework 应用程序中。
现在通过这个序列化器进行对字符串的序列化与反序列化。
这里写一个小例子
发送
public void SendMessage(string strMsg)
{
MessageQueue _queue = CreateQueue();
Message _message = new Message(strMsg);
_message.Formatter = new ActiveXMessageFormatter();
_queue.Send(_message);
}
接收
public string ReceiveMessage()
{
MessageQueue _queue = CreateQueue();
Message _message = _queue.Peek();
_message.Formatter = new ActiveXMessageFormatter();
return _message.Body.ToString();
}
测试
mm.SendMessage("这里ActiveX序列化器");
……
Console.WriteLine(mm.ReceiveMessage());
……
打印这里ActiveX序列化器
对于这个包内容这里不给出了。