如何设置JMS客户端的持久化？
JMS（Java Message Service）是一种用于在分布式系统中发送、接收和处理消息的Java API。在JMS中，可以通过设置持久化来确保消息的可靠传递和持久存储。
要设置JMS客户端的持久化，需要以下步骤：
- 创建一个JMS连接工厂：JMS连接工厂是用于创建JMS连接的对象。可以使用JNDI（Java Naming and Directory Interface）或直接在代码中创建连接工厂对象。
- 创建一个JMS连接：使用连接工厂创建一个JMS连接对象。连接对象表示与消息代理（如消息队列）的连接。
- 创建一个JMS会话：使用连接对象创建一个JMS会话对象。会话对象用于创建消息生产者和消息消费者。
- 创建一个JMS目的地：JMS目的地可以是一个队列（Queue）或一个主题（Topic）。队列用于点对点通信，主题用于发布-订阅模式。
- 创建一个JMS消息生产者：使用会话对象和目的地创建一个消息生产者对象。消息生产者用于发送消息到目的地。
- 创建一个JMS消息：使用会话对象创建一个JMS消息对象。消息对象可以是文本消息、字节消息、对象消息等。
- 设置消息的持久化：在创建消息对象之后，可以通过调用消息对象的setJMSDeliveryMode方法来设置消息的持久化。将参数设置为DeliveryMode.PERSISTENT表示消息是持久化的，将参数设置为DeliveryMode.NON_PERSISTENT表示消息是非持久化的。
- 发送消息：使用消息生产者发送消息到目的地。
以下是JMS客户端持久化的优势和应用场景：
优势：
- 可靠性：持久化确保消息在发送过程中不会丢失，并且可以在消息代理重新启动后重新传递。
- 持久存储：持久化将消息存储在持久化存储介质（如数据库）中，以便在需要时进行检索和处理。
- 离线消费：持久化允许消费者在离线状态下接收消息。当消费者重新连接时，它将接收到在其离线期间发送的消息。
应用场景：
- 订单处理：在电子商务系统中，使用持久化确保订单消息的可靠传递和持久存储，以便在需要时进行处理和跟踪。
- 通知和提醒：使用持久化发送通知和提醒消息，以确保消息的可靠传递和持久存储，以便用户可以在需要时查看。
- 日志记录：使用持久化将系统日志消息发送到消息队列，以便在需要时进行检索和分析。
腾讯云提供的相关产品和产品介绍链接地址如下：
- 云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 云数据库 CDB：https://cloud.tencent.com/product/cdb
- 云服务器 CVM：https://cloud.tencent.com/product/cvm
- 云存储 COS：https://cloud.tencent.com/product/cos
- 人工智能 AI：https://cloud.tencent.com/product/ai
- 物联网 IoT Hub：https://cloud.tencent.com/product/iothub
- 区块链 BaaS：https://cloud.tencent.com/product/baas
- 视频处理 MPS：https://cloud.tencent.com/product/mps
请注意，以上链接仅供参考，具体产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我们开发的网管产品已经被几家电信运营商部署。我们的应用程序(使用ActiveMQ)将故障通知发布到故障队列，消息被设置为持久化。这些消息由第三方JMS客户端使用。并不是所有的客户都有一个通知客户端来使用事件(有些部署没有任何订阅)。问题是，如果队列中没有连接到队列的订阅者，ActiveMQ会持久化消息吗？
浏览 1提问于2015-12-16得票数 0
3回答
我使用使用SSL的安全通道，通过JMS设置了与Weblogic IBM Webpsphere MQ的连接。我在Weblogic上的应用程序收到了来自MQ的消息。正在将应答发送到应答队列。响应头是当前的MQMD，它填充了java。在参数持久化JMS中发送值"1“。其他系统需要在持久化时接收"0“值。如何将该参数设置为java？我猜这个参数是jav
浏览 12提问于2017-01-17得票数 3
使用JMS1.x，clientId用于在创建持久订阅时唯一地标识客户端。这个解释了JMS1.x中clientId的使用来自
共享持久订阅。它们仅在JMS2.0中可用，并使用createSharedDurableConsumer创建。他们可以有任意数量的消费者。设置
浏览 15提问于2019-11-03得票数 0
回答已采纳
我正在使用由3个代理组成的ActiveMQ Artemis集群(1个主服务器，2个从服务器)，安装UDP广播。sslEnabled=true我
浏览 9提问于2020-04-20得票数 0
1回答
我使用ActiveMQ作为JMS Server，我想发送几秒钟后过期的非持久化消息，因为我不想在消费客户端宕机时排队等待太多消息。(有没有最好的实践？)问题是如果JMS服务器时间戳与JMS客户端时间戳不同。有没有好的方法来获取JMS服务器的时间戳？或者ActiveMQ 是解决这个问题的“最佳”方法？
浏览 2提问于2013-03-08得票数 1
回答已采纳
我们开发了一个Java应用程序，其中多个Java JMS客户机都使用Websphere MQ 7.0.1.9连接到一个服务器。每个客户端都有带有特定于应用程序的客户端id选择器的消费者，例如。共享队列上的JMSCorrelationID='050_14133431‘，其中服务器对通过setJMSCorrelationID( )发送到特定客户端的消息设置特定于应用程序的客户端id。应用程序特
浏览 1提问于2015-09-30得票数 2
我在JBoss 4.x上将遗留的EJB2.x迁移到了WildFly 17.x上的JPA/ EJB 3。我的应用程序依赖于JMS重传计数来执行特定的消息传递顺序。在JMS4.x中，我经常通过来自JBoss消息的JMS_JBOSS_REDELIVERY_COUNT属性查询重发计数。
在WildFly中，没有关于的信息。WildFly如何跟踪重发计数，是否有通过属性或其他方式访问它的规定？
浏览 5提问于2019-12-12得票数 1
回答已采纳
今天，我已经从JMS主题订阅者那里注册了一个持久订阅。为此，我设置了一个唯一的客户端Id，并将订阅命名为：session.createDurableSubscriber(xyzTopic, "xyzSubscription");12/06/18 22:30:42警告broker.Transp
浏览 1提问于2012-06-18得票数 1
3回答
我确实获得了ActiveMQ支持数据持久性()，但我无法理解如何使其工作，结果是当我重新启动ActiveMQ时，所有的消息都消失了，而队列和主题仍然保留。我已经读过如何在数据库上启用持久性，但我希望将数据保存在文件系统上，因为我的系统正面临数据库性能问题。<!
浏览 8提问于2017-03-23得票数 2
回答已采纳
我有一个ActiveMQ Artemis队列使用者，客户机id被设置为主机名。这是在库伯奈特的复制品上运行的。现在的问题是，每当一个吊舱崩溃时，它就被分配了新的主机名，而使用者就失去了它在代理上的状态。有没有办法在整个吊舱生命周期内保持一个一致的客户身份？是否有一种方法可以从代理中分配所有的客户id，以便从一个id池中分配已知的id？
浏览 0提问于2020-08-05得票数 1
回答已采纳
2回答
我正在阅读Java EE教程的这一部分。还有一个问题:如果我有一个生成消息并将它们发送到服务器上的目标队列的JMS客户端(而不是服务器)，那么这个producer.setDeliveryMode(DeliveryMode.PERSISTENT我的意思是，JMS客户端是否支持持久化消息的任何机制，还是仅随提供程序/服务器软件提供的机制？
谢谢
浏览 1提问于2011-02-28得票数 5
回答已采纳
根据，"Camel支持来自EIP模式的保证传递，使用以下组件：.JMS。“例如,
一条消息是POSTed to someRestRoute。该消息在someQueue上排队并持久化。
浏览 3提问于2016-11-08得票数 2
回答已采纳
我们正在创建一个Mule应用程序，它将运行在Kubernetes上的一个容器中，并且将在一个副本集中运行，该副本集将连接到JMS2.0RedHatAMQ 7(基于ActiveMQ Artemis)。已将pom.xml配置为获取jms客户端： <groupId>org.apache.activemq</groupId>
<artifactId>artemis-jms-client-allsendCorrelation
浏览 1提问于2020-02-13得票数 0
回答已采纳
2回答
我有一种情况，我需要从一个主题中读取一条(正在进行的)消息，并将它们放到另一个队列中。我怀疑我是否需要jms队列，或者我可以满足于内存中的java队列。我将由同一jvm中的其他线程从队列中读取消息，并在从(内存中)队列中读取消息后对主题进行客户端确认，并根据需要对其进行处理(发送到远程IBM MQ) .So如果我的客户端崩溃，则内存中队列中存在的消息将丢失我说的对吗？
浏览 0提问于2016-02-13得票数 1
我们开发了一个以ActiveMQ Artemis作为服务间通信方式的微服务系统.由于需求要求能够在运行时停止侦听器，所以我们不能使用spring提供的@JmsListener。持久订阅的情况并非如此。为什么这两个队列的行为不同？另外，正确的行为是什么？我们担心自动删除会删除队列中尚未发送的消息。另一方面，如果我们一次又一次地运行测试，test-event-topic下的新队列将继续被创建。但是对于持久订阅，不设置<
浏览 3提问于2021-06-01得票数 1
回答已采纳
两者都运行在不同的JVM上。他们正在向持久主题发送消息，并使用相同的ClientId。
我想知道JMS2.0规范是否允许以下内容，以及在Artemis中是否可以这样做。在消费端，我有一个连接工厂，在实例化.setEnabledSharedClientId(true)I bean时，通过以下方法在工厂中设置clientID：.setClientId("clientId"在这个类中，有一个send方法，它检查连接是否存在，如果不存在，则通过this.connectionF
浏览 0提问于2020-08-16得票数 0
1回答
我在创建一个主题的持久订阅者时遇到了一些问题。这是我在创建一个主题的持久订阅时得到的错误消息-我可以创建一个普通/普通的订阅者。目前，我在创建持久订阅者时任意设置订阅者名称和clientID。在客户端使
浏览 0提问于2012-02-16得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
