连接到websphere mq v7.1并使用Java和JMS清除一个或多个指定队列的所有消息的最佳方法是什么？我需要使用Websphere MQ特定的java API吗？谢谢。
浏览 0提问于2012-07-17得票数 2
回答已采纳
2回答
我们正在使用IBM MQ，我们面临着一些严重的问题，关于控制它的异步传递到它的recipient.We已经配置了一些java侦听器，现在的问题是，我们需要控制到达侦听器的消息，因为进入服务器的消息有数百万个，服务器机器没有那么多的容量来同时处理这么多的线程，所以有没有像IBM MQ端的节流一样的方法，我们可以像Apache MQ那样配置预取限制？
或者，有没有其他方法来实现这一点？
目前，当监听器达到某个X限制时，我们正在关闭与IBM MQ的连接，但这似乎不是有效的方法。
请大家帮助我们解决这个问题。
浏览 0提问于2011-07-16得票数 0
1回答
我使用mQuee.h来使用POSIX消息队列在线程之间进行通信(用于学校项目演示)。
当我完成了使用队列的两个线程并希望关闭消息队列时，我应该做什么呢？
从两个线程执行mq_unlink和mq_close操作
从一个线程执行mq_unlink和mq_close
只从一个线程执行mq_unlink
只从两个线程执行mq_unlink
只从一个线程执行mq_close
只从两个线程执行mq_close
编辑(因为)：“结束。这个问题需要细节或清晰”
我使用在mQuee.h (C)中定义的POSIX消息队列在线程之间发送消息。这类似于与消息队列的进程间通信。我可以使用
浏览 3提问于2020-02-03得票数 1
回答已采纳
2回答
我是消息队列的新手。我正在尝试使用以下代码从MQ队列中获取消息。
我正在创建一个连接，并使用该连接从队列中获取每条消息。这样做是否正确，以及我是否需要提交连接。
无限的for循环是从队列接收消息的正确方式，对吗？请多多指教。
try {
createMQConnection(); // getting mq connection
createMQSession(); // getting mq session
createMQDestination(); // getting mq destination
for ( ; ; ) { // infinite l
浏览 0提问于2017-01-24得票数 4
2回答
我做了一个从MSMQueue读取消息的Windows服务，我需要并行地做这件事(两个线程应该同时读取消息)。我该怎么做呢？下面是我的代码(基本上是照本宣科)：
public partial class MyNewService : ServiceBase
{
System.Messaging.MessageQueue mq;
System.Messaging.Message mes;
public MyNewService()
{
InitializeComponent();
浏览 2提问于2013-05-01得票数 2
1回答
我正在设计一个单进程多线程嵌入式Linux应用程序.该设计包括客户机-服务器子系统，其中工作线程接收POSIX消息队列上其他线程发布的消息。
我需要队列显示非阻塞发送和阻塞接收语义。我可以想出几种实现上述功能的方法：-创建两个单独的消息队列描述，用于为了发送和接收访问队列，即两次调用mq_open。随后将设置用于通过队列发送的描述的O_NONBLOCK标志。
指定阻塞行为并使用mq_timedsend代替mq_send
指定阻塞行为并在mq_getattr之前调用mq_send以避免在发送时阻塞
第一种解决方案可能是首选的解决方案，但要使其工作，必须保证每次对mq_open的调
浏览 12提问于2020-02-27得票数 3
回答已采纳
目前，我们计划升级我们的产品，使用MQ(RabbitMQ或ActiveMQ)在服务器和客户端之间进行消息传输。现在，我们使用了一个网络库(Evpp)来实现这个目的。
因为我以前不使用MQ，所以对MQ的许多新特性非常感兴趣，所以我无法找出它们之间的本质区别，也不知道何时何地应该使用MQ或仅仅使用网络库就可以了。
使用MQ的目的是解决通信的不可靠性，如消息丢失或网络环境不稳定造成的其他问题。
希望有一个熟悉他们的人可以释放我的困惑。谢谢你提前。
浏览 2提问于2020-05-21得票数 1
回答已采纳
2回答
我对实时操作系统中消息队列的使用感到非常困惑。给出的代码似乎使用了消息队列:甚至将变量传递给另一个类对象也是通过MQ完成的。我总是有一个在IPC中使用的MQ概念。问题是:消息队列的正确用法是什么？
浏览 1提问于2011-05-13得票数 3
回答已采纳
2回答
我有一个消息驱动的bean，它在某些情况下抛出异常。当它抛出异常时，消息不会被处理并放回队列中。根据我对MQ和WAS (Websphere Application Server)的理解，消息应该在x次尝试后被标记为坏的，并从队列中删除。这种情况不会发生，消息仍保留在标记为坏的队列中。
MQ和/或我错过了设置正确的配置的哪一部分？
( MDB抛出异常的问题不是这里的重点)
谢谢。
浏览 5提问于2010-06-01得票数 3
回答已采纳
我有一个连接到Websphere MQ的C#应用程序。
基本上：
MQEnvironment.Hostname = HostName;
MQEnvironment.Channel = Channel;
MQEnvironment.Port = Port;
MQQueueManager queueManager = new MQQueueManager(QueueManagerName);
using (MQQueue putQueue = queueManager.AccessQueue(putQueueName, MQC.MQOO_OUTPUT))
{
}
我的问题是:应该
浏览 3提问于2015-03-16得票数 1
回答已采纳
2回答
我试图编写一个消息队列实现，这样我的线程就可以交换数据。为了保持简单，队列只负责发送指向内存的指针。只有一个线程可以发送消息，只有一个线程可以读取消息。
struct mq_t表示消息队列。
mq_t.messages是指针的循环缓冲区。
mq_t.send是上一次发送消息的索引。
mq_t.recv是要接收的下一条消息的索引。
我想知道一些事情：
线程安全:我没有使用互斥锁或锁，但我认为代码非常线程安全。这是真的吗？
在代码中，我使用像while (isempty(queue));这样的东西。是否有更好的方法来处理这些事情，比如挂起线程直到内存发生变化？
跨平台:我的代码是依赖于非跨平台代码
浏览 0提问于2013-08-03得票数 6
回答已采纳
有没有办法使一个写入器进程在使用mq_send()向消息队列发送消息后，多个读取器进程可以使用mq_receive()读取该消息。我希望1次写入mq，1次从mq读取，消息会丢失。
所以我只想知道我的理解是否错了。有没有办法让单个写入器和多个读取器进程可以使用posix消息队列进行通信。
浏览 2提问于2012-03-30得票数 8
在没有O_NONBLOCK的情况下创建消息队列时，如果队列为空，则mq_receive()调用阻塞。当一条新消息被发送到队列时，哪些等待的mq_receive()调用实际上解除阻塞？
QNX文档明确提到FIFO顺序：
如果多个mq_receive()调用在单个队列上被阻塞，那么它们将在消息到达时按FIFO顺序解除阻塞。
所有POSIX IPC实现都是这样吗？Linux实现是做什么的？该手册相当不具体：
如果队列为空，则默认情况下，mq_receive()会阻塞，直到消息可用，或者呼叫被信号处理程序中断。。
浏览 0提问于2019-12-02得票数 1
回答已采纳
1回答
我们有WebSphere MQ服务器。我已经编写了Java客户端实用程序，可以读取所有消息(将它们留在队列中)或从队列中删除所有消息。但是，这是否可以读取消息，如果它包含某些字符串-删除它？
要读取我使用的队列消息(消息将保留在服务器队列中以供将来处理，coz实用程序仅用于测试)：
MQQueue queue = queueManager.accessQueue(queueName, MQC.MQ00_BROWSE | MQC.MQ00_INPUT_SHARED);
MQGetMessageOptions options = new MQGetMessageOptions();
options
浏览 3提问于2012-01-30得票数 1
回答已采纳
1回答
mq_notify仅启动一个线程
、、、、
我正在尝试使用mq_notify调用来启动一个具有POSIX消息队列的线程。看起来一切正常，但我只有一个线程，它处理所有消息，但它永远不会终止。我的印象是，我会得到新的线程来处理，但这似乎是不正确的。
浏览 0提问于2011-06-07得票数 2
回答已采纳
我面临一个关于消息队列的问题：
我使用mq_timedreceive()在abs_timeout时获取消息队列。但这一功能受系统时间(CLOCK_REALTIME)的影响。我的意思是，当系统时间改变时，abs_timeout (绝对时间)不再正确。
为了解决这个问题，我意识到它应该改为CLOCK_MONOTOIC时钟。但是在linux中，没有办法(我搜索并发现QNX支持这种机制)。
最后，我将select()和mq_timereceive与NO_WAIT结合起来。+ select()：使用相对时间，因此不受系统时间变化的影响。超时之后，我将得到带有mq_timereceive()的
浏览 2提问于2016-04-24得票数 2
我们从不同的交易所获得交易，我们需要以从MQ收到的相同顺序加载交易，我们保留相同顺序的原因是有时exchange可能会发送相同交易类型的更改和删除记录类型，在这种情况下，我们需要在删除之前处理更改。我注意到，在我们的系统中加载每条消息需要21毫秒(xml -> jaxb object-->pojo-->db)。Exchange在MQ中丢弃一条xml消息。使用Spring集成，我如何将21毫秒/msg的交易负载提高到10毫秒左右，同时需要保留相同的顺序，并应优雅地完全终止进程。
我有把xml转换成jaxb对象的jaxb转换器，还有把嵌套的jaxb对象转换成单个java实体对象的
浏览 0提问于2015-05-12得票数 1
我必须向IBM队列发送一条消息。我已经编写了一个普通的生产者类来将消息推送到队列中，如下所示：
Session session = queueConnection.createSession(true,
QueueSession.AUTO_ACKNOWLEDGE);
Destination destination =
session.createQueue("test.queue");
MessageProducer producer = session.createProducer
浏览 2提问于2017-09-03得票数 0
救命啊！我们使用IBM，这是输出dspmqver：
Name: WebSphere MQ
Version: 8.0.0.14
Level: p800-014-200107.1
BuildType: IKAP - (Production)
Platform: WebSphere MQ for Linux (x86-64 platform)
Mode: 64-bit
O/S: Linux 4.15.3-1-generic
InstName: Installation1
InstDesc:
Primary:
浏览 17提问于2020-04-22得票数 0
我是IBM的新手，我想问您解决以下任务的最佳方法。
我使用WebSphere MQ7.0，并实现了一个java应用程序来检查传入消息的MQ队列。
通过以下代码打开的传入队列：
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_INQUIRE;
MQQueue incomingQueue =
qManager.accessQueue(qName, openOptions, null, null, null);
现在，任务是在incomingQueue中出现新消息时以实时模式检查并处理它们。
我通过在while-loop
浏览 2提问于2011-11-15得票数 3
回答已采纳
1回答
删除消息队列
、、
我对C/C++程序中删除消息队列的方式感到非常困惑。我看到
删除消息队列
您可以使用ipcrm命令(请参阅ipcrm(1)参考页)或通过调用msgctl()和传递IPC_RMID命令代码来删除消息队列。在许多情况下，消息队列仅用于一个程序的范围内，您不希望该队列在该程序结束后持续存在。调用msgctl()删除队列，作为终止的一部分。
然后是其他的东西，也就是
我很困惑，现在完全删除消息队列的方法是什么？
现在让我告诉大家我所面临的问题。我在我的应用程序中创建了两个消息队列，现在突然出现了信号，并将控件传递给信号处理程序。在信号处理程序中，我正在重新启动服务，在该服务中，我在说"
浏览 7提问于2015-07-28得票数 4
我正在升级一个独立的Java应用程序，它使用IBM MQ将消息发送到本地Websphere 8.5服务器。现有的应用程序对MQ代码使用了一堆不同的jars (mq、mqbind、mqjms、connector-api、jms)。
对于新的版本，我看到现在有一个包罗万象的"allclient“MQ ()，所以我决定使用它。
对于前几条消息，它似乎工作得很好，但在发送4-5条消息后，所有后续消息都将失败，并显示代码2594 ()：
Caused by: com.ibm.mq.jmqi.JmqiException: CC=2;RC=2594;AMQ9204: Connection to ho
浏览 2提问于2020-09-22得票数 0
最近，我开始遇到以下问题，导致消息无法传递到：
"PollThread" prio=10 tid=0x00007f0a2cf86000 nid=0x76b8 in Object.wait() [0x00007f09eb6bf000]
java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:503)
at com.ibm.mq.
浏览 1提问于2014-09-25得票数 1
1回答
ZMQ异步，它是如何准确工作的？
、、、、
我目前正在工作的一个项目，要求快速网络管理。为此，我选择了0MQ，但是在阅读了这个文档和示例之后。关于0MQ的异步部分，我很难理解。
是否为路由器或经销商套接字上的每个请求创建了任何线程？
我经常犯将异步和多线程结合在一起的错误。当我查看的人时，我发现对于一个交易商或路由器套接字，传入的路由设置在“公平排队”。由此我得出结论，异步意味着您可以在套接字上写入或读取，而无需等待应答发送另一个请求(所有内容都排队并同步处理)。
所以问题是，
对于每个请求，0MQ是否创建了任何线程？(我不是说后台线程0MQ在内部管理消息队列)。
浏览 3提问于2015-11-01得票数 3
回答已采纳
问题
是否可以将MQ消息从一个队列管理器/队列复制到另一个队列管理器/队列？
场景
我有一个"PROD“队列管理器，当它在队列上收到消息时，我想将消息”复制“到"TEST”队列管理器上的队列中。
需求
必须将原始消息保留在PROD队列上，以便按正常方式处理。
这必须是一个自动化的过程(一天中有很多消息)。我不能以信息为基础进行干预。
如果可能的话，我希望这可以通过一些本地MQ功能来实现，而不是一个临时的程序/脚本。
复制必须尽可能接近实时。
必须使用MQ版本是7.0.2.1(!)。这是不能改变的。
必须在版本5.11 (Tikanga)上运行。再说一遍，
浏览 1提问于2017-07-21得票数 1
回答已采纳
1回答
我正在努力研究如何构建一个“机器”，通过Twisted向WebSphere MQ发送和接收消息。我希望它尽可能通用，这样我就可以在许多与MQ接口的不同情况下重用它。
我以前用过Twisted，但很多年前我正在尝试恢复我曾经拥有的知识.
我遇到的具体问题是如何使用Twisted实现MQ。有一个与MQ接口的pymqi Python库，它提供了我需要的所有接口。我需要实现的MQ调用是：
启动到特定MQ服务器/端口/通道/队列管理器/队列组合的连接
获取内容并将其作为消息发送到所需的队列
轮询队列并返回队列中下一条消息的内容
向队列管理器发送请求，以查找队列中当前的消息数。
所
浏览 3提问于2012-08-03得票数 0
回答已采纳
我在兔子messages中使用ServiceStack，发现通过ServiceController.ExecuteMessage处理程序处理的服务消息是用两个线程处理的，即使"noOfThreads = 1“。下面是我注册处理程序的方式：
container.Register<IMessageService>(c => new RabbitMqServer());
var mqServer = (RabbitMqServer)container.Resolve<IMessageService>();
mqServer.RegisterHandler<
浏览 2提问于2014-08-12得票数 1
我知道如何使用C#控制台应用程序连接到IBM MQ并将消息接收到队列中，但我不想编写控制台应用程序。我想写一个windows服务，它将接收消息到MQ中。有可能吗？任何线索，任何类型的链接都会对此有所帮助。请帮帮忙。
浏览 0提问于2018-06-08得票数 0
我将重构一个为websphere MQ编写的代理应用程序。在现有应用程序中，当从队列中读取消息时，将设置以下选项：
MQConstants.MQGMO_WAIT和
waitInterval = 1000 (毫秒)。
在我们的应用程序中，不能保证每秒都会收到一条消息。我们可能在几个小时内都收不到消息。我不确定为什么这个应用程序的创建者选择waitInterval = 1000而不是将waitInterval设置为MQWI_UNLIMITED。目前，代码中有一个catch块，它在MQException.MQRC_NO_MSG_AVAILABLE发生时不做任何事情。
这个应用程序的创建者是非常聪明的
浏览 1提问于2014-01-22得票数 0
我试图弄清楚如何“反转”单个POSIX消息队列，以启用客户机和服务器进程之间的双向通信，同时只使用一个POSIX消息队列(即一次只使用一个内存段)。本质上，这是一个支持双向通信的半双工设置，但是消息一次只能向一个方向流动。
标准方法是为客户端->服务器使用一个队列，为服务器->客户机使用一个队列，如下所示(这基本上是我当前的代码)。
客户端：
...
int read = mq_open("servertoclient", O_RDWR | O_CREAT, 0600, 0);
int write = mq_open("clienttoserver"
浏览 4提问于2021-10-21得票数 0
我们正在使用IBM来实现.NET的WebSphere MQ。
创建MQQueueManager对象显然是一项昂贵的操作，因此我们缓存和重用这些对象的池。
目前，对于每个请求，我们访问所需的队列：
//obtain queueManager from pool
IBM.WMQ.MQQueue requestQ= queueManager.AccessQueue(requestQName, mqOptions);
IBM.WMQ.MQQueue responseQ= queueManager.AccessQueue(responseQName, mqOptions);
一旦做完就关闭它们：
req
浏览 3提问于2010-12-09得票数 5
1回答
我有一个强制销毁具有给定名称的posix消息队列的硬要求。
经过反复试验，我发现这个命令行不通。
mq_unlink(BROKER_NAME);
上面的问题是，即使在取消链接之后，只要其他线程/进程引用队列，队列就会存在。
有没有一种方法可以强行销毁队列，不问问题？
我还将向队列添加文件描述符。
浏览 2提问于2019-07-29得票数 0
我们设置了IBM websphere mq，它接受来自外部世界的消息，并将消息传输到另一个内部队列管理器。我想要跟踪每条消息进行此活动所用的时间。有人知道有什么工具或MQ功能吗？
谢谢!
浏览 2提问于2010-09-02得票数 2
回答已采纳
这是基于的后续。
如何设置MQ支持包(如MA01中的Q实用程序)中的.exe程序，使其在每次收到消息时执行？这可以在MQ Explorer中设置吗？(我们在Windows 2008/R2上使用7.0 )。
浏览 1提问于2012-11-14得票数 3
回答已采纳
2回答
我的应用程序中有两个线程-一个线程异步读取MQ队列中的消息并将它们发送到处理单元，另一个线程从处理单元检索信息并将相关消息放到发送方队列中。问题是，在前面的消息输出线程完成之前，将检索下一条消息并发送到处理单元，从应用程序的角度来看，这是不正确的。由于在任何时候都可以在队列中找到要处理的消息，因此不希望同步读取消息。
我知道我可以引入另一个队列来保持消息直到准备好被处理，但是是否有任何与MQ设置相关的解决方案可供我使用呢？在我看来，这是一种非常常见的设置。
提前感谢你的建议/帮助。
浏览 2提问于2014-02-17得票数 1
回答已采纳
1回答
分析ZeroMQ
、、、
有关ZeroMQ评测和调试的问题。我有兴趣找出0MQ套接字的两个信息。1)队列长度和2)消息(消息数量和总消息大小)。
有没有什么方法我们可以在0MQ套接字中监控和记录上述信息？0MQ是否公开这样的计数器？我认为对我们在0MQ之上构建的系统进行概要分析和调试是非常有用的。我们正在使用C++应用编程接口。谢谢。
浏览 0提问于2017-07-06得票数 0
我在Linux上使用Posix消息队列。基本上，我有多个线程通过调用mq_timedreceive从同一队列接收消息。
如果多个线程同时运行并且队列不为空，是否可以保证消息不会被多次接收(即消息不会被传递到多个线程)？
可以肯定的是，我可以将接收与互斥同步，但如果可能的话，我希望避免这个锁。我阅读了所有的手册页(man mq_overview(3))，但没有找到任何明确的内容。
提前谢谢。
浏览 4提问于2012-03-02得票数 4
回答已采纳
2回答
简介
我有一个基于SEDA的系统，并使用MSMQ在不同的应用程序/服务之间进行通信(事件触发)。
其中一个服务通过文件获取消息，因此我有一个文件侦听器，它读取文件内容并将其插入队列(实际上是4个不同的队列，但这对于第一个问题并不是很重要)。
服务器是Windows 2008
第一个问题-读慢
我的应用程序在另一边读取这些消息，通常每秒从队列中读取大约20条消息，但是当发送消息的服务开始排队大约1,000条消息时，读掉了，读取的应用程序每秒只读取2-4条消息。当没有投递到队列时，读取应用程序可以每秒读取多达20条消息。
读取应用程序中的代码非常简单，是用C#开发的，我在System.Messag
浏览 3提问于2011-06-27得票数 8
我试图避免过多地填充消息队列，所以这里有几个问题
使用mq_attr时
mq_curmsgs什么时候满？当它是0或max_msgs时
满的时候，我需要冲洗吗？
您会推荐使用以下几种：select、poll或epoll？如果是这样，我该如何使用它们？
浏览 3提问于2013-06-24得票数 0
回答已采纳
1回答
我有一个主MQ和一个从MQ。如果主MQ崩溃，我可以使用消息驱动bean通过从MQ发送消息吗？同样，在我的主MQ再次启动之后，我可以在不重新启动JVM的情况下自动重新连接行吗？
浏览 1提问于2015-05-22得票数 1
回答已采纳
3回答
我在一个.c文件中打开一个消息队列，如果成功，它会显示消息队列id为3。当该程序仍在运行时，我在另一个终端上启动了另一个程序(另一个.c文件)，该程序创建了一个具有不同mqd_t的新消息队列。但它的id也显示为3。这有问题吗？
服务器文件是这样的：
void server(char* req_mq) {
struct mq_attr attr;
mqd_t mqdes;
struct request* msgptr;
int n;
char *bufptr;
int buflen;
pid_t apid;
//attr.mq_maxmsg = 300;
//attr.mq_msgsize
浏览 2提问于2010-03-07得票数 4
回答已采纳
2回答
队列中是否有任何事件机制或预定义信号。如果队列中有任何数据或消息，队列应该生成一个事件，表示数据已经准备好处理。或者指示其他线程执行他的任务，而不是连续轮询到队列。
在posix消息队列中，有类似于mq_notify()的函数，如果消息队列中有任何数据出现，它将通知其他进程或线程，这样我们就可以避免轮询。
编辑
如果不是，那么我如何在std::queue上实现这一点。我希望避免不断轮询，这样会降低代码的性能。
每当队列上发生某些事件时，它都应该通知其他人。
浏览 4提问于2014-07-02得票数 3
回答已采纳
1回答
我是新的多线程编程和进程间通信机制。
我有一个程序(比如说A)，它在无限循环中通过async_receive()等待传入的数据。
现在我想从一个单独的过程(比方说B)控制程序A。
更准确地说，当B发出信号时，我想终止程序A。这样，程序A中的io_service()就会被取消，程序A就会终止。
似乎我应该在程序A中定义一个线程来等待来自B的信号。
我的问题是为什么我能收到来自B的信号？
我尝试使用message_queue(mq) (boost/interprocess/ipc/message_queue)。所以，B在mq中放了一条消息，但是我如何通知程序A从mq读取数据呢？当en\dequeu
浏览 3提问于2013-11-06得票数 1
回答已采纳
我们有一个环境，在这个环境中，MQ充当
网站和微焦点。有时消息会卡在队列中，
从而阻塞该特定队列上的所有通信。如果
队列深度大大增加，所有的通信都停止在
队列管理器。
当我们检查队列的状态时，我们看到那里存在微焦点进程。
有没有办法自动清除所有连接到队列的应用程序？
浏览 4提问于2013-03-15得票数 1
2回答
我在深度上定义了一个MQ触发器，如下所示。创建后第一次触发，但不会再次触发。定义如下。
DEFINE PROCESS(DEVL.OFFLOAD.PROCESS) APPLTYPE(UNIX) +
APPLICID('/home/mqm/bin/queue_offload.ksh') +
DESCR('Queue Offload Program Triggered on Depth')+
replace
DEFINE QL('TEST.QUEUE') INITQ(SYSTEM.DEFAULT.INITIATION.QUEUE) +
浏览 0提问于2015-06-03得票数 0
如何配置Websphere MQ以在消息到达时激活组件？
我希望避免使用某些Windows对新传入的消息进行持续轮询，我确实希望将推送给我，而不是相反。
我在.NET 4环境和WCF中工作，是我可以使用的合法技术。
浏览 2提问于2013-06-03得票数 0
如果我在Websphere MQ队列中保留500条消息，并由消耗该队列的程序运行，则每条消息大约需要2-3毫秒。
如果我保持消费者程序运行，并保持以每秒200毫秒的速度将消息放入队列，则读取程序会急剧减慢，每条消息大约需要200毫秒。
我怀疑是某种锁定影响了消费者程序。有什么办法可以解决这个问题吗？
谢谢,
Yash
浏览 2提问于2014-12-05得票数 0
我们使用IBM MQ6.1。并使用IBM API将消息发送到队列。由于我们需要发送大量的消息，我想知道我们是否可以使用多线程并将消息发送到同一队列。有什么建议吗？
浏览 1提问于2010-08-06得票数 1
1回答
我们有一个标记为已触发的应用程序MQ队列，并在其上设置了一个MQTT_FIRST。
当消息第一次到达该队列时，queue将创建一个触发消息并将其写入我们为此目的定义的初始队列中。触发消息触发监视进程的执行，该进程将启动触发器监视应用程序，该应用程序将逐个从应用程序队列中读取消息。
我们使用Spring JmsTemplate逐个从应用程序队列读取消息。该jmsTemplate实例打开到应用程序队列的连接，从那里读取一条消息，然后关闭连接。
我们遇到的问题是，当连接关闭时，如果应用程序队列中有多个消息，一个新的触发消息将被发送到启动队列，这将导致另一个触发器监视器应用程序(运行在另一个主机上)弹
浏览 3提问于2014-03-06得票数 0
1回答
我现在正在做一个带有时间限制的项目。安装程序是: web服务接受(微小的) xml文件，我必须快速地处理这些文件。
首先，也是最天真的想法是在请求分配器本身中处理这个处理，但这并没有扩展，从一开始就注定失败。
因此，现在我正在研究各种传入请求，每个请求在我这边产生大约50个作业。可供使用的技术由于客户的规则而受到限制。如果不是Sql Server或MQ，它可能不会运行。
我考虑沿着MQ路由(Web服务只是提交消息、以后多个消费者进程)和概念模块的小证明，就像一种魅力。
但是有一个问题:在队列中，这些任务的优先级可能会发生很大变化。这个系统是相当重要的时间，所以如果我们--无论出于什么原因--不
浏览 2提问于2010-08-25得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
