如何在SQL Server sp上的Websphere MQ Queue上放置消息？

Question

是否有API从SQL Server存储过程连接到Websphere MQ队列并将消息放入队列？

如果不是，最好的方法是什么？

Answer 1

有一个比这更简单的解决方案..检查了这一点。

http://publib.boulder.ibm.com/infocenter/wmbhelp/v7r0m0/index.jsp?topic=%2Fcom.ibm.etools.mft.doc%2Fbc34040_.htm

Answer 2

我能想到的最简单的方法是，将信息写入文件，然后使用rfhutil将消息导出到队列中。这需要人工干预。另一种选择是使用JMS和JDBC编写简单的Java应用程序。

Answer 3

我打算使用的解决方案是编写CLR存储过程并将其部署到SQL Server上。

在CLR存储过程中，我将使用MQ .NET API。

更新：我创建了一个存储过程使用下面的代码：

using System; 
using System.Data; 
using System.Data.SqlClient; 
using System.Data.SqlTypes; 
using Microsoft.SqlServer.Server; 
using IBM.WMQ; 

public partial class StoredProcedures 
{ 
    [Microsoft.SqlServer.Server.SqlProcedure] 
    public static int MQStoredProc(String queueManager, String queueName, String messageText) 
    { 
     //MQEnvironment.Hostname = "localhost"; 
     //MQEnvironment.Port = 1414; 
     //MQEnvironment.Channel = "SYSTEM.DEF.SVRCONN"; 

     MQQueueManager mqQMgr = null;   // MQQueueManager instance 
     MQQueue mqQueue = null;   // MQQueue instance 

     try 
     { 
      mqQMgr = new MQQueueManager(queueManager); 
      mqQueue = mqQMgr.AccessQueue(queueName, MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING); // open queue for output but not if MQM stopping 

      if (messageText.Length > 0) 
      { 
       // put the next message to the queue 
       MQMessage mqMsg = new MQMessage(); 
       mqMsg.WriteString(messageText); 
       mqMsg.Format = MQC.MQFMT_STRING; 
       MQPutMessageOptions mqPutMsgOpts = new MQPutMessageOptions(); 
       mqQueue.Put(mqMsg, mqPutMsgOpts); 
      } 

      return 0; 
     } 
     catch (MQException mqe) 
     { 
      return ((int)mqe.Reason);   
     } 
     finally 
     { 
      if (mqQueue != null) 
       mqQueue.Close(); 
      if (mqQMgr != null) 
       mqQMgr.Disconnect(); 
     } 
    } 
}; 

这不是生产做好准备，但成功地将在队列管理器在同一台服务器中绑定的SQL服务器上运行的消息模式。

Answer 4

.NET CLR方法也是我的建议。我很想看到代码的一个例子，我从来没有尝试过！我应该工作。