TOMMYHU

下载文件 (已下载 2 次)

戳这里下载文件: MSMQTest.rar

利用 MSMQ（Microsoft Message Queue），应用程序开发人员可以通过发送和接收消息方便地与应用程序进行快速可靠的通信。消息处理为您提供了有保障的消息传递和执行许多业务处理的可靠的防故障方法。

MSMQ与XML Web Services和.Net Remoting一样，是一种分布式开发技术。但是在使用XML Web Services或.Net Remoting组件时，Client端需要和Server端实时交换信息，Server需要保持联机。MSMQ则可以在Server离线的情况下工作，将Message临时保存在Client端的消息队列中，以后联机时再发送到Server端处理。

显然，MSMQ不适合于Client需要Server端及时响应的这种情况，MSMQ以异步的方式和Server端交互，不用担心等待Server端的长时间处理过程。

虽然XML Web Services和.Net Remoting都提供了[OneWay]属性来处理异步调用，用来解决Server端长方法调用长时间阻碍Client端。但是不能解决大量Client负载的问题，此时Server接受的请求快于处理请求。

一般情况下，[OneWay]属性不用于专门的消息服务中。

1. 基本术语和概念（Basic terms and concepts）

“消息”是在两台计算机间传送的数据单位。消息可以非常简单，例如只包含文本字符串；也可以更复杂，可能包含嵌入对象。

消息被发送到队列中。“消息队列”是在消息的传输过程中保存消息的容器。消息队列管理器在将消息从它的源中继到它的目标时充当中间人。队列的主要目的是提供路由并保证消息的传递；如果发送消息时接收者不可用，消息队列会保留消息，直到可以成功地传递它。

“消息队列”是 Microsoft 的消息处理技术，它在任何安装了 Microsoft Windows 的计算机组合中，为任何应用程序提供消息处理和消息队列功能，无论这些计算机是否在同一个网络上或者是否同时联机。

“消息队列网络”是能够相互间来回发送消息的任何一组计算机。网络中的不同计算机在确保消息顺利处理的过程中扮演不同的角色。它们中有些提供路由信息以确定如何发送消息，有些保存整个网络的重要信息，而有些只是发送和接收消息。

“消息队列”安装期间，管理员确定哪些服务器可以互相通信，并设置特定服务器的特殊角色。构成此“消息队列”网络的计算机称为“站点”，它们之间通过“站点链接”相互连接。每个站点链接都有一个关联的“开销”，它由管理员确定，指示了经过此站点链接传递消息的频率。

“消息队列”管理员还在网络中设置一台或多台作为“路由服务器”的计算机。路由服务器查看各站点链接的开销，确定经过多个站点传递消息的最快和最有效的方法，以此决定如何传递消息。

2. 队列类型（Queue Type）

有两种主要的队列类型：由您或网络中的其他用户创建的队列和系统队列。

用户创建的队列可能是以下任何一种队列：

“公共队列”在整个“消息队列”网络中复制，并且有可能由网络连接的所有站点访问。

“专用队列”不在整个网络中发布。相反，它们仅在所驻留的本地计算机上可用。专用队列只能由知道队列的完整路径名或标签的应用程序访问。

“管理队列”包含确认在给定“消息队列”网络中发送的消息回执的消息。指定希望 MessageQueue 组件使用的管理队列（如果有的话）。

“响应队列”包含目标应用程序接收到消息时返回给发送应用程序的响应消息。指定希望 MessageQueue 组件使用的响应队列（如果有的话）。

系统生成的队列一般分为以下几类：

“日记队列”可选地存储发送消息的副本和从队列中移除的消息副本。每个“消息队列”客户端上的单个日记队列存储从该计算机发送的消息副本。在服务器上为每个队列创建了一个单独的日记队列。此日记跟踪从该队列中移除的消息。

“死信队列”存储无法传递或已过期的消息的副本。如果过期或无法传递的消息是事务性消息，则被存储在一种特殊的死信队列中，称为“事务性死信队列”。死信存储在过期消息所在的计算机上。有关超时期限和过期消息的更多信息，请参见默认消息属性。

“报告队列”包含指示消息到达目标所经过的路由的消息，还可以包含测试消息。每台计算机上只能有一个报告队列。

“专用系统队列”是一系列存储系统执行消息处理操作所需的管理和通知消息的专用队列。

在应用程序中进行的大多数工作都涉及访问公共队列及其消息。但是，根据应用程序的日记记录、确认和其他特殊处理需要，在日常操作中很可能要使用几种不同的系统队列。

