使用脚本任务向远程私有消息队列发送消息

消息队列（又称为 MSMQ）使开发人员可以通过发送和接收消息，轻松实现与应用程序之间的快速可靠通信。 消息队列既可位于本地计算机，也可位于远程计算机；既可以是公共的，也可以是私有的。 在 Integration Services 中，MSMQ 连接管理器和消息队列任务不支持向远程计算机上的私有队列发送消息。 但通过使用脚本任务，可轻松地向远程私有队列发送消息。

说明

下面的示例使用一个现有 MSMQ 连接管理器以及 System.Messaging 命名空间的对象和方法，向远程私有消息队列发送包含在包变量中的文本。 对 MSMQ 连接管理器的 M：Microsoft.SqlServer.Dts.ManagedConnections.MSMQConn.AcquireConnection（System.Object） 方法的调用将返回一个 MessageQueue 对象，该方法 Send 完成此任务。

配置此脚本任务示例

1. 使用默认名称创建一个 MSMQ 连接管理器。 设置有效远程私有队列的路径，格式如下：

   FORMATNAME:DIRECT=OS:<computername>\private$\<queuename>  
   

2. 创建一个名为 MessageText 的 String Integration Services 变量，用于将消息文本传递到脚本中。 输入默认消息作为该变量的值。

3. 向设计图面添加一个脚本任务，并对其进行编辑。 在“脚本任务编辑器”的“脚本”选项卡中，将 MessageText 变量添加到 ReadOnlyVariables 属性中，使该变量在脚本内可用。

4. 单击“编辑脚本”，打开 Microsoft Visual Studio Tools for Applications (VSTA) 脚本编辑器。

5. 在脚本项目中添加对 System.Messaging 命名空间的引用。

6. 用下面部分中的代码替换脚本窗口中的内容。

代码

Imports System  
Imports Microsoft.SqlServer.Dts.Runtime  
Imports System.Messaging  
  
Public Class ScriptMain  
  
    Public Sub Main()  
  
        Dim remotePrivateQueue As MessageQueue  
        Dim messageText As String  
  
        remotePrivateQueue = _  
            DirectCast(Dts.Connections("Message Queue Connection Manager").AcquireConnection(Dts.Transaction), _  
            MessageQueue)  
        messageText = DirectCast(Dts.Variables("MessageText").Value, String)  
        remotePrivateQueue.Send(messageText)  
  
        Dts.TaskResult = ScriptResults.Success  
  
    End Sub  
  
End Class  

using System;  
using Microsoft.SqlServer.Dts.Runtime;  
using System.Messaging;  
  
public class ScriptMain  
{  
  
    public void Main()  
        {  
  
            MessageQueue remotePrivateQueue = new MessageQueue();  
            string messageText;  
  
            remotePrivateQueue = (MessageQueue)(Dts.Connections["Message Queue Connection Manager"].AcquireConnection(Dts.Transaction) as MessageQueue);  
            messageText = (string)(Dts.Variables["MessageText"].Value);  
            remotePrivateQueue.Send(messageText);  
  
            Dts.TaskResult = (int)ScriptResults.Success;  
  
        }  
  
}  

随时了解 Integration Services
有关来自Microsoft的最新下载、文章、示例和视频，以及来自社区的所选解决方案，请访问 MSDN 上的 Integration Services 页面：

访问 MSDN 上的 Integration Services 页

若要获得有关这些更新的自动通知，请订阅该页上提供的 RSS 源。

另请参阅

消息队列任务