发布/订阅WMQ的简单队列分配方案

By simon at 2018-02-07 • 0人收藏 • 40人看过

使用WebSphere MQ我想设置一个使用队列的主题,以便在何时使用 应用程序或入站群集连接尝试把一个消息给一个 “队列”,它实际上使用一个主题,并将其发布到2个订阅,其中 本身是2个独立的队列。本质上,我想从入境去 按名称排队,但将其映射到2个单独的队列,如 AFTODAAS是入站主题/今天是一个实际的群集队列别名 =>转到AFTOAPP1和 =>去AFTOAPP2 有点像这些是q在我想的分配名单上 这两件事是本地队列。 我迷失在/ topic / node业务映射中它来订阅和 模型队列,什么不...

2 个回复 | 最后更新于 2018-02-07
2018-02-07   #1

WebSphere MQ允许别名指向队列或主题。它也提供 一种创建持久订阅管理的手段atively。要做到这一点 设置,通过用一个替换现有的别名来连接点 指向一个话题。那我们呢e两个管理订阅路由 出版物到两个(或更多)队列。

* First, define the topic
DEFINE TOPIC('AF_TO_DAAS.TOPIC') +
   TOPICSTR('AF_TO_DAAS') +
   REPLACE

* Now, create an alias over the topic.
* Sending apps think this is a queue.
DEFINE QALIAS('AF_TO_DAAS') +
   TARGET('AF_TO_DAAS.TOPIC') +
   TARGTYPE(TOPIC) +
   REPLACE

* Queues for the two recvr apps
DEFINE QLOCAL('AF_TO_APP1') +
   REPLACE

DEFINE QLOCAL('AF_TO_APP2') +
   REPLACE

* Now set up adminsitrative subs to route
* messages to the two app queues.
DEFINE SUB('AF_TO_DAAS.SUB') +
   TOPICSTR(' ') +
   TOPICOBJ('AF_TO_DAAS.TOPIC') +
   DEST('AF_TO_APP1') +
   PSPROP(NONE) +
   REPLACE

DEFINE SUB('AF_TO_APP2.SUB') +
   TOPICSTR(' ') +
   TOPICOBJ('AF_TO_DAAS.TOPIC') +
   DEST('AF_TO_APP2') +
   PSPROP(NONE) +
   REPLACE
因为这是一本出版物,该消息将包含一个属性 Top其中包含主题字符串。在PSPROP(NONE)中 订阅entrie这导致它被压制,所以消息看起来像 原来的出版物。 还请注意publi上的MQMD.MsgID阳离子是不同的 在原来的消息。

2018-02-07   #2

WebSphere MQ允许别名指向队列或主题。它也提供 一种创建持久订阅管理的手段atively。要做到这一点 设置,通过用一个替换现有的别名来连接点 指向一个话题。那我们呢e两个管理订阅路由 出版物到两个(或更多)队列。

* First, define the topic
DEFINE TOPIC('AF_TO_DAAS.TOPIC') +
   TOPICSTR('AF_TO_DAAS') +
   REPLACE

* Now, create an alias over the topic.
* Sending apps think this is a queue.
DEFINE QALIAS('AF_TO_DAAS') +
   TARGET('AF_TO_DAAS.TOPIC') +
   TARGTYPE(TOPIC) +
   REPLACE

* Queues for the two recvr apps
DEFINE QLOCAL('AF_TO_APP1') +
   REPLACE

DEFINE QLOCAL('AF_TO_APP2') +
   REPLACE

* Now set up adminsitrative subs to route
* messages to the two app queues.
DEFINE SUB('AF_TO_DAAS.SUB') +
   TOPICSTR(' ') +
   TOPICOBJ('AF_TO_DAAS.TOPIC') +
   DEST('AF_TO_APP1') +
   PSPROP(NONE) +
   REPLACE

DEFINE SUB('AF_TO_APP2.SUB') +
   TOPICSTR(' ') +
   TOPICOBJ('AF_TO_DAAS.TOPIC') +
   DEST('AF_TO_APP2') +
   PSPROP(NONE) +
   REPLACE
因为这是一本出版物,该消息将包含一个属性 Top其中包含主题字符串。在PSPROP(NONE)中 订阅entrie这导致它被压制,所以消息看起来像 原来的出版物。 还请注意publi上的MQMD.MsgID阳离子是不同的 在原来的消息。

登录后方可回帖

Loading...