小编Jos*_*hMc的帖子

死信队列和退出队列有什么区别?

死信队列和退出队列有什么区别?

在WebSphere MQ术语和应用程序服务器方面.

所有J2EE/JEE应用程序服务器都有一个MQ提供程序它们是否也有一个死信队列的构造,或者是特定于WebSphere MQ的东西?

我对退出队列的理解如下:

如果MQ在指定次数的尝试后无法将消息传递到目标,则会将消息移至后退队列.

我对死信队列没有清楚的了解.

感谢任何帮助.

jms java-ee ibm-mq

19
推荐指数
1
解决办法
4万
查看次数

是否可以在一台机器上运行多个rabbitmq实例?

我想在我的开发机器(windows)中构建一个RabbitMQ集群.
原因是我想测试和研究它.

是否可以在一台机器上运行多个rabbitmq实例?
我猜我需要:

  1. 更改侦听端口
  2. 更改appdata文件夹(C:\ Users\MyUser\AppData\Roaming)
  3. 更改ui插件端口,以便查看所有实例.
  4. 删除服务并从cli运行

有人试过吗?有一个已知的指南吗?

rabbitmq

12
推荐指数
2
解决办法
9600
查看次数

带有IBM MQ的Apache Camel

您有没有人使用过Camel和IBM的MQ.我们正在考虑可能同时使用这两种产品,但没有两种产品协同工作的例子.

apache apache-camel ibm-mq

9
推荐指数
2
解决办法
2万
查看次数

我们没有发送数据包,禁用方法

我曾尝试在 AIX 到 AIX 之间设置公钥连接,并且正在运行,但我在 AIX 和 DataPower 设备之间设置相同的公钥连接时遇到了问题。

我可以在已建立连接的日志中看到,但在使用 public 时,我无法登录,并且每次都希望手动输入密码。

有人可以帮忙吗?

