我需要关于JMS队列和消息处理的帮助。我对每个属性的消息组和队列有了一些了解。我的想法是，我想要进行特定于属性组的同步处理</
浏览 12提问于2018-02-15得票数 1
1回答
更新：但在HornetQ (或jms )中，每个组都被固定到一个特定的工作进程。这意味着，如果组A和组B被固定到工作线程X，并且队列中有10条用于组A的消息和10条用于组B的<em
浏览 0提问于2014-06-25得票数 0
3回答
Java:跨多个服务器同步线程
、、、、
我有一个问题，我需要为Windows上的Java服务跨多个不同的服务器同步多个线程的处理。
在这个应用程序中，我有多个使用者线程从同一个JMS队列中提取消息。消息以3个或4个为一组进入，我需要确保每个组中的消息都是完全串行处理的。我需要某种同步机制来确保如果thread1拉出一条消息，然后thread2从该组中拉出下一条消息，thread2等待t
浏览 8提问于2009-04-03得票数 5
回答已采纳
我的应用程序要求具有特定组id的所有消息都由同一线程处理。我尝试使用DMLC进行设置，但当我看到消息正在处理时，当并发设置为> 1时，它们将由DMLC中的单独线程处理。我希望我可以让多个使用者分别使用不同的消息组从队列中读取数据，但在这种设置下，我没有看到所需的行为。有没有办法使用DMLC或SMLC (使用JTA)来支持队列上的多个侦听器，其中具有特定<em
浏览 7提问于2016-08-24得票数 2
我有一个tibco队列，在这里我们接收来自生产者的消息，而骡子流正在消耗这些消息。在jms:连接器中，我将numberOfConsumers设置为20。有些时候，当负载很高时，我的消息就会在流中按顺序接收。我希望我的流能够按顺序接收消息，而不会使其单线程化。queue="${queue1}" connector-ref="jmsconnector" doc:name="JMS">
<log
浏览 2提问于2018-05-14得票数 0
1回答
我有一个在多个集群节点上有多个使用者的JMS队列。我收到了来自不同发件人的信息。可能有多条消息，其中只有一个实体的信息。这些实体需要用jpa持久化。当接收到一个实体的消息时，该实体可能已经存在于数据库中，也可能还不存在。 当两个消费者同时处理同一实体的消息时，问题就出现了。两个使用者都试图在数据库中查找该实体。但我使用的是容器管理的事务，在刷新和事务结束之间仍然存在差距。 第二个想法是关于合并和持久化之间的区别。但是，即使它可以与merge一起使用，也会导致覆盖现有数据
浏览 12提问于2019-04-11得票数 0
回答已采纳
我正试图了解Lambda将如何处理具有指定MessageGroupId参数的FIFO消息。
属于同一消息组的消息以FIFO方式处理(但是，不同消息组中的消息可能会按顺序处理)。在这种情况下，多个使用者可以处理队列，但是每个用户的会话数据都是以FIFO方式处理的。FIFO行为，加上短语“将多个订单流交织在一个队列中”，向我建议，具有特定Mess
浏览 1提问于2020-07-02得票数 2
1回答
我有多个客户端(将它们称为通道)访问WebSphere消息代理上的服务。SOAP或HTTP节点似乎没有等效的属性。想知道如何才能获得来自特定客户端通道的请求的优先级。我是否可以使用多个执行组(EG)来为特定通道提供更高的优先级。换句话说，我正在考虑使用EG为特定通道提供更大的
浏览 0提问于2014-05-01得票数 0
1回答
JMS :结束流数据包
、、、、
我将从一些输入文件中读取数据，并将它们加载到jms队列中，然后让一些消费者从队列中读取数据包并对其进行处理。有没有办法通知消费者输入数据已经完成，并且他们可以在处理完他们当前持有的数据后安全地关闭它们？谢谢,
浏览 0提问于2014-03-02得票数 0
1回答
锁定骆驼处理器
、、、
我想知道在骆驼处理器上实现同步的方法。
注意，在按设计使用ActiveMQ、JMS或SEDA时没有并发或锁定问题；它们是为高度并发使用而设计的。然而，在消息的处理器中存在可能的并发问题，即处理器如何处理消息？因此，如果我想锁定org.apache.camel.Processor.process(Exchange)，即希望其他线程在繁忙时
浏览 8提问于2013-11-08得票数 4
1回答
根据示例，在Azure Event Hub客户端中有一个同步发送事件的"Send“方法，但在接收端是否有同步的东西。
要实现接收器，我们必须使用事件处理器Host类，但所有寄存器事件都是异步的。如何同步触发接收器？
浏览 2提问于2018-04-15得票数 1
因此，在非独占队列上，我们已经对消息进行了排序(例如，id 123 update event将在id 123 create event之后)。当我们只有一个消费者时，一切都很好，但需要水平可伸缩性。通过产生另一个消费者，我知道代理将在它之间进行轮询，因此更新事件可能会在其创建事件之前被处理。
关于如何解决这个问题，solace上有什么现有的模式吗？我逐渐了解到一些像kafka和activemq这样的代理支持它，通过在发布期间指定id，它将确保具有该id的所有消息将只在一个消费者上排队；因此，尊重事件的顺序。
浏览 1提问于2020-01-30得票数 3
1回答
我们将在数据库表中配置URI，以调用下一组服务。这些服务被配置为侦听特定的JMS消息。下一组服务将接收JMS消息并处理数据.上面的方法是否仍然代表REST体系结构？除了网络延迟之外，还有什么其他的东西吗？，我们缺少的REST体系结构的好处是什么。
或者我们可以说我们的方法是REST体系结构，但方法不同吗？
浏览 3提问于2019-09-27得票数 0
4回答
我需要实现一个公平的排队系统，以便根据某些消息头的值，对当前排队的消息头的所有值以循环的方式处理消息。我需要能够按顺序使用消息，这样就不会将特定
浏览 7提问于2014-10-15得票数 12
3回答
并发消费者仍确保订单
、、、
我有一个JMS队列，它的填充速率非常高(>100,000/秒)。现在，整个设置正在放缓，因为使用者无法处理传入消息的速率。由于在用户处理消息的速率上存在SLA，我一直在尝试让多个使用者并行地执行以加快处理速度的想法。
浏览 6提问于2012-07-19得票数 3
1回答
我们通过为每个用户使用命名队列并将芹菜配置为一次只从任何给定队列运行一个任务来完成这一任务。问题/所需结构
我们希望过渡到使用AWS函数来执行我们的后台任务，因为我们在应用程序使用上有很大的差距(我们通常在大组中获得任务)，这可以节省成本。Lambda似乎具有管理并发性的功能，但只针对每个函数，而不具有与我们目前使用的多个队列相同的功能。
浏览 5提问于2022-10-11得票数 0
或者使用相同的ID进行等待其他请求，同时，如果我有其他ID的请求，无需等待就可以处理，比如12。如果没有这样的id (例如12)，则继续处理。
一旦旧进程完成，它应该告诉其他具有相同ID等待的作业，其中一个作业可以从它们等待的位置恢复工作，这样就应该发送响应。在同步方法"RequestSynchronization“中，我希望对ID为ID的现有作业执行检查操作，如果存在，则等待来自以前的通知(如果不返回响应)，然后继续处理。使用路由"
浏览 3提问于2019-11-07得票数 0
我还设置了一个SQS触发器和批处理大小为1的Lambda。比如说，队列中有100条消息。在我当前的实现中，我执行了以下步骤：
处理完成后，将手动从队列中删除消
浏览 8提问于2021-02-12得票数 1
回答已采纳
我是个新手，正在尝试理解最大并发是如何工作的？我理解这是为了确定可以同时接收多少个请求。但我有一个问题，如果我对应用程序有大量的传入请求，如果我设置了最大并发，后续请求是否会在队列中，或者它会出错，或者数据将会丢失？例如，假设我的应用程序收到大约10,000个请求，并且我将最大并发数设置为1000。那么，其他9000将在队列中，还是有数据丢失的机会？提前谢谢。
浏览 5提问于2021-05-21得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
