微波EDA网,见证研发工程师的成长!
首页 > 应用设计 > 消费类电子 > MSMQ技术在Windows Mobile系统通信中应用

MSMQ技术在Windows Mobile系统通信中应用

时间:02-14 来源:中电网 点击:

指向队列的路径必须是唯一的。表1列出用于每种类型的队列的路径信息。

如果是发送到本机上,还可以使用"."代表本机名称。具体的引用方法可以在初始化消息队列时设置,也可以通过设置消息队列的Path属性来实现。如果在初始化时引用消息队列,那么消息队列必须存在于系统中,否则会产生错误。在程序中可以实现消息队列的创建。

在初始化时引用消息队列的代码如下:

MessageQueue Mq=new MessageQueue(".\private$\mq");

通过Path属性引用消息队列的代码:

MessageQueue Mq=new

MessageQueue();

Mq.Path=".\private$\mq";

如果消息队列不存在,可以使用 Create方法可在计算机上创建队列,实现代码如下:

System.Messaging.MessageQueue.

Create(@".private$mq");

发送消息

应用程序引用消息队列后,就可以进行发送和接收消息操作。发送的消息可以分为简单消息和复杂消息,简单消息类型就是常用的数据类型,例如整型、字符串等数据;复杂消息的数据类型通常对应于系统中的复杂数据类型,例如结构体和类对象等。

简单消息的发送示例如下:

Mq.Send(1000); //发送整型数据

1000

Mq.Send("This is a test

message!"); //发送字符串

复杂消息的发送和简单消息的发送大同小异,只是发送时,通常不是直接给出发送的消息内容,而是代表发送消息内容的变量。下面的代码分别通过消息变量和复杂数据类型变量发送一条复杂消息。

下面的代码中发送的消息由消息变量表示:

Message Msg;

Msg=new Message("A Complex

Message!");

Msg.Label="This is the label";

Msg.Priority=MessagePriority.High; Mq.Send(Msg);

下面的代码中发送的消息由复杂数据类型变量表示,Customer为自定义的一个类:

Customer customer = new

Customer();

customer.LastName = "Copernicus";

customer.FirstName = "Nicolaus";

Mq.Send(customer);

接收消息

接收消息相比发送消息要复杂一些。接收消息有两种方式:通过Receive方法接收消息同时永久性地从队列中删除消息;通过Peek方法从队列中取出消息而不从队列中移除该消息。如果知道消息的标识符(ID),还可以通过ReceiveById方法和PeekById方法完成相应的接收消息操作。

接收消息的代码如下:

Mq.Receive(); //或

Mq.ReceiveById(ID);

Mq.Peek(); // 或

Mq.PeekById(ID);

阅读消息

只有通过根据通信双方的约定将接收到的消息中信息提取出来,传递的消息才有价值,因此接收到消息以后还必须能读出消息中包含的信息。在发送端的应用程序发送的消息和消息队列中的传输消息的格式不同,因而发送端的应用程序发送出去的消息经过序列化以后才发送给了消息队列,这一过程由系统自动完成了,程序开发人员不必为此编写代码,然而在接收到消息后就需要对接收的消息进行反序列化。

消息的反序列化可以通过Visual Studio和.NET Framework附带的三个预定义的格式化程序来完成:XMLMessageFormatter对象(MessageQueue组件的默认格式化程序设置)、BinaryMessageFormatter对象、ActiveXMessageFormatter对象。由于后两者格式化后的消息通常不能被用户阅读,所以经常采用XMLMessageFormatter对象对接收的消息进行反序列化。

使用XMLMessageFormatter对象反序列化消息的代码如下:

string[] types = { "System.String" };

((XmlMessageFormatter)mq.Formatter).TargetTypeNames = types;

Message m=mq.Receive(new

TimeSpan(0,0,3));

将接收到的消息传送给消息变量以后,通过消息变量m的Body属性就可以读出消息了:

MessageBox.Show((string)m.Body);

关闭消息队列

关闭消息队列可以通过Close函数来实现,代码如下:

Mq.Close();

结语

基于Windows Mobile平台的高速无线网络为各行业客户提供更加可靠便捷的移动解决方案。消息队列技术保证移动设备与数据中心之间进行良好的通信。通过对Windows Mobile平台上,发送、接收和阅读消息工作过程的讲解说明消息队列技术简单实用。基于MSMQ技术的Windows Mobile平台通信系统已经在国内某大型客车企业生产追踪系统中得到应用。

发布者:吕勇

Copyright © 2017-2020 微波EDA网 版权所有

网站地图

Top