debug1: Authentications that can continue: publickey,password
debug3: start over, passed a different list publickey,password
debug3: preferred publickey,keyboard-interactive,password
debug3: authmethod_lookup publickey
debug3: remaining preferred: keyboard-interactive,password
debug3: authmethod_is_enabled publickey
debug1: Next authentication method: publickey
debug1: Offering RSA public key: ./***_rsa.pub
debug3: send_pubkey_test
debug2: we sent a publickey packet, wait for reply
debug1: Authentications that can continue: publickey,password
debug2: we did not send a packet, disable method
debug3: authmethod_lookup password …
Run Code Online (Sandbox Code Playgroud)

ibm-datapower ssh-keys

9
推荐指数
5
解决办法
3万
查看次数

在 Windows Docker 下运行的 IBM MQ 客户端

我正在寻找一种在 Windows Docker 容器下运行 IBM MQ 客户端的解决方案。我知道 Docker Hub 仅提供 MQ 的 Linux 实现,但是,我不需要完整的 MQ 服务器功能。相反,我希望有一种方法可以安装 MQ 客户端并简单地连接到另一个(非 Docker)系统上定义的通道和队列。为了解决这个问题,我做了以下工作:

  1. 在命令提示符下启动一个 Windows Docker 容器(用于概念证明)

  2. 复制并扩展MQ Client 9.0.0.8-IBM-MQC-Win64.zip

  3. 静默安装的 MQ 客户端(例如msiexec /i "c:\temp\Windows\MSI\IBM MQ.msi" /l*v c:\temp\install.log /q TRANSFORMS="1033.mst" AGREETOLICENSE="yes" ADDLOCAL="Client")。

    注:安装成功,没有报错

  4. 建立所需的环境变量(MQServer 等)和更新的路径(类路径、lib、include 等)。

  5. Ping MQ 服务器系统以验证连接。

我尝试使用amqsputc.exe MYDOCKER.DS.Q. 立即返回代码是MQCONNX ended with reason code 2195。不幸的是,2195它非常通用,并且没有其他日志可供查看。

我理解在 VM 下运行 MQ 与在容器下运行 MQ 之间的区别,但是由于我只需要客户端访问,我希望 MQ 客户端足够轻量级以供使用。

如果 MQ 客户端不是一个可行的方向,是否有可能通过云连接实现的 MQ 解决方案?我的旧应用程序基于 Windows,并依赖 MQ 进行作业消息传递。

docker ibm-mq

9
推荐指数
1
解决办法
1071
查看次数

使用IBM MQ类从队列中浏览,读取和删除消息

我正在使用Eclipse的Java类编写一个简单的Java应用程序.

现在,我可以在不删除存储的消息的情况下浏览远程队列.
以下是阅读周期的代码:

MQQueueManager QMgr = new MQQueueManager(qManager); //<-- qManager is a String with the QMgr name

int openOptions = MQC.MQOO_FAIL_IF_QUIESCING | MQC.MQOO_INPUT_SHARED | MQC.MQOO_BROWSE;  

MQQueue queue = QMgr.accessQueue(queueName, openOptions);

MQMessage theMessage    = new MQMessage();
MQGetMessageOptions gmo = new MQGetMessageOptions();
    gmo.options=MQC.MQGMO_WAIT | MQC.MQGMO_BROWSE_FIRST;
    gmo.matchOptions=MQC.MQMO_NONE;
    gmo.waitInterval=5000;

boolean thereAreMessages=true;
while(thereAreMessages){
    try{
        //read the message          
        queue.get(theMessage,gmo);  
        //print the text            
        String msgText = theMessage.readString(theMessage.getMessageLength());
        System.out.println("msg text: "+msgText);

                 // <--- Solution code Here

        //move cursor to the next message               
        gmo.options = MQC.MQGMO_WAIT | MQC.MQGMO_BROWSE_NEXT;

    }catch(MQException …
Run Code Online (Sandbox Code Playgroud)

java queue ibm-mq

8
推荐指数
1
解决办法
4万
查看次数

使用CoD over Camel JMS组件实现本机websphere MQ

我在使用Apache CAMEL实现Websphere MQ(WMQ)连接器时遇到了很多困难,该连接器可以无异常地处理MQ确认传递(CoD)报告,也不会以不需要的响应数据报的形式出现副作用.最后,我按照我想要的方式工作,如果您习惯于编写本机MQ客户端,那么这是一种非常标准和通用的方式.我在同一主题的帖子中记录了该方法,但我发现解决方案臃肿而复杂,并且非常感谢任何建议或示例,以使实现更清晰,更优雅.

我理解这个问题的根源在于MQ设计请求 - 回复消息交换模式(MEP)的方式,而不是JMS规范的方式,而不是其JMS组件中的请求 - 应答MEP的CAMEL实现.三种不同的哲学!

  1. WMQ具有MessageType标头(请参阅MQMD字段常量),其中请求值为1,回复为2,数据报为8(单向MEP).此外,值4用于以CoD(交付配置),PAN(肯定确认)和NAN(否定确认)的形式标记报告消息,其中 - 在消息流方面 - 也进行额外的回复信息.可以使用另一个名为"Report"的标题字段为Request消息,回复或数据报请求CoD,PAN和NAN ack,其中可以组合所有报告变体的标志.其他标头字段'ReplyToQ'和'ReplyToQMgr'指定原始发件人期望报告和回复的队列和队列管理器,以及固定的24字节'CorrelId'字段 - 可选 - 可以帮助将报告和回复与原始数据报或请求消息相关联.为了使其更复杂,实际上可以使用相同的原始消息ID和没有CorrelID发回回复和报告,或者在CorrelId中提供原始消息ID,或者在原始请求或数据报中已经指定时返回CorrelId值.IBM 通过WMQ提供JMS API,允许通过WMQ将纯JMS交换作为传输(在额外消息头名称MQRFH2的帮助下),或将本机MQ消息映射到JMS消息,反之亦然.
  2. 另一方面,JMS规范提供了一个可选的'JMSReplyTo'头字段和一个'JMSCorrelationID',但是确实将MEP语义保留给客户端应用程序; 即在规格中陈述:" 答复可能是可选的;由客户自行决定. "
  3. CAMEL以XML或Java DSL中的"路由"和内部Exchange对象模型为特征,目的是支持EIP模式,其中包括Request-Reply模式.然后CAMEL在其JMS组件中假定如果设置了JMSReplyTo字段,则这必然是期望回复的请求,导致Exchange的Out部分(或者如果Out为空,则部分修改)返回到JMSReplyTo中定义的队列. .

我愿意通过远程Websphere队列管理器支持本地MQ消息与交付确认(CoD)报告的交换,这样除了事务和持久性(即没有丢失,没有重复)之外,我还可以跟踪消息何时被消费并在发生延误时提出警报.

入境问题:

默认情况下,Websphere队列管理器在队列中的消息消耗完成时生成CoD报告.因此,在没有任何特定设置的情况下,当CAMEL端点消耗消息时,远程MQ客户端发送带有CoD标志的数据报(以及当时强制的ReplyToQ)将从队列管理器获得第一个回复作为MQ报告,然后是第二个(意外的)回复消息由CAMEL显式返回并包含CAMEL路由末尾的Exchange对象中剩余的内容,因为CAMEL假定存在JMSReplyTo字段的请求 - 应答EIP(从MQ ReplyToQ和ReplyToQMgr映射)被要求支持CoD回流).

出境问题:

如果没有特定设置,CAMEL默认也会在出站连接上采用请求 - 回复EIP/MEP.然后,CAMEL JMS/MQ端点将等待1个响应.当OUTbound消息是MQ上的JMS(因此具有MQRFH2头)时,这可以正常工作.当强制普通的vanilla MQ,即删除下面的MQRFH2头时,我无法使端点侦听器与相关的传入MQ报告匹配,尽管跟踪值看起来都是正确的(强制执行24个char相关ID以便截断更长的CorrelId值或空填充通过MQ无法对相关过滤器进行地理化处理).有没有人能够解决这个问题?

详细信息:虽然IBM JMS API接受传递特定的JMS属性值WMQ_MESSAGE_BODY = {1 | 0}/WMQ_TARGET_CLIENT = {1 | 0}来控制生成的消息中是否存在JMS头MQRFH2,但这些选项通过CAMEL变得不可用.必须使用CamelJmsDestinationName标头(如CAMEL JMS …

jms apache-camel ibm-mq

8
推荐指数
1
解决办法
3325
查看次数

WebSphere MQ .NET - IBM.XMS.dll和amqmdnet.dll之间的区别

我已经非常广泛地使用了.NET,但我对WebSphere MQ很陌生.我需要创建一个从MQ读取消息的.NET应用程序.我一直看到引用IBM.XMS或amqmdnet库的文章.

我应该使用IBM.XMS库,但这两者之间究竟有什么区别?

谢谢!

.net ibm-mq

7
推荐指数
1
解决办法
4001
查看次数

是否会有针对Websphere XMS的.net核心支持

我目前正在使用XMS连接到Websphere,我想知道是否有人听说过或知道通过.net核心连接的方式?

.net core xms ibm-mq

7
推荐指数
0
解决办法
1011
查看次数

如何将消息从未确认状态推送到就绪状态,rabbitmq

在我们的应用程序中使用了 RabbitMq 有数百个消息在时间上累积,几个队列处于未确认状态,并且由于侦听器不活动时的几次意外关闭,TTL 无法工作。

现在出于商业原因,我不能只是清空队列。我想手动将未确认的消息推送到就绪状态。

有没有 ??

谢谢 !

tomcat rabbitmq redis

7
推荐指数
1
解决办法
9696
查看次数

标签 统计

ibm-mq ×7

.net ×2

apache-camel ×2

jms ×2

rabbitmq ×2

apache ×1

core ×1

docker ×1

ibm-datapower ×1

java ×1

java-ee ×1

queue ×1

redis ×1

ssh-keys ×1

tomcat ×1

xms ×1