3. 同步和异步通信（Synchronous VS. Asynchronous Communication）

队列通信天生就是异步的，因为将消息发送到队列和从队列中接收消息是在不同的进程中完成的。另外，可以异步执行接收操作，因为要接收消息的人可以对任何给定的队列调用BeginReceive 方法，然后立即继续其他任务而不用等待答复。这与人们所了解的“同步通信”截然不同。

在同步通信中，请求的发送方在执行其他任务前，必须等待来自预定接收方的响应。发送方等待的时间完全取决于接收方处理请求和发送响应所用的时间。

4. 同消息队列交互（Interacting with Message Queues）

消息处理和消息为基于服务器的应用程序组件之间的进程间通信提供了强大灵活的机制。同组件间的直接调用相比，它们具有若干优点，其中包括：

    
• 稳定性 — 组件失败对消息的影响程度远远小于组件间的直接调用，因为消息存储在队列中并一直留在那里，直到被适当地处理。消息处理同事务处理相似，因为消息处理是有保证的。
    
• 消息优先级 — 更紧急或更重要的消息可在相对不重要的消息之前接收，因此可以为关键的应用程序保证足够的响应时间。
    
• 脱机能力 — 发送消息时，它们可被发送到临时队列中并一直留在那里，直到被成功地传递。当因任何原因对所需队列的访问不可用时，用户可以继续执行操作。同时，其他操作可以继续进行，如同消息已经得到了处理一样，这是因为网络连接恢复时消息传递是有保证的。
    
• 事务性消息处理 — 将多个相关消息耦合为单个事务，确保消息按顺序传递、只传递一次并且可以从它们的目标队列中被成功地检索。如果出现任何错误，将取消整个事务。
    
• 安全性 — MessageQueue 组件基于的消息队列技术使用 Windows 安全来保护访问控制，提供审核，并对组件发送和接收的消息进行加密和验证。

5. 在.Net环境下编写简单的Message Queue程序

（1）先安装Message Queuing Services

通过Control Panel，“Add/Remove Programs” – “Add/Remove Windows Components”步骤安装MSMQ。

MSMQ可以安装为工作组模式或域模式。如果安装程序没有找到一台运行提供目录服务的消息队列的服务器，则只可以安装为工作组模式，此计算机上的“消息队列”只支持创建专用队列和创建与其他运行“消息队列”的计算机的直接连接。

（2）配置MSMQ

打开Computer Management – Message Queuing，在Private Queues下创建MSMQDemo队列

（3）编写代码－简单演示MSMQ对象

MessageQueue 类是“消息队列”周围的包装。MessageQueue 类提供对“消息队列”队列的引用。可以在 MessageQueue 构造函数中指定一个连接到现有资源的路径，或者可在服务器上创建新队列。在调用 Send、Peek 或 Receive 之前，必须将 MessageQueue 类的新实例与某个现有队列关联。

MessageQueue 支持两种类型的消息检索：同步和异步。同步的 Peek 和 Receive 方法使进程线程用指定的间隔时间等待新消息到达队列。异步的 BeginPeek 和BeginReceive 方法允许主应用程序任务在消息到达队列之前，在单独的线程中继续执行。这些方法通过使用回调对象和状态对象进行工作，以便在线程之间进行信息通讯。

// Send Message

private void btnSendMessage_Click(object sender, System.EventArgs e)

{

       // Open queue

       System.Messaging.MessageQueue queue = new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");

       // Create message

       System.Messaging.Message message = new System.Messaging.Message();

       message.Body = txtMessage.Text.Trim();

       message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] {typeof(string)});

       // Put message into queue

       queue.Send(message);

}

// Receive Message

private void btnReceiveMessage_Click(object sender, System.EventArgs e)

{

       // Open queue

       System.Messaging.MessageQueue queue = new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");

       // Receive message, 同步的Receive方法阻塞当前执行线程，直到一个message可以得到

       System.Messaging.Message message = queue.Receive();

       message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] {typeof(string)});

       txtReceiveMessage.Text = message.Body.ToString();

}

Demo界面：

******

关于MSMQ消息队列介绍文字来自于MSDN.

References:

1, MSDN, 消息队列（Message Queue）

阅读全文

 一、数据集基本应用

1.表格新增记录

方式一：利用BindingSource的AddNew

//新增记录，推荐使用，光标位置处于当前新增记录，且正处理编辑状态
DataRow thisRow = ((DataRowView)usersBindingSource.AddNew()).Row;
thisRow["OID"] = 5;
thisRow["CNAME"] = "新增用户";
thisRow["sex"] = "m";

