腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
视频
沙龙
5
回答
长寿的JMS会话。保持JMS连接/ JMS会话总是打开的做法是不好的吗?
java
、
jms
保持JMS连接/会话/使用者总是处于开放状态是不好的做法吗? 代码草案示例: // app startup code ConnectionFactory cf = (ConnectionFactory)jndiContext.lookup(CF_JNDI_NAME); Connection connection = cf.createConnection(user,pass); Session session = connection.createSession(true,Session.TRANSACTIONAL); MessageConsumer consumer = session.c
浏览 0
提问于2008-11-07
得票数 10
回答已采纳
1
回答
发送者如何知道消息已经被MQ JMS API消费?
jms
、
mq
我正在处理一个独立的MQ JMS应用程序,我们的应用程序需要“意识到”客户端已经使用了放在队列中的消息生产者。因为客户端app不是我们负责的。所以我们不能让他们自己写"msg.acknowledge();“之类的东西(在我的情况下,msg.acknowledge()不是正确的方法)。我在堆栈溢出中搜索历史答案。查找以下内容与我想要的内容完全相同: 我的问题是,是否有其他方法可以将其归档到MQ API或JMS API中?我只需要在msg产生端做编码,它可以是队列或主题。 另一个问题是JMS中的确认模式CLIENT_ACKNOWLEDGE,那是不是无关紧要呢?我一直认为这种模式可以在调
浏览 2
提问于2012-01-06
得票数 3
回答已采纳
2
回答
Spring JmsTemplate默认关闭连接吗?
java
、
spring
、
jms
、
jmstemplate
我在Glassfish中编写了一个在web服务中运行的JMS应用程序(也将其部署在JBoss中),我注意到在我通过MessageListener MDP处理了几个消息之后,JMS服务器耗尽了连接! 使用Apache和Glassfish内部ActiveMQ代理(openMQ?) 有没有办法检查为什么会发生这种情况?如果这是JmsTemplate的默认行为,那么用正确的方式开发JMS生产者和消费者的替代方法是什么? 谢谢!
浏览 0
提问于2010-11-02
得票数 6
1
回答
启用CachingConnectionFactory的Spring
java
、
jms
、
ibm-mq
、
spring-jms
我目前正在进行一个建立spring cachedConnectionFactory sessionCahceSize的项目,请给出为什么一个1(3个目的地)的sessionCacheSize注册1+ (大约3) JMS缓存的消息生成器的原因? 应用程序以事务模式运行,并发线程大小为1。 我是否应该研究一下找出空闲缓存的生产者和驱逐缓存的生产者进行优化的策略?
浏览 6
提问于2017-04-26
得票数 1
回答已采纳
1
回答
使用XA的JMS会话和JPA事务
ejb
、
jms
、
jta
、
websphere-8
、
xa
我在EJB3.1和中使用WebSphere 8.5。 我需要使用无状态会话bean作为生产者在队列中写入消息。EJB是用TransactionAttributeType.REQUIRED注释的,因为我需要在队列上发送消息并使用这些消息(读取由生产者编写的记录)之前执行一些"DB插入“。 问题是,如果我定义了一个JDBC数据源,那么生产者会在队列中写入消息,但是服务器会抱怨本地资源(我认为是datasource本身)的2阶段提交失败,并且没有调用MDB的onMessage方法。如果我定义了JDBC,一切都可以工作。 我的问题: JMS会话是否需要作为默认XA资源?为什么? 如果我
浏览 2
提问于2014-11-23
得票数 3
1
回答
JMS生产者/消费者/代理如何确保/确认消息被发送/删除/消费/处理
java
、
jms
、
message-listener
1. JMS生产者如何获得消息已成功发送到Broker/MOM/JMS Server的确认。 2. JMS生产者如何获得消息已成功交付给消费者的确认(在同步和异步情况下) 3. JMS Consumer如何确保消息被成功读取到代理和生产者。 是AUTO_Acknowledgment吗? 4. JMS Consumer如何确保消息成功处理到broker和producer。 是AUTO_Acknowledgment吗?
浏览 1
提问于2013-09-20
得票数 0
2
回答
Spring JMS并发性和JMSXGroupID
java
、
spring
、
multithreading
、
spring-jms
我在TomEE容器内的web应用程序中使用Spring JMS,并希望使用JMSXGroupID将我的消息分组在一起。我使用以下Spring JMS侦听器容器配置。 <jms:listener-container container-type="default" connection-factory="jmsFactory" cache="none" acknowledge="auto" transaction-manager="transactionManager" concurrency="1-5
浏览 0
提问于2016-08-24
得票数 1
1
回答
消息的ActiveMQ分布
messaging
、
activemq
我有几台从Python生成xml文件的服务器,还有一些使用Java使用这些xml的其他服务器。我最近才研究过JMS和,并决定尝试使用它来传递xml文件。 因此,我在使用者服务器上设置了ActiveMQ守护进程,并认为我应该在产品上实现一些循环方法,以便在使用者之间均匀地分发xmls。 Python -----------------------------> ActiveMQ ---> Java \ / \ / --------
浏览 2
提问于2009-03-16
得票数 2
回答已采纳
3
回答
Apache Kafka是JMS的另一个API吗?
migration
、
apache-kafka
、
jms
Apache Kafka不是JMS的另一种实现吗 我正在我的应用程序中使用JMS+AMQ,并迁移到Apache Kafka。我必须更改所有的JMS代码吗?
浏览 2
提问于2015-05-26
得票数 25
回答已采纳
1
回答
不同JVM上的JMS使用者
jms
、
message-driven-bean
、
jboss-mdb
我的应用程序将消息放入JMS队列中。实现MDB和MessageListener的bean从此队列中弹出消息。所有这些都发生在单个JVM上。 我想要做的是:我希望MDB和它将从池中获得的其他实例能够在不同的JVM上运行。我该怎么做呢?我使用的应用服务器是JBOSS 4.0.5.GA。 提前谢谢。
浏览 2
提问于2011-12-05
得票数 1
1
回答
如何在activemq中的多个线程中共享同一个生产者和使用者?
java
、
jms
、
activemq
、
messaging
下面我用一篇关于临时排队的文章来解释我的想法,我只想知道我是对还是错。 参考链接: 创建临时目的地、使用者、生产者和连接都是与代理的同步请求-响应操作,因此在处理每个请求时应该避免,因为它会导致与JMS代理的大量聊天。 即使用者和生产者,临时队列在同一个会话或连接中。如果我们关闭连接或会话,临时队列将导致disappear.we无法在不同的session.it中获取临时队列,将与activemq进行大量聊天。 实现请求-响应的最佳方法是在启动时为每个客户端创建一个临时队列和每个客户端,将每个消息上的JMSReplyTo属性设置为临时队列,然后在每个消息上使用一个correlationI
浏览 2
提问于2013-11-12
得票数 0
1
回答
JMS服务器的最佳实践是什么?它应该部署在消费者端还是生产者端?
jboss
、
jms
、
weblogic
、
integration
、
message-queue
从体系结构的角度来看,我想知道在使用两个应用程序和对象服务总线作为中间件的集成场景中,最佳实践是什么: JMS Consumer在JBoss上运行,而对象服务总线应用程序封装服务提供者。WebLogic队列应该驻留在JMS (外部服务器)上还是JMS服务器上?也就是说,如果我可以选择,JMS Server应该在消费者端还是生产者端?这样做的利弊是什么?提前谢谢。
浏览 2
提问于2013-04-01
得票数 0
1
回答
JAX-WS连接不会关闭,并在x条消息后停止消息传递
java
、
spring
、
jms
、
activemq
、
messaging
我对JAX-WS有一点小问题。我使用ActiveMQ作为妈妈和Spring。消息传递非常简单:一个jar应该向另一个jar发送包含一些数据的soap消息。 我在sender_beans.xml中是这样定义客户端的: <bean id="jmsConfig-Manager" class="org.apache.cxf.transport.jms.JMSConfiguration" p:connectionFactory-ref="jmsConnectionFactory" p:targetDestination="ac
浏览 0
提问于2012-11-29
得票数 2
回答已采纳
2
回答
刷新连接时Weblogic JMS客户端线程停滞
java
、
spring
、
jms
、
weblogic
大家好, 我们使用Spring与使用wlfullclient.jar的Weblogic JMS服务器集成。每隔一段时间,jmsListenerthreads就会卡住。我们已经观察到在刷新连接时会发生这种情况。 使用的版本: wlfullClient.jar : 10.0.1 Spring : 3.0.3 两个阻塞线程的堆栈跟踪: Name: jmsListenerContainer-1770 State: WAITING on weblogic.jms.client.JMSSession@35c0fb37 Total blocked: 3,681 Total waited: 3,66
浏览 2
提问于2011-01-19
得票数 1
回答已采纳
1
回答
C信号量线程文件
c
、
multithreading
、
file
、
semaphore
我写代码时,有三个线程从文件中读取行,三个线程写到文件中。当读取这些行时,它们被存储在一个缓冲区中。当读取完成时,将被激活。我已经尝试过了,我能够让它只用一个线程读,一个线程写。此时此刻,我非常迷茫。任何帮助都是最好的。 下面是我写的代码片段。 void *read_file(void *arg) { semaphore_down(&sem_write); while(fgets(temp, MAX_BUFFER, file) != NULL) { if(!isFull(&b)) { printf("ADDIN
浏览 1
提问于2011-10-08
得票数 0
2
回答
JMS应用程序是否应该为它发送的每条消息创建一个新会话?
java
、
jms
JMS应用程序应该为它发送的每条消息创建一个新会话,还是为一个长消息序列创建一个会话更可取?
浏览 0
提问于2010-04-22
得票数 3
回答已采纳
1
回答
Java消息侦听器和onException
java
、
jms
、
activemq
我有一个具有主线程和JMS线程的应用程序,它们通过ActiveMQ 5.15.11相互通信。我可以很好地发送消息,但是我想要一种发送状态或错误的方法。我注意到MessageListener允许onSuccess()和onException(ex)作为两个可监听的事件,但是我发现只有onSuccess()被调用。 这是我的代码片段。 JMS线程: ConnectionFactory factory = super.getConnectionFactory(); Connection connection = factory.createConnection(); Session session
浏览 3
提问于2020-02-22
得票数 0
回答已采纳
1
回答
在同一个集群中添加不同的kafka代理是可能的/最佳实践吗?
apache-kafka
如果我有一个集群,其中有一个代理从微服务MS-1消费/产生事件x,我可以在同一个集群中添加额外的代理,这样它就可以从微服务MS-2消费/生成事件y,或者对于每种代理类型都必须生成专用集群吗? 这是最好的实践,甚至可能吗? 我是在问,因为我已经看到经纪人作为领导者-跟随者在同一个集群,意味着所有的都是领导者的复制品。
浏览 3
提问于2020-02-12
得票数 0
回答已采纳
2
回答
Amazon MQ (ActiveMQ)在大消息上性能不佳
jms
、
activemq
、
amazon-mq
我们正在从IBM MQ迁移到Amazon MQ,至少我们愿意这样做。问题在于,与IBM MQ相比,Amazon MQ在使用JMS producer将较大的消息放入队列时的性能较差。 所有消息都是持久的,系统关于IBM MQ是高可用性的,Amazon MQ是多AZ的。 如果我们将这个大小的XML文件放到IBM MQ (2个cpu和8 8GB HA实例)中,我们会得到这样的性能: 256 KB = 15ms 4,6 MB = 125ms 9,3 MB = 141ms 18,7 MB = 218ms 37,4 MB = 628ms 74,8 MB = 1463ms 如果我们将相同的文件放在Amaz
浏览 3
提问于2020-03-26
得票数 1
1
回答
卡夫卡制作人和消费者能在同一春初应用程序吗?
apache-kafka
、
spring-kafka
我是卡夫卡的新手。我正在设计和开发一个Kafka解决方案来读取Oracle表(Kafka Connect或CDC在我的组织中还不是一个选项),并将这些大量的记录发送给Kafka Brokers,最终将被消费者收集并发送到目标系统。我的卡夫卡生产者和消费者代码能在同一个Spring应用中吗?还是我需要让我的AppName-生产者和AppName-消费者作为两个单独的Spring应用程序,以便它们可以单独地进行缩放? 比方说,我需要有3个生产者+3个消费者(作为一个消费者群体的一部分),所以这是否意味着我需要部署同一个应用程序的6个实例?还是3个生产者应用程序和3个消费者应用程序作为单独的应用程序
浏览 3
提问于2022-05-08
得票数 1
1
回答
发送者如何知道接收者在使用Spring Boot的JMS中不可用?
java
、
spring
、
spring-boot
、
jms
、
activemq
我有一个Spring Boot应用程序,有两个微服务,这些微服务使用JMS和ActiveMq进行异步通信。因此,发送方(ms1)向接收方(ms2)发送一条消息,发送方将把消息放在队列中,如果接收方不可用,消息将一直留在队列中,直到接收方可用。 我想问你,发送者如何知道接收者是否可用?我想知道,因为我想使用Hystrix,如果接收方可用,发送方将显示如下消息:“事务成功完成!”,但如果接收方不可用,发送方将显示其他消息,例如:“接收方服务当前不可用,消息将被添加到队列中,并将在消息可用时发送给接收方”。 以下代码来自Sender服务: @HystrixCommand(fallbackMe
浏览 0
提问于2020-06-19
得票数 0
2
回答
主题消息可以在activemq中持久化吗?
activemq
我对JMS和ESB非常陌生。我使用activemq作为JMS,使用mule作为ESB。当我在jms连接器参数"persistentDelivery“为"true”的情况下将消息从一个队列转发到另一个队列时,它会在activemq重新启动后将消息保留在目标队列中。但是当消息从一个topic转发到另一个topic时,消息在重启后不会保留在目标topic中。 如果是activemq中的topic,消息的持久化有什么限制吗? 提前谢谢。 向您致敬,Arijit
浏览 1
提问于2012-01-12
得票数 5
回答已采纳
1
回答
Spring与JMS的集成不能正常工作
java
、
spring-boot
、
spring-integration
、
spring-integration-dsl
嗨,我正在尝试构建一个Spring引导应用程序,并使用spring集成。 应用程序1: Publisher Jms Message -> Broker ->queue1 应用程序2:订阅者和发行者 Broker->queue1->Transform->HTTP CALL->HTTP Response->JMS Message->Broker->queue2 Publisher Flow @Configuration public class EchoFlowOutBound { @Autowired private Con
浏览 0
提问于2018-07-27
得票数 1
回答已采纳
2
回答
JMS队列已满
java
、
jboss
、
jms
我的Java应用程序不断地将JMS发送到队列,但有时JMS使用者应用程序会停止接收JMS。它会导致JMS队列非常大甚至是满的,从而使服务器崩溃。我的服务器是JBoss或Websphere。应用服务器是否提供了删除“超时”JMS消息的策略? 处理大型JMS队列的策略是什么?谢谢!
浏览 2
提问于2011-01-26
得票数 14
回答已采纳
2
回答
是否有任何工具来优化JMS队列中的使用者线程和生产者线程的数量?
performance
、
multithreading
、
jboss
、
jms
我正在开发一个分布在两个JBoss实例上并在多个JMS队列上生成/使用JMS消息的应用程序。 当我们配置应用程序时,我们必须确定我们将使用哪个线程模型,特别是每个队列产生和使用线程的数量。我们已经以一种非常特别的方式这样做了,但是在阅读了Herb在Dobbs博士(特别是)中的最新专栏后,我想用更严格的方式来衡量我们的线程。 是否有任何方法/工具来度量JMS (特别是JBoss消息队列)的吞吐量,作为生成/消费线程数量的函数?
浏览 2
提问于2009-01-06
得票数 2
1
回答
JMS中的多线程
java
、
multithreading
、
asynchronous
、
jms
、
synchronous
我需要编写一个多线程JMS生产者和一个多线程JMS消费者;我对使用JMS比较陌生,以前从未使用过多线程。我在API中看到,您可以使用生产者的完成侦听器和消费者的消息侦听器异步发送和接收消息。这是否意味着使用完成侦听器和消息侦听器会导致程序多线程?如果没有,那么如何编写多线程生产者和多线程消费者呢?
浏览 1
提问于2015-06-08
得票数 1
2
回答
将队列中的消息提供给具有延迟的消费者:Weblogic
java
、
jms
、
weblogic
我可以找到在生产者的供应和消费者的消费之间造成延迟的方法。 但我想知道是否有任何可能的方法在每个message.Say上造成延迟,我希望我的消费者每2秒只挑选一条消息,但我希望我的生产者以其最佳性能速度生产,因为我的消费者没有生产者效率高。那么,有没有一种方法可以在消息从队列发送到消费者之前控制其延迟呢? 我在producer上试用了weblogic.jms.extensions.WLMessageProducer producer = (weblogic.jms.extensions.WLMessageProducer)queueSender; 和
浏览 1
提问于2013-10-09
得票数 0
3
回答
在ActiveMQ中向多个用户发送消息
java
、
activemq
我是ActiveMQ的新手。我试图在activemq中实现生产者-消费者(发送者-接收者)。在我的代码中,我很容易通过ActiveMQ从单个生产者发送和接收消息到单个消费者。但是,问题是,我不能向同一个生产者的多个消费者发送信息。 这是我的制片人&消费者课程。 MsgProducer.java package jms_service; import javax.jms.JMSException; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConn
浏览 7
提问于2014-08-29
得票数 2
回答已采纳
1
回答
使用camel jms组件在activemq中的消息消耗
java
、
spring
、
apache-camel
、
spring-jms
我有两条骆驼路线的申请: 1号干线(消费者路线) 读取没有的文本文件。对于记录(分隔行),根据每一行拆分它们,并将每个拆分记录发送到另一个队列(“中间”队列)。 2号干线(生产者路线) 从中间队列读取每个记录,转换它们并将它们发送到一个out队列。 我用的是ActiveMQ和骆驼JmsComponent (concurrentConsumers=7, maxConcurrentConsumers=10)。我猜骆驼在下面使用Spring从队列中读取。 Configurations activemq.broker.uri = tcp://0.0.0.0:61616?jms.useA
浏览 1
提问于2016-06-22
得票数 3
2
回答
不同源系统和单个使用者的活动MQ并发
java
、
spring
、
jms
、
activemq
我有一个问题,在我的队列中有来自不同源系统的消息。 例如:在第一条消息中,我的源系统名为:“X”,而在第二条消息中,源系统名称是:'Y‘。 目前,我有一个JMS侦听器,其并发级别设置为1。因此,所有消息都按预期的方式逐一处理,但现在我希望并发地处理消息,如果消息来自同一个源系统,那么一次只应该为该源系统处理一条消息,如果存在针对不同源系统的消息,则必须并行执行。 源系统是动态创建的,这就是为什么我不能为每个源系统设置单独的队列和使用者。 如果有人把我推向正确的方向,那就太好了。
浏览 2
提问于2017-05-04
得票数 2
回答已采纳
2
回答
ActiveMQ与JMS
spring
、
jms
、
activemq
、
spring-jms
我正在尝试理解JMS。 ActiveMQ和JMS的区别是什么? 在Spring中可以使用ActiveMQ插件来共享非ActiveMQ的数据吗? 谢谢,提前说
浏览 0
提问于2015-09-06
得票数 11
回答已采纳
2
回答
ActiveMQ和CachingConnectionFactory的自动重新连接问题
java
、
spring
、
activemq
我对ActiveMQ和Spring的CachingConnectionFactory有点问题。我这样设置它们: <!-- A connection to ActiveMQ --> <bean id="myConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="${jms.url}"/> <property
浏览 0
提问于2011-05-07
得票数 7
回答已采纳
1
回答
在ActiveMQ中使用实现发布订阅
java
、
activemq
、
spring-integration
、
spring-jms
我在ActiveMQ中使用Spring的PublishSubscribe通道开发了一个生产者和消费者。我可以使用实现发布和接收消息,但只有一个服务激活器以循环方式使用消息。我需要确定这是否正确。以下是我的配置: 制片方: <int:publish-subscribe-channel id="jmsPubSubChannel" /> <int-jms:outbound-channel-adapter channel="jmsPubSubChannel" destinat
浏览 1
提问于2016-07-28
得票数 0
回答已采纳
1
回答
分布式环境下的消息排序
spring-boot
、
design-patterns
、
java-8
、
microservices
我需要一些关于解决我目前面临的问题的指导。我有一个微服务,它部署在8个豆荚中,它有一个JMS监听器,在所有豆荚中都启用了这个监听器来增加并行性。 现在,事件正在按不同的顺序处理,无法维持事件处理的顺序。业务要求按特定顺序处理事件(事件包含顺序no,这保证了订单)。但是,我们需要适当的并行性来运行多个荚中的侦听器。 如果有人对如何设计它有任何建议,请你分享?使用DB或redis或任何其他组件? 谢谢桑迪普
浏览 6
提问于2022-01-20
得票数 0
1
回答
Connection.start不是JMS MessageProducer需要的,而是MessageConsumer需要的。
java
、
jms
、
activemq
、
jms-queue
A-问题 我知道有一个类似的问题,但不一样。 我正试图了解JMS中的MessageProducer和MessageConsumer在幕后发生了什么。使用MessageProducer ActiveMQ的实现,我编写了一个简单的示例以发送消息到队列,并编写了一个MessageConsumer示例来使用来自队列的消息,同时在本地运行ActiveMQ。 向队列发送消息需要Connection#start方法。确切的调试点如下所示。Connection#start触发ActiveMQSession#start方法。此方法是在调用Connection#start时触发的。请参见org.apache.ac
浏览 5
提问于2020-10-02
得票数 1
回答已采纳
2
回答
当运行jms时,队列生产者发送消息,而使用者获得消息,但没有显示消息。
java
、
jms
、
activemq
、
producer-consumer
、
jms-topic
嗨,我有java代码,它有一个生产者和一个消费者。生产者将消息发送到队列,使用者也会收到消息,但我不知道为什么不显示消息。我使用的是activeMQ,因为我没有收到消息,所以我签入了in :/localhost:8161/admin/Quees.jsp,在那里它显示队列有生产者和使用者,但是消息没有打印在命令prompt.Please告诉我 producer.java import javax.jms.*; import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFa
浏览 1
提问于2013-03-06
得票数 1
1
回答
Websphere消息重传
java
、
spring
、
ibm-mq
我有一个Websphere MQ和一个java应用程序接收来自它的消息。如果在我的应用程序中抛出任何异常,我想要重新传递系统。我正在使用spring事务管理器,但问题是如果消息在我的应用程序中导致异常,该应用程序正在尝试重新发送相同的消息。如果有一些(2,3等)不成功的重发尝试,我能在队列的末尾放一条断消息吗? 这是我的弹簧配置: <bean id="mqMessageListener" class="ru.mos.notification.controller.MQNotificationListener"> <property na
浏览 8
提问于2014-11-25
得票数 0
回答已采纳
1
回答
Avro模式GenericRecord缺少键
c#
、
apache-kafka
、
schema
、
avro
、
confluent-platform
我使用Avro模式动态地从C#应用程序生成消息给卡夫卡集群,使用汇合的Kafka客户端。编译时不知道数据类型,因此我使用来自GenericRecord类的Avro.Generic命名空间,如下所述:。 但是,我有一个问题--如果模式有一个可以包含空值的字段,则仍然需要使用add方法将该字段添加到GenericRecord,并将null作为值。我的应用程序不知道可以为null的字段,也不认为应该是--因为这违背了模式中可空字段的目的。 Avro模式: { "namespace": "Test", "type": "record
浏览 3
提问于2019-11-21
得票数 0
1
回答
如何通过camel-jms组件将Artemis与Camel Java DSL结合使用?
apache-camel
、
activemq
、
jms2
现在查看camel-jms文档,根本没有提到如何使用通用的camel JMS组件来生成和使用发往任何JMS2.0兼容代理的消息。 上的惟一示例是使用Spring DSL使用其专用的ActiveMQ组件配置ActiveMQ连接工厂。如何配置Camel JMS连接到我的Artemis实例? 考虑到尽管Artemis与JMS5.x兼容,但我将使用Camel路由来发布和订阅共享持久主题,因此我需要能够配置ActiveMQ连接,并使用它创建发布者和共享持久订阅者(仅在JMS2.0中支持,ActiveMQ仅支持JMS1.1)。 谢谢!
浏览 5
提问于2016-01-22
得票数 6
2
回答
如果存在超时或处理消息崩溃的应用程序,消息会发生什么情况?
java
、
jms
我目前正在阅读同步JMS for JAVA。我正在努力确认我的理解是否正确。根据我在Google中搜索的内容,我的理解是JMS同步方法,如果出现超时,消息将永远丢失。我说得对吗? ,我的问题是:,如果发生超时,或者应用程序使用基于以下示例的同步JMS方法处理消息崩溃时,消息会发生什么变化? 以同步为例,其中系统A是消息的产生者,系统B使用和处理消息 1:系统A将消息发送到队列并提交。 2:系统A连接仍然可用,等待确认 3:另一边的System将使用接收()来使用来自队列的消息 4: System使用消息并尝试保存/处理消息。 5:此时,系统B崩溃。消息回滚到队列(我是否正确地理解了这一点) 6
浏览 4
提问于2015-12-16
得票数 3
2
回答
无法在tomcat上使用ActiveMQ消息
tomcat
、
jakarta-ee
、
jms
、
activemq
、
jndi
我试图在Apache中配置Active。我有两个war文件,MessageProducer.war和MessageConsumer.war,我在两个项目的/WebContent/WEB/lib文件夹中添加了所有ActiveMQ依赖war。我在两个wars的context.xml文件中配置了以下资源。context.xml文件放置在/WebContent/META/文件夹中,用于这两个wars。 Context.xml <Context> <Resource name="myConFactory" auth="Contai
浏览 4
提问于2016-10-06
得票数 1
4
回答
发布/订阅vs生产者/消费者?
message-queue
从kafka,rabbit,hornet mq,activemq等系统的消息传递角度来看……pub/sub和prod/con之间有区别吗?还是可以互换使用?
浏览 100
提问于2017-02-27
得票数 32
回答已采纳
1
回答
对于JMS中的客户端确认模式,使用者向谁发送确认
java
、
jms
、
websphere
、
ibm-mq
当我们在JMS中使用客户端确认模式时(我使用的是Websphere MQ和WAS),MDB将确认发送给谁(文档说发送给JMS服务器)。 但在本例中,JMS服务器的含义是:实际拥有所有队列和消息的WebSphere MQ,或者连接到websphere MQ的web sphere application server。
浏览 1
提问于2013-10-11
得票数 0
1
回答
Jms:具有多个使用者的发布/订阅
spring-boot
、
jms
、
oracle-aq
对于具有一个主题和两个持久订阅者的JMS pub/sub,在大多数情况下,当消息被发送到主题时,我们希望这两个订阅者都使用该消息。 但在特定的场景中,我们可能希望消息只由特定的订阅者使用。这是可能的吗?它能做到吗?我们正在使用带有Spring Boot的OracleAQ。
浏览 3
提问于2021-04-14
得票数 0
1
回答
JMS队列(点到点消息)到底是如何工作的?
java
、
spring
、
jakarta-ee
、
jms
、
spring-jms
我正在学习Spring认证,我对的工作方式和Spring如何处理它有一些疑问。 因此,我知道JMS核心组件是: 消息 目的地 连接 会话 MessageProducer MessageConsumer 据我所知,TextMessage,ObjectMessage,消息是与其他实体(必须使用此数据的其他产品)发送和共享的消息,消息可以具有不同的形状:StreamMessage. MapMessage、BytesMessage和StreamMessage.。 好的,据我所了解,JMS组件的目标组件定义了接收消息的人和发送消息的逻辑。 所以我知道我有两种目的地:
浏览 1
提问于2015-03-05
得票数 0
回答已采纳
1
回答
如何在JMS中使用JMS点对点采样器向IBM MQ队列发送消息?
jmeter
、
jms
、
ibm-mq
、
jndi
、
point-to-point
我设置了一个本地IBM实例,并设置了一些默认队列。 使用JMeter 5.4.1,我首先要向其中一个队列发送消息,以测试连接是否有效。 1.是否可以使用IBM,还是只适用于Active MQ? 我想要实现的测试场景是: JMeter用ID1向一个名为"DEV.QUEUE.1“的队列发送一些消息 被测试的系统接收来自"DEV.QUEUE.1“的消息,进行一些处理并将响应放在"DEV.QUEUE.2”上。 JMeter检查并断言在X秒内收到了名为"DEV.QUEUE.2“的队列中带有ID1的消息的响应 查看汇总报告中的结果 2.使用JMS点对
浏览 3
提问于2021-10-27
得票数 0
回答已采纳
1
回答
如何处理JMS队列满时的情况?
jms
、
activemq
我创造了一个队列。生产者不断地发布到JMS队列。但是,用户需要一些时间来处理消息,并且队列在一段时间后就会满。 如何在生产者端(即Java应用程序)和JMS代理上处理这种情况?
浏览 3
提问于2021-01-26
得票数 0
回答已采纳
1
回答
Weblogic JMS高吞吐量生产者/消费者
java
、
jms
、
weblogic
、
java-ee-5
、
producer
我正在做一个项目,在这个项目中,我们有一个高吞吐量的jms消息产品(顺便说一下,还有消费者)。一些测试让我相信我没有在最佳状态下正确处理JMS消息产品。首先,让我解释一下场景:我们有一个包含13个队列的Weblogic集群(2个节点)。在UDP listener (Netty)上接收消息,并创建一个分配在第一个队列上的ByteMessage,依此类推。通过一些分析,我发现执行第一步并不需要很长时间,它的使用者也不需要太长时间,但是消息仍然会在队列中停留很长一段时间。它们是非持久性的,交付时间为0(零)。一个改进是缓存de connectionFactory、ConnectionQueue、Qu
浏览 1
提问于2013-04-23
得票数 0
回答已采纳
3
回答
JMS -消息选择器如何与多个队列和主题使用者一起工作?
java
、
jakarta-ee
、
jms
、
messaging
假设您有一个JMS队列,并且多个使用者正在查看队列中的消息。您希望其中一个消费者获得所有特定类型的消息,因此决定使用 例如,您定义了一个要放入JMS消息头部的属性,名为targetConsumer。您的消息选择器类似于WHERE targetConsumer = 'CONSUMER_A',您将其应用于称为A的消费者。 很明显,消费者A现在将像在示例中一样,使用属性集抓取消息。然而,其他消费者会意识到这一点吗?如果另一个消费者不受消息选择器的约束,如果它在消费者A之前查看队列,它会获取CONSUMER_A消息吗?我是否需要将像WHERE targetConsumer <&g
浏览 2
提问于2010-05-14
得票数 8
回答已采纳
1
回答
ActiveMQ:以编程方式限制对目标的访问
runtime
、
jms
、
authorization
、
activemq
有人知道如何在activemq中通过编程来限制对jms目的地的访问吗? 我得到了一个客户端-服务器应用程序,我想为每个客户端使用一个目的地,以便将消息发送到服务器。 在activemq网站()上有一个简短的认证示例,但它使用的是xml配置文件。 我需要在运行时以编程方式完成它。 ->创建目标并限制特定用户的读/写访问权限 这个是可能的吗?有谁能给我个提示吗? 谢谢!
浏览 5
提问于2013-06-29
得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
JMS规范
使用kafka之前要知道的概念
active mq消息中间件(一)
消息队列中间件(二)使用 ActiveMQ
ActiveMQ进阶学习
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券