本文介绍发布/订阅（Publish/Subscribe）技术在 WebSphere MQ V7 中实现的原理及方法。WebSphere MQ V7 在 MQ V6 的基础上做了很大改动。MQ V7 不仅增强了发布/订阅功能，提供了一种新的发布/订阅引擎并整合在队列管理器中，还扩展了 MQ API 接口。在 WebSphere MQ V7 中，可以使用 MQ Explorer 对发布/订阅进行图形化的使用和管理。
发布/订阅技术概述
发布/订阅是一种异步消息传输机制，它定义了应用程序模型，把消息的发布者（Publisher）与消息的订阅者（Subscriber）以一种松耦合的方式联系在一起，它们不需要知道对方的任何信息，甚至不需要知道对方是否存在，就可以实现消息的异步传递。发布者和订阅者之间通过主题（Topic）交换信息：发布者把信息发布到主题字符串（Topic String），订阅者在主题上注册并接收信息，通过这种方式主题字符串把发布者和订阅者连接起来。
下面介绍一个发布/订阅的具体实例。图 1 是 IBM Redbooks RSS 网站。网站（发布者）定期在每类技术专题（主题）发布最新的 Redbooks 信息，用户（订阅者）在自己感兴趣的技术专题订阅，当该技术专题有最新的 Redbooks 信息到达时，用户便会接收到。网站不需要知道哪些用户定订阅了哪些技术专题，它们需要做的只是在各类技术专题发布 Redbooks 信息。用户关心的只是 Redbooks 信息，它们不需要知道是谁发布的，它与网站之间是松耦合关系，这就构成了一个典型的发布/订阅系统。
主题（Topic）和订阅（Subscription）是发布/订阅中重要的对象，MQ V7 把它们作为新增加的对象并整合到队列管理器中。本文将从主题和订阅展开讲解，详细讲述它们在 MQ V7 中的定义和属性以及 MQ V7 是如何通过主题和订阅对发布/订阅进行管理。接下来本文将通过复杂的 MQ V7 发布/订阅环境讲解分布式发布/订阅技术，这部分内容是 MQ V7 发布/订阅技术中的高级部分，以使读者对 MQ V7 发布/订阅技术有更深入的了解。
MQ V7 把发布/订阅消息机制整合到队列管理器中，这样做很容易对发布/订阅进行管理、配置等操作。可以通过 MQSC 脚本在命令行管理配置主题和订阅，也可以通过 MQ Explorer 图形化的方式管理配置主题和订阅。
WebSphere MQ V7 把主题作为一种新的对象类型定义在队列管理器中。主题字符串是主题 对象的属性，它是连接发布者和订阅者之间的“纽带”。
在 MQ V7 队列管理器内部，主题是以主题树的继承形式展现的。图 2 是一棵主题树，在 主题树的最顶端是树的根节点 SYSTEM.BASE.TOPIC，其他的节点可以分成两类：一类是管理节点，一类是非管理节点。
管理节点：在主题树节点中，定义了主题对象的节点被称为是管理节点，它们是主题树中永久部分，不会因为队列管理器重启被系统删除掉。管理节点允许在其上定义该节点的属性，非管理节点可以继承该属性。图2 中 主题 FIFA 所在的节点是管理节点，因为在该节点上定义了主题对象 FOOTBALL 并定义了主题字符串 FIFA。
非管理节点：主题字符串并不用预先定义，应用程序在发布或订阅一个不存在的主题字符串时，该主题字符串会自动生成，它在主题树中以非管理节点存在，非管理节点的所有属都性继承在它以上的第一个管理节点的属性。在图 2 中主题字符串 FIFA/EURO 不是预先定义的，它在主题树中以非管理节点形式存在，它继承 FIFA 所在管理节点的所有属性。
对于管理节点，需要预先定义主题对象，在 MQ V7 中，可以通过 MQSC 或 MQ Explorer 定义主题对象。清单 1 中使用 MQSC 脚本命令定义一个主题，主题名字是 WEST, 主题字符串是 NBA/LAKER。
DEFINE TOPIC(WEST) TOPICSTR(NBA/LAKER) DESCR('This is a TOPIC') PUB(ASPARENT) SUB(
ENABLED) + WILDCARD(PASSTHRU)
1 : DEFINE TOPIC (WEST) TOPICSTR(NBA/LAKER) DESCR('This is a TOPIC') PUB(
ASPARENT) SUB(ENABLED) WILDCARD(PASSTHRU)
AMQ8690: WebSphere MQ TOPIC created.
PUB：是否允许发布者在这个主题上发布消息，它有三个选项：ENABLED 允许，DISABLED 禁止，ASPARENT 继承父节点。在图 3 中，由于 WEST 所在的节点 PUB 属性是 ASPARENT，并且它的父节点不是管理节点，所以 WEST 所在的节点继承了根结点 SYSTEM.BASE.TOPIC 的属性。
SUB：是否允许订阅者在这个主题上订阅操作。它有三个选项：ENABLED 允许，DISABLED 禁止，ASPARENT 继承父节点。
WILDCARD：通配符。它有两个选项:PASSTHRU 和 BLOCK。举例说明它们的含义：在图 3 中，若一个订阅者订阅主题字符串“#”，这会导致在主题树中所有主题上的发布内容被发送到订阅者。如不希望在 FIFA 以下的节点接收到发布内容，可以按照清单 2 上的命令修改 WILDCARD 属性为 BLOCK。WILDCARD 的默认属性值为 PASSTHRU，没有 ASPARENT 属性。
ALTER TOPIC(FOOTBALL) WILDCARD(BLOCK) 4 : ALTER TOPIC(FOOTBALL) WILDCARD(BLOCK) AMQ8691: WebSphere MQ TOPIC changed.
清单 3 显示已经定义的主题 FOOTBALL 的信息。
清单 3. 显示主题信息
DISPLAY TOPIC(FOOTBALL) 5 : DISPLAY TOPIC(FOOTBALL) AMQ8633: Display TOPIC details. TOPIC(FOOTBALL) TYPE(LOCAL) TOPICSTR(FIFA) DESCR( ) CLUSTER( ) DURSUB(ASPARENT) PUB(ASPARENT) SUB(ASPARENT) DEFPSIST(ASPARENT) DEFPRTY(ASPARENT) DEFPRESP(ASPARENT) ALTDATE() ALTTIME(01.57.11) PMSGDLV(ASPARENT) NPMSGDLV(ASPARENT) PUBSCOPE(ASPARENT) SUBSCOPE(ASPARENT) PROXYSUB(FIRSTUSE) WILDCARD(BLOCK) MDURMDL( ) MNDURMDL( )
清单 4 使用 DISPLAY TOPIC(*) MQSC 命令显示队列管理器中所有主题的定义，并用Where 语句根据主题字符串的值等于 (EQ) FIFA 对主题过滤,得到符合特定属性值的主题。
清单 4. 用 WHERE 语句匹配显示主题信息
DISPLAY TOPIC(*) WHERE(TOPICSTR EQ FIFA) 6 : DISPLAY TOPIC(*) WHERE(TOPICSTR EQ FIFA) AMQ8633: Display TOPIC details. TOPIC(FOOTBALL) TYPE(LOCAL) TOPICSTR(FIFA)
清单 5 显示主题字符串 FIFA 所在节点的状态：DISPLAY TPSTATUS(Topic-String)。从返回值中可以看到主题字符串“FIFA”的主题名字是 FOOTBALL，这个节点是 ADMIN 及管理节点。
清单 5. 显示主题字符串所在节点的状态
DIS TPSTATUS(FIFA) 11 : DIS TPSTATUS(FIFA) AMQ8754: Display Topic status details. TOPICSTR(FIFA) ADMIN(FOOTBALL) MDURMDL(SYSTEM.DURABLE.MODEL.QUEUE) MNDURMDL(SYSTEM.NDURABLE.MODEL.QUEUE) DEFPSIST(NO) DEFPRTY(0) DEFPRESP(SYNC) DURSUB(YES) PUB(ENABLED) SUB(ENABLED) PMSGDLV(ALLDUR) NPMSGDLV(ALLAVAIL) RETAINED(NO) PUBCOUNT(0) SUBCOUNT(0) PUBSCOPE(ALL) SUBSCOPE(ALL)
清单 6 使用 DISPLAY TPSTATUS（FIFA/+）返回 FOOTBALL 节点的下一级所有节点的状态，因为该节点是非管理节点，所以 ADMIN 参数是空。
清单 6. 使用“+”返回主题节点下一级所有节点的状态
DIS TPSTATUS(FIFA/+) 2 : DIS TPSTATUS(FIFA/+) AMQ8754: Display Topic status details. TOPICSTR(FIFA/EURO) ADMIN( ) MDURMDL(SYSTEM.DURABLE.MODEL.QUEUE) MNDURMDL(SYSTEM.NDURABLE.MODEL.QUEUE) DEFPSIST(NO) DEFPRTY(0) DEFPRESP(SYNC) DURSUB(YES) PUB(ENABLED) SUB(ENABLED) PMSGDLV(ALLDUR) NPMSGDLV(ALLAVAIL) RETAINED(NO) PUBCOUNT(0) SUBCOUNT(1) PUBSCOPE(ALL) SUBSCOPE(ALL)
清单 7 使用 DISPLAY TPSTATUS(FIFA/#) 命令不仅返回了 FOOTBALL 节点本身的状态，还返回了 FOOTBALL 以下所有节点的状态。
清单 7. 在 DISPLAY TPSTATUS 命令中使用“#”
DIS TPSTATUS('FIFA/#')
12 : DIS TPSTATUS('FIFA/#')
AMQ8754: Display Topic status details.
TOPICSTR(FIFA/EURO/ESP) ADMIN( )
MDURMDL(SYSTEM.DURABLE.MODEL.QUEUE)
MNDURMDL(SYSTEM.NDURABLE.MODEL.QUEUE)
DEFPSIST(NO) DEFPRTY(0)
DEFPRESP(SYNC) DURSUB(YES)
PUB(ENABLED) SUB(ENABLED)
AMQ8754: Display Topic status details.
TOPICSTR(FIFA) ADMIN(FOOTBALL)
MDURMDL(SYSTEM.DURABLE.MODEL.QUEUE)
MNDURMDL(SYSTEM.NDURABLE.MODEL.QUEUE)
DEFPSIST(NO) DEFPRTY(0)
DEFPRESP(SYNC) DURSUB(YES)
PUB(ENABLED) SUB(ENABLED)
PMSGDLV(ALLDUR) NPMSGDLV(ALLAVAIL)
SUBSCOPE(ALL)
AMQ8754: Display Topic status details.
TOPICSTR(FIFA/EURO) ADMIN( )
MDURMDL(SYSTEM.DURABLE.MODEL.QUEUE)
MNDURMDL(SYSTEM.NDURABLE.MODEL.QUEUE)
DEFPSIST(NO) DEFPRTY(0)
DEFPRESP(SYNC) DURSUB(YES)
PUB(ENABLED) SUB(ENABLED)
PMSGDLV(ALLDUR) NPMSGDLV(ALLAVAIL)
SUBSCOPE(ALL)
值得注意的是，DISPLAY TPSTATUS 命令不支持“*”，但是可以在 WHERE 语句中使用“*”作为过滤条件。清单 8 中命令返回以 FIFA/EURO/E 开头节点的状态。
清单 8. WHERE 语句中使用“*”作为过滤条件
DISPLAY TPSTATUS('FIFA/#') WHERE(TOPICSTR LK FIFA/EURO/E*) ALL
1 : DISPLAY TPSTATUS('FIFA/#') WHERE(TOPICSTR LK FIFA/EURO/E*) ALL
AMQ8754: Display Topic status details.
TOPICSTR(FIFA/EURO/ESP) ADMIN( )
MDURMDL(SYSTEM.DURABLE.MODEL.QUEUE)
MNDURMDL(SYSTEM.NDURABLE.MODEL.QUEUE)
DEFPSIST(NO) DEFPRTY(0)
DEFPRESP(SYNC) DURSUB(YES)
PUB(ENABLED) SUB(ENABLED)
PMSGDLV(ALLDUR) NPMSGDLV(ALLAVAIL)
RETAINED(NO) PUBCOUNT(0)
SUBCOUNT(0) PUBSCOPE(ALL)
SUBSCOPE(ALL)
另外，可以使用 DISPLAY TPSTATUS(‘#’) 返回主题树中所有节点的状态，也可以使用DISPLAY TPSTATUS(+) 返回主题树根结点的状态。
上面详细介绍了如何使用 MQSC 脚本命令实现对主题的管理，接下来我们将介绍如何使用 MQ Explorer 和 MQSC 脚本实现对订阅的管理。
WebSphere MQ V7 提供了两种管理订阅的方法，一种是通过 MQ Explorer 管理，另一种是通过 MQSC 命令管理。
打开 MQ V7 Explorer，展开队列管理器目录结构，找到被管理的队列管理器，右击“Subscriptions”，如图 4：
点击“Subscription”打开创建新的“Subscription”窗口，如图 5：
在图 5 中可以通过 Select 按钮选择已经存在的主题，也可以在 Topic Name 和 Topic String 处输入。参数 Destination Class 有两个值 Managed 和 Provided，如果选择 Managed，队列管理器提供动态队列作为 Destination。如果选择 Provided，用户需要输入 Destination 值，该值必须是已经存在的队列。
WebSphere MQ V7 引入了新的 MQSC 命令定义和管理订阅。清单 9 使用 DEFINE SUB 命令定义新的订阅 SUB1，指定 Q1 为 Destination。
DEFINE SUB(SUB1) TOPICSTR(NEWS/SPORTS) DEST(Q1) 6 : DEFINE SUB(SUB1) TOPICSTR(NEWS/SPORTS) DEST(Q1) AMQ8094: WebSphere MQ subscription created.
定义 Managed 类型的订阅可以不用指定 DEST 参数，清单 10 定义了 Managed 类型的 订阅 SUB2。
清单 10. 定义 Managed 类型订阅
DEFINE SUB(SUB2) TOPICSTR(NEWS/ENT) DESTCLAS(MANAGED) 1 : DEFINE SUB(SUB2) TOPICSTR(NEWS/ENT) DESTCLAS(MANAGED) AMQ8094: WebSphere MQ subscription created.
清单 11 使用 DISPLAY SUB 命令显示订阅的定义。
清单 11. 显示订阅定义
DIS SUB(SUB2) 1 : DIS SUB(SUB2) AMQ8096: WebSphere MQ subscription inquired. SUBID(414D5120514D35202020202020202020E3DB4F4920145108) SUB(SUB2) TOPICSTR(NEWS/ENT) TOPICOBJ( ) DEST(SYSTEM.MANAGED.DURABLE.494FDBE307511420) DESTQMGR(QM5) PUBAPPID( ) SELECTOR( ) USERDATA( ) PUBACCT(16010515000000B218D7C0694A597186E61BE3F603000000000000000000000B) DESTCORL(414D5120514D35202020202020202020E3DB4F4920145108) DESTCLAS(MANAGED) DURABLE(YES) EXPIRY(UNLIMITED) PSPROP(MSGPROP) PUBPRTY(ASPUB) REQONLY(NO) SUBSCOPE(ALL) SUBLEVEL(1) SUBTYPE(ADMIN) VARUSER(ANY) WSCHEMA(TOPIC) SUBUSER(root)
在以上的章节，我们为您讲述了 MQ V7 对主题和订阅这两个对象的管理。接下来，我们将为您介绍两种分布式发布/订阅结构以帮助您更好的理解 MQ V7 发布/订阅技术。
相关推荐
原生js图片圆形排列按钮控制3D旋转切换插件.zip
内含二维数组与三维数组,分别为list2nd,list3rd
原生js颜色随机生成9x9乘法表代码.zip
原生js实现图片叠加滚动切换代码.zip
【Academic tailor】学术小裁缝必备知识点：全局注意力机制（GAM） 注意力机制是深度学习中的重要技术，尤其在序列到序列（sequence-to-sequence）任务中广泛应用，例如机器翻译、文本摘要和问答系统等。这一机制由 Bahdanau 等人在其论文《Neural Machine Translation by Jointly Learning to Align and Translate》中首次提出。以下将详细介绍这一机制的背景、核心原理及相关公式。 全局注意力机制（Global Attention Mechanism, GAM）由 《Global Attention Mechanism: Retain Information to Enhance Channel-Spatial Interactions》提出，是一篇针对计算机视觉任务提出的方法。这篇文章聚焦于增强深度神经网络中通道和空间维度之间的交互，以提高分类任务的性能。与最早由 Bahdanau 等人提出的用于序列到序列任务的注意力机制 不同，这篇文章的重点是针对图像分类任务，并未专注于序
本项目在开发和设计过程中涉及到原理和技术有: B/S、java技术和MySQL数据库等；此文将按以下章节进行开发设计； 第一章绪论；剖析项目背景,说明研究的内容。 第二章开发技术；系统主要使用了java技术， b/s模式和myspl数据库，并对此做了介绍。 第三章系统分析；包罗了系统总体结构、对系统的性能、功能、流程图进行了分析。 第四章系统设计；对软件功能模块和数据库进行详细设计。 第五章系统总体设计；对系统管理员和用户的功能进行描述， 第六章对系统进行测试， 第七章总结心得；在论文最后结束章节总结了开发这个系统和撰写论文时候自己的总结、感想,包括致谢。
1、资源项目源码均已通过严格测试验证，保证能够正常运行； 2、项目问题、技术讨论，可以给博主私信或留言，博主看到后会第一时间与您进行沟通； 3、本项目比较适合计算机领域相关的毕业设计课题、课程作业等使用，尤其对于人工智能、计算机科学与技术等相关专业，更为适合； 4、下载使用后，可先查看README.md文件（如有），本项目仅用作交流学习参考，请切勿用于商业用途。
镗夹具总工艺图
原生js树叶数字时钟代码.rar
近代非线性回归分析-韦博成1989
内容概要：本文详细介绍了用 Rust 语言实现冒泡排序算法的具体步骤，以及通过设置标志位来优化算法性能的方法。示例代码包括了函数定义、内外层循环逻辑、标志位的应用，并在主函数中展示了如何调用 bubble_sort 函数并显示排序前后的数组。 适合人群：具有基本 Rust 编程基础的学习者和开发者。 使用场景及目标：适用于想要深入了解 Rust 中冒泡排序实现方式及其优化技巧的技术人员。通过本篇文章，能够掌握 Rust 基本语法以及算法优化的基本思想。 阅读建议：除了仔细阅读和理解每一部分的内容外，还可以尝试修改代码，改变数据集大小，进一步探索冒泡排序的时间复杂度和优化效果。此外，在实际应用时也可以考虑引入并发或其他高级特性以提升性能。
培训课件 -安全隐患分类与排查治理.pptx
中国各地级市的海拔标准差数据集提供了298个地级市的海拔变异性信息。海拔标准差是衡量某地区海拔高度分布离散程度的统计指标，它通过计算各测量点海拔与平均海拔之间的差异来得出。这一数据对于评估地形起伏对网络基础设施建设的影响尤为重要，因为地形的起伏度不仅会增加建设成本，还会影响信号质量。此外，由于地形起伏度是自然地理变量，它与经济社会因素关联性较小，因此被用作“宽带中国”试点政策的工具变量，以研究网络基础设施建设对经济的影响。数据集中包含了行政区划代码、地区、所属省份、所属地域、长江经济带、经度、纬度以及海拔标准差等关键指标。这些数据来源于地理空间数据云，并以Excel和dta格式提供，方便研究者进行进一步的分析和研究。
YOLO算法的原理与实现
视网膜病变是糖尿病和高血压的主要微血管并发症。如果不及时治疗，可能会导致失明。据估计，印度三分之一的成年人患有糖尿病或高血压，他们未来患视网膜病变的风险很高。我们研究的目的是检查糖化血红蛋白 (HbA1c)、血压 (BP) 读数和脂质水平与视网膜病变的相关性。我们的主要假设是，血糖控制不佳（表现为高 HbA1c 水平、高血压和异常脂质水平）会导致视网膜病变风险增加。我们使用眼底照相机筛查了 119 名印度患者的视网膜病变，并获取了他们最近的血压、HbA1c 和血脂谱值。然后，我们应用 XGBoost 机器学习算法根据他们的实验室值预测是否存在视网膜病变。我们能够根据这些关键生物标志物高精度地预测视网膜病变。此外，使用 Shapely Additive Explanations (SHAP)，我们确定了对模型最重要的两个特征，即年龄和 HbA1c。这表明血糖控制不佳的老年患者更有可能出现视网膜病变。因此，这些高风险人群可以成为早期筛查和干预计划的目标，以防止视网膜病变发展为失明。
在强化学习（RL）领域，如何稳定地优化策略是一个核心挑战。2015 年，由 John Schulman 等人提出的信赖域策略优化（Trust Region Policy Optimization, TRPO）算法为这一问题提供了优雅的解决方案。TRPO 通过限制策略更新的幅度，避免了策略更新过大导致的不稳定问题，是强化学习中经典的策略优化方法之一。
1、资源项目源码均已通过严格测试验证，保证能够正常运行； 2、项目问题、技术讨论，可以给博主私信或留言，博主看到后会第一时间与您进行沟通； 3、本项目比较适合计算机领域相关的毕业设计课题、课程作业等使用，尤其对于人工智能、计算机科学与技术等相关专业，更为适合； 4、下载使用后，可先查看README.md文件（如有），本项目仅用作交流学习参考，请切勿用于商业用途。
这组数据涵盖了1999至2020年间中国各地区普通小学毕业生的数量。它为我们提供了一个深入了解中国教育领域中普通小学阶段教育水平和教育资源分配情况的窗口。通过分析这些数据，可以为制定科学合理的教育政策提供依据，同时，通过比较不同城市的普通小学毕业生数，也能为城市规划和劳动力市场调查提供参考。数据来源于中国区域统计年鉴和中国各省市统计年鉴，包含了8472个样本，以面板数据的形式呈现。这些数据对于掌握中国教育态势具有重要的参考价值。
原生js制作拖拽排列排序代码.zip
PixPin截图工具,非常好用的一款截图工具