方式二：利用DataTable的NewRow

//新增记录(不建议使用，因为这种方式Rows.Add时并不处于编辑状态时会受约束影响，且新增时光标不会自动移动该条记录) 
DataRow thisRow = userDataSet.Tables["Users"].NewRow();
thisRow["OID"] = 5;
thisRow["CNAME"] = "新增用户";
thisRow["sex"] = "m";
userDataSet.Tables["Users"].Rows.Add(thisRow);

2.表格删除记录

方式一：利用BindingSource的RemoveCurrent 

if (usersBindingSource.Current != null)
   //删除当前记录，推荐使用
   usersBindingSource.RemoveCurrent();

方式二：利用DataRowCollection的Remove 

//删除当前记录,不推荐使用，这种方式不会记录到RowState中，保存时不会更新
DataRow thisRow = getCurrentDataRow(usersBindingSource);
if (thisRow != null)
   userDataSet.Tables["Users"].Rows.Remove(thisRow);

方式三：利用DataRow的Delete 

//删除当前记录,不推荐使用，BindingSource可以更简洁
DataRow thisRow = getCurrentDataRow(usersBindingSource);
if (thisRow != null)
   thisRow.Delete();

3.表格修改记录

方式一：利用DataRowObject[列名]直接修改 

DataRow thisRow = getCurrentDataRow(usersBindingSource);

if (thisRow != null)
{
   thisRow.BeginEdit();
   thisRow["CNAME"] = "修改的名称";
   thisRow.EndEdit();
}

4.表格查找和筛选记录

方式一：利用DataRowCollection.find查找 

DataColumn[] keys = new DataColumn[1];
keys[0] = userDataSet.Tables["Users"].Columns["OID"];
userDataSet.Tables["Users"].PrimaryKey = keys;
DataRow findRow = userDataSet.Tables["Users"].Rows.Find("1");

if (findRow == null)
{
   MessageBox.Show("没有找到");
}
else
{
   MessageBox.Show("成功找到,CNAME = " + findRow["CNAME"]);
} 

方式二：利用BindingSource.find查找 

int i = usersBindingSource.Find("OID", "1");

if (i >= 0)
   MessageBox.Show("成功找到,CNAME = " +
   userDataSet.Tables["users"].Rows[i]["CNAME"]);

方式三：利用DataTable.Select获得DataRow数组 

DataRow[] AryDr = userDataSet.Tables["users"].Select("OID > 1");

for (int i = 0; i < AryDr.Length; i++)
{
    DataRow dr = AryDr[i];
    MessageBox.Show(Convert.ToString((int)dr["OID"]));
}

5．表格记录的移动

方式一：采用BindingSource的方法或position属性实现。 

//指定定位到哪一行,Position不会随表格列排序而变化，0不一定就是表格的第一行

usersBindingSource.Position = 0;

//移动到上一条,对于表格列排序后，上一条不定是界面显示表格的上一条

usersBindingSource.MovePrevious();

usersBindingSource.MoveNext();//移动到下一条

usersBindingSource.MoveFirst();

usersBindingSource.MoveLast();

6．表格的过滤

方式一：利用BindingSource的Filter来实现 

usersBindingSource.Filter = "OID > 1";

7．数据集清空

方式一：利用DataTable.Clear()，注意这种不会保留删除状态，保存时不会真正删除 

userDataSet.Tables["users"].Clear();

方式二：利用DataTable.Rows.Clear删除，注意这种不会保留删除状态，保存时不会真正删除 

userDataSet.Tables["users"].Rows.Clear();

方式三：利用BindingSource.RemoveCurrent循环删除全部记录，这种就会保留删除状态。 

while (usersBindingSource.Current != null)
      usersBindingSource.RemoveCurrent();

8．数据集数据和结构的复制

方式一：整个数据集的复制 

DataSet copyDS = userDataSet.Copy();

方式二：只复制单个表 

DataSet copyDS = new DataSet();
copyDS.Tables.Add(userDataSet.Tables["users"].Copy());

方式三：只复制数据集的结构 

copyDS = userDataSet.Clone();
MessageBox.Show(copyDS.Tables["users"].Rows.Count.ToString());

9．获取脏数据

方式一：整个数据集的脏数据 

copyDS = userDataSet.GetChanges();

方式二：获取单个表的脏数据 

