IBM WebSphere MQ的C#工具类以及源码(net)
2024-10-18 00:30:34
简单的介绍一下MQ常用的对象
Queue Manager |
队列管理器 |
主要负责管理队列、通道等,类似与Oracle中的Oracle实例的概念,在一台服务器中可以定义多个Queue Manager。 |
Queue |
队列 |
是存放Message的对象,是我们主要操作的对象。类似与Oracle中的表的概念。 |
Message |
消息 |
实际放入Queue中的消息,该消息可以存储字符串、Stream等对象。 |
Channel |
通道 |
是我们的应用以及两个Queue Manager操作的链接对象 |
Process |
过程 |
Queue的分类:
Local Queue |
本地队列 |
主要存储消息的对象 |
Remote Queue |
远程队列 |
和另外一个Queue Manager通讯的队列 |
Mode Queue |
模板队列 |
建立一个队列模板,通过这个模板可以建立与模板相同属性的动态队列。 |
Dynamic Queue |
动态对了(临时队列) |
可以在程序中创建和删除的临时队列 |
MQ工具类:
using IBM.WMQ;
using IBM.WMQ.PCF;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
//using IBM.WMQAX; /// <summary>
/// MQHelp 类库
/// henrylee
/// </summary>
public class MQHelp
{
public MQHelp()
{ }
/// <summary>
/// 创建本地队列
/// </summary>
/// <param name="qmName">队列管理器</param>
/// <param name="queueName">队列名称</param>
/// <param name="isTransmissionQueue">是否为传输队列</param>
public void CreateQueue(string qmName, string queueName, bool isTransmissionQueue = false)
{
PCFMessageAgent agent = new PCFMessageAgent(qmName);
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_Q);
request.AddParameter(MQC.MQCA_Q_NAME, queueName);
request.AddParameter(MQC.MQIA_Q_TYPE, MQC.MQQT_LOCAL);
if (isTransmissionQueue) request.AddParameter(MQC.MQIA_USAGE, MQC.MQUS_TRANSMISSION);
PCFMessage[] response = agent.Send(request);
}
/// <summary>
/// 删除队列
/// </summary>
public void DelQueue(string qmName, string queueName)
{
PCFMessageAgent agent = new PCFMessageAgent(qmName);
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_DELETE_Q);
request.AddParameter(MQC.MQCA_Q_NAME, queueName);
PCFMessage[] response = agent.Send(request);
}
/// <summary>
/// 读取消息
/// </summary>
/// <returns></returns>
public string ReadMessage(string qmName, string queueName)
{
MQQueueManager qMgr = new MQQueueManager(qmName);
MQQueue queue = qMgr.AccessQueue(queueName, MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_FAIL_IF_QUIESCING);
MQGetMessageOptions gmo = new MQGetMessageOptions();
gmo.Options = MQC.MQGMO_WAIT;
gmo.WaitInterval = ;
gmo.MatchOptions = MQC.MQMO_NONE;
MQMessage message = new MQMessage();
queue.Get(message);
return message.ReadString(message.MessageLength);
}
/// <summary>
/// 写入消息
/// </summary>
public void WriteMessage(string qmName, string queueName, string body)
{
MQQueueManager qMgr = new MQQueueManager(qmName);
MQQueue queue = qMgr.AccessQueue(queueName, MQC.MQOO_OUTPUT);
MQMessage message = new MQMessage();
message.WriteString(body);
message.Format = MQC.MQFMT_STRING;
queue.Put(message);
}
/// <summary>
/// 获取当前管理器所有队列
/// </summary>
/// <param name="qmName">队列管理器</param>
/// <param name="isFindSystemQueue">是否包含系统队列</param>
/// <returns></returns>
public List<string> GetALLQueue(string qmName, bool isFindSystemQueue = false)
{
PCFMessageAgent agent = new PCFMessageAgent(qmName);
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_INQUIRE_Q_NAMES);
request.AddParameter(MQC.MQCA_Q_NAME, "*");
PCFMessage[] response = agent.Send(request);
string[] names = response[].GetStringListParameterValue(CMQCFC.MQCACF_Q_NAMES);
List<string> result = null;
if (!isFindSystemQueue)
result = names.ToList().Where(s => !s.Contains("AMQ.") && !s.Contains("SYSTEM.")).ToList();
else
result = names.ToList();
return result;
}
/// <summary>
/// 创建远程队列
/// </summary>
/// <param name="qmName">队列管理器</param>
/// <param name="queueName">队列名称</param>
/// <param name="ycqmName">远程队列管理器名称</param>
/// <param name="ycqueueName">远程队列名称</param>
/// <param name="csqueueName">传输队列名称</param>
public void CreateRemoteQueue(string qmName, string queueName, string ycqmName, string ycqueueName, string csqueueName)
{
PCFMessageAgent agent = new PCFMessageAgent(qmName);
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_Q);
request.AddParameter(MQC.MQCA_Q_NAME, queueName);
request.AddParameter(MQC.MQIA_Q_TYPE, MQC.MQQT_REMOTE);
request.AddParameter(MQC.MQCA_REMOTE_Q_MGR_NAME, ycqmName);
request.AddParameter(MQC.MQCA_REMOTE_Q_NAME, ycqueueName);
request.AddParameter(MQC.MQCA_XMIT_Q_NAME, csqueueName);
PCFMessage[] response = agent.Send(request);
agent.Disconnect();
}
/// <summary>
/// 创建发送方通道
/// </summary>
/// <param name="qmName">队列管理器</param>
/// <param name="channelName">通道名称</param>
/// <param name="transmissionQueueName">传输队列名称</param>
/// <param name="iPPort">IP地址与端口号 例:localhost(1415) </param>
public void CreateChannelBySend(string qmName, string channelName, string transmissionQueueName, string iPPort)
{
PCFMessageAgent agent = new PCFMessageAgent(qmName);
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_CHANNEL);
request.AddParameter(CMQCFC.MQCACH_CHANNEL_NAME, channelName); request.AddParameter(CMQCFC.MQIACH_CHANNEL_TYPE, MQC.MQCHT_SENDER);
request.AddParameter(CMQCFC.MQCACH_CONNECTION_NAME, iPPort);
request.AddParameter(CMQCFC.MQCACH_XMIT_Q_NAME, transmissionQueueName); PCFMessage[] response = agent.Send(request);
agent.Disconnect();
}
/// <summary>
/// 创建接受方通道
/// </summary>
/// <param name="qmName">队列管理器</param>
/// <param name="channelName">管道名称</param>
public void CreateChannelByReceive(string qmName, string channelName)
{
PCFMessageAgent agent = new PCFMessageAgent(qmName);
PCFMessage request = new PCFMessage(CMQCFC.MQCMD_CREATE_CHANNEL);
request.AddParameter(CMQCFC.MQCACH_CHANNEL_NAME, channelName); request.AddParameter(CMQCFC.MQIACH_CHANNEL_TYPE, MQC.MQCHT_RECEIVER); PCFMessage[] response = agent.Send(request);
agent.Disconnect();
}
}
以下是前台调用:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls; public partial class _Default : System.Web.UI.Page
{
public const string MQNAME1 = "ManageTest1";
public const string MQNAME2 = "ManageTest2";
public readonly MQHelp MQHELP = new MQHelp();
protected void Page_Load(object sender, EventArgs e)
{
if (!IsPostBack)
{
List<string> list = new MQHelp().GetALLQueue(MQNAME1);
list.ForEach(s => ddlQueueList.Items.Add(new ListItem(s)));
}
}
protected void Button1_Click(object sender, EventArgs e)
{
Button but = sender as Button;
switch (but.Text)
{
case "添加队列":
MQHELP.CreateQueue(MQNAME1, txtQueue.Text.Trim());
break;
case "删除队列":
MQHELP.DelQueue(MQNAME1, txtQueue.Text.Trim());
break;
case "添加消息":
MQHELP.WriteMessage(MQNAME1, ddlQueueList.SelectedValue, txtMessage.Text.Trim());
break;
case "获取消息":
Literal1.Text = MQHELP.ReadMessage(MQNAME1, ddlQueueList.SelectedValue);
break;
case "添加传输队列":
MQHELP.CreateQueue(txtTMName.Text, txtTName.Text.Trim(), true);
break;
case "删除传输队列":
MQHELP.DelQueue(txtTMName.Text, txtTName.Text.Trim());
break;
case "添加远程队列":
MQHELP.CreateRemoteQueue(txtRMName.Text, txtRQName.Text, txtRMTName.Text, txtRMTQName.Text, txtRTQName.Text);
break;
case "添加发送方通道":
MQHELP.CreateChannelBySend(txtCMName.Text, txtCCName.Text, txtCTName.Text, txtCip.Text);
break;
case "添加接收方通道":
MQHELP.CreateChannelByReceive(txtCMName.Text, txtCCName.Text);
break;
default:
break;
}
}
}
最新文章
- MongoDB 由于目标计算机积极拒绝,无法连接 2014-07-25T11:00:48.634+0800 warning: Failed to connect to 127.0.0.1:27017, reason: errno:10061
- Linux流量监控工具 - iftop
- [驱动开发] struct _LDR_DATA_TABLE_ENTRY
- Android之Inflate()
- HTML5初学篇章_3
- No plugin found for prefix &#39;jetty&#39; in the current project and in the plugin groups 【转】
- 石子合并 区间DP (经典)
- python 之 range()
- iOS10推送必看UNNotificationServiceExtension
- myeclipse如何导入相应的jar包
- eval 如何定义函数
- QT更改程序图标
- Dedecms自定义sql 出现错误Safe Alert: Request Error step 2!
- UpdatePanel局部刷新用法
- 【定位:PDF文件定位关键字所在坐标和页码】
- 更多文章请关注公众号:FullStackPlan 或前往个人主页:www.linbingdong.com
- js函数中的BOM和DOM
- 51Nod 1080 两个数的平方和(数论,经典题)
- C# Aspose.Cells方式导入Excel文件
- webpack详细配置解析
热门文章
- 虚拟化之KVM virsh常用命令篇
- sql 函数 总结
- B - Numbers That Count
- 表单验证的validate.js插件---jQuery Validation Plugin
- sublime远程连接到linux主机
- python运维开发(十三)----SQLalchemy和paramiko续
- 经典面试题(二)附答案 算法+数据结构+代码 微软Microsoft、谷歌Google、百度、腾讯
- java学习:AWT组件和事件处理的笔记(1)--文本框上的ActionEvent事件
- SQL Server 找出值得优化的语句
- Oracle EBS-SQL (PO-14):检查报价单与成本对比.sql