MSMQ(3)——复杂的消息及系统提供的序列化器

简介: 复杂消息的消息队列实现及空间下的三种序列化器介绍 先做一个例子: (1)定义Customer类 public class Customer { public int Unid { get; set; } public string CustomerName { get; set; } ...

复杂消息的消息队列实现及空间下的三种序列化器介绍

先做一个例子

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三种序列化器

1XmlMessageFormatter

默认的序列化器在创建MessageQueue对象时同时创建并关联到消息队列对象。这里这个简称为xml序列化器。

xml序列化器可用于写入队列但如果要从队列中读取先要对设置TargetTypesTargetTypeNames属性可以同时设置这两个属性。也可以创建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;

 

2BinaryMessageFormatter

使用二进制将对象进行序列化和反序列化。这个简称二进制序列化器。

二进制序列化器非常有效且可用于大多数对象的序列化。序列化后的结果紧凑且可以快速分析但不允许进行松耦合消息处理。松耦合意味着客户端和服务端可以独立控制发送和接收的类型的版本。这个二进制速度快。二进制我最爱

这里给出一段经过二进制序列化器序列化的消息的包内容

.....ÿÿÿÿ......... ....?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序列化器换成二进制序列化器就可以了。二进制速度快吞吐量大。

3ActiveXMessageFormatter

使用与 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序列化器

对于这个包内容这里不给出了。

 

博客园大道至简

http://www.cnblogs.com/jams742003/

转载请注明博客园

目录
相关文章
|
3月前
|
存储 Java
【IO面试题 四】、介绍一下Java的序列化与反序列化
Java的序列化与反序列化允许对象通过实现Serializable接口转换成字节序列并存储或传输,之后可以通过ObjectInputStream和ObjectOutputStream的方法将这些字节序列恢复成对象。
|
3月前
|
存储 开发框架 .NET
解锁SqlSugar新境界:利用Serialize.Linq实现Lambda表达式灵活序列化与反序列化,赋能动态数据查询新高度!
【8月更文挑战第3天】随着软件开发复杂度提升,数据查询的灵活性变得至关重要。SqlSugar作为一款轻量级、高性能的.NET ORM框架,简化了数据库操作。但在需要跨服务共享查询逻辑时,直接传递Lambda表达式不可行。这时,Serialize.Linq库大显身手,能将Linq表达式序列化为字符串,实现在不同服务间传输查询逻辑。结合使用SqlSugar和Serialize.Linq,不仅能够保持代码清晰,还能实现复杂的动态查询逻辑,极大地增强了应用程序的灵活性和可扩展性。
130 2
|
2天前
|
JSON 数据格式 索引
Python中序列化/反序列化JSON格式的数据
【11月更文挑战第4天】本文介绍了 Python 中使用 `json` 模块进行序列化和反序列化的操作。序列化是指将 Python 对象(如字典、列表)转换为 JSON 字符串,主要使用 `json.dumps` 方法。示例包括基本的字典和列表序列化,以及自定义类的序列化。反序列化则是将 JSON 字符串转换回 Python 对象,使用 `json.loads` 方法。文中还提供了具体的代码示例,展示了如何处理不同类型的 Python 对象。
|
13天前
|
存储 安全 Java
Java编程中的对象序列化与反序列化
【10月更文挑战第22天】在Java的世界里,对象序列化和反序列化是数据持久化和网络传输的关键技术。本文将带你了解如何在Java中实现对象的序列化与反序列化,并探讨其背后的原理。通过实际代码示例,我们将一步步展示如何将复杂数据结构转换为字节流,以及如何将这些字节流还原为Java对象。文章还将讨论在使用序列化时应注意的安全性问题,以确保你的应用程序既高效又安全。
|
26天前
|
存储 Java
Java编程中的对象序列化与反序列化
【10月更文挑战第9天】在Java的世界里,对象序列化是连接数据持久化与网络通信的桥梁。本文将深入探讨Java对象序列化的机制、实践方法及反序列化过程,通过代码示例揭示其背后的原理。从基础概念到高级应用,我们将一步步揭开序列化技术的神秘面纱,让读者能够掌握这一强大工具,以应对数据存储和传输的挑战。
|
1月前
|
存储 安全 Java
Java编程中的对象序列化与反序列化
【10月更文挑战第3天】在Java编程的世界里,对象序列化与反序列化是实现数据持久化和网络传输的关键技术。本文将深入探讨Java序列化的原理、应用场景以及如何通过代码示例实现对象的序列化与反序列化过程。从基础概念到实践操作,我们将一步步揭示这一技术的魅力所在。
|
13天前
|
存储 缓存 NoSQL
一篇搞懂!Java对象序列化与反序列化的底层逻辑
本文介绍了Java中的序列化与反序列化,包括基本概念、应用场景、实现方式及注意事项。序列化是将对象转换为字节流,便于存储和传输;反序列化则是将字节流还原为对象。文中详细讲解了实现序列化的步骤,以及常见的反序列化失败原因和最佳实践。通过实例和代码示例,帮助读者更好地理解和应用这一重要技术。
10 0
|
2月前
|
存储 XML JSON
用示例说明序列化和反序列化
用示例说明序列化和反序列化
|
2月前
|
JSON fastjson Java
niubility!即使JavaBean没有默认无参构造器,fastjson也可以反序列化。- - - - 阿里Fastjson反序列化源码分析
本文详细分析了 Fastjson 反序列化对象的源码(版本 fastjson-1.2.60),揭示了即使 JavaBean 沲有默认无参构造器,Fastjson 仍能正常反序列化的技术内幕。文章通过案例展示了 Fastjson 在不同构造器情况下的行为,并深入探讨了 `ParserConfig#getDeserializer` 方法的核心逻辑。此外,还介绍了 ASM 字节码技术的应用及其在反序列化过程中的角色。
69 10
|
2月前
|
存储 Java 开发者
Java编程中的对象序列化与反序列化
【9月更文挑战第20天】在本文中,我们将探索Java编程中的一个核心概念——对象序列化与反序列化。通过简单易懂的语言和直观的代码示例,你将学会如何将对象状态保存为字节流,以及如何从字节流恢复对象状态。这不仅有助于理解Java中的I/O机制,还能提升你的数据持久化能力。准备好让你的Java技能更上一层楼了吗?让我们开始吧!