DataTable dt = userDataSet.Tables["users"].GetChanges();

10．数据集的数据合并

方式一：整个数据集的DataSet.Merge合并 

ds.Merge(userDataSet);

方式二：单个表的DataTable.Merge合并 

ds.Merge(userDataSet.Tables["users"]);

11．数据集的数据回滚

方式一：数据集的数据回滚 

userDataSet.RejectChanges();

方式二：数据表的数据回滚 

userDataSet.Tables["users"].RejectChanges();

方式三：数据行的数据回滚 

DataRow dr = getCurrentDataRow(usersBindingSource);

if (dr != null)
   dr.RejectChanges();

12．数据集从数据库取数

方式一：利用SqlDataAdapter.Fill来填充数据表 

this.usersTableAdapter.Fill(this.userDataSet.Users);

13．数据集更新到数据库

方式一：利用SqlDataAdapter.Update来更新到数据库 

this.Validate();
this.usersBindingSource.EndEdit();

if (this.userDataSet.HasChanges())
{
   this.usersTableAdapter.Update(this.userDataSet.Users);
   MessageBox.Show("保存成功!");
}

14．判断数据集变更 

方式一：利用DataSet.HasChanges()

15获取数据集表列集合

方式一：利用DataTable.Columns 

DataColumnCollection dcc = userDataSet.Tables["users"].Columns;

for (int i = 0; i < dcc.Count; i++)
{
    DataColumn dc = dcc[i];
    MessageBox.Show(dc.ColumnName);
}

16获取属于该表的行的集合

方式一：利用DataTable.Rows 

DataRowCollection drc = userDataSet.Tables["users"].Rows;

for (int i = 0; i < drc.Count; i++)
{
    DataRow dr = drc[i];
    MessageBox.Show((string)dr["CNAME"]);
}

阅读全文

 工作流引擎是一个为工作流实例执行提供运行服务环境的软件，是工作流管
理系统的核心组件。工作流引擎负责解析、解释工作流过程定义、控制过程实例、
决定活动的执行次序、向用户工作表中添加工作项、调用应用程序、与其他工作
流引擎交互等功能。工作流引擎的作用不言而喻，就如计算机对于软件的作用
一样，可以说没有它，就没有工作流的一切，再好的流程设计也是无法有效执行
的，所以说它是工作流管理系统的核心组件。
工作流引擎的主要功能是： 
1)实例化及执行过程定义：解释企业经营过程的过程定义，根据过程执行
需要的初始条件和执行参数生成过程实例，运行过程实例并管理其运行过程。过
程模型作为企业经营过程的一个模板，可以被执行多次，也可以有多个有关这个
过程模型的实例在同时运行。
2)为过程和活动的执行进行导航：根据过程定义和工作流相关数据，为过
程实例的运行进行导航。如根据过程的进入和退出的条件启动和终止一个过程实
例；根据活动之间的关联和活动的执行条件，决定并行或串行执行后续活动；给
用户提供需要操作的工作流任务项信息；或者根据所需激活的应用程序信息启动
相应的应用程序等等。
3)与外部资源交互完成各项活动：客户应用接口和直接调用应用接口方式。
对于客户应用方式，工作流引擎通过任务项列表管理器对应用的执行进行管理。
任务项列表管理器提供任务项列表供用户进行选择，并记录监督工作项的完成情
况，由用户完成从任务项列表管理器提供的任务项列表中选择相应的任务项，并
在需要的时候调用应用工具完成相应任务的执行，在任务执行完成后，用户需要
修改相关任务项的状态，如置完成标志，供任务项列表管理器使用。对于直接由
工作流引擎启动的活动，由工作流机直接调用相应的应用来完成，这些自动执行
的应用同样需要将合适的预先定义好的应用执行完成情况反馈给工作流机。
4)维护工作流控制数据和工作流相关数据：工作流在执行过程中要维护不
同过程和活动实例的内部状态信息，以及用于协调和恢复的各种检查数据和恢复
／重起信息，还包括用户传送的必要的相关数据。

阅读全文

解释 XQuery 的最佳方式是：XQuery 相对于 XML，等同于 SQL 相对于数据库。

XQuery 被设计用来查询 XML 数据。

 ◆简介

　　XQuery = XML Query，是W3C所制定的一套标准，用来从类XML文档中提取信息，类XML文档可以理解成一切符合XML数据模型和接口的实体，他们可能是文件或RDBMS。

XQuery有如下特点：

开始学习》》http://www.w3school.com.cn/xquery/

阅读全文