Qpid JMS:接收文本消息导致强制转换异常 - 腾讯云开发者社区 - 腾讯云

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

看完这篇，还怕面试官问消息中间件么？

这种消息类型基于消息队列的发送方和接收方，每条消息都被发送到一个特定的队列中，消费者也就是接收客户端从保存了消息的队列中提取消息，队列的好处就是保证每条消息都会被消费，并且只会被一个消费者消费一次。...以下是常见的JMS提供者程序列表 Amazon SQS's Java Messaging Library Apache ActiveMQ Apache Qpid, using AMQP IBM MQ JBoss...No.3 消息体（Message Body）在消息体中，JMS API定义了五种消息体格式，它们也被称为消息类型，允许以多种不同的形式发送和接收数据，并提供与现有消息格式的兼容性。...它基本上由从JMS发送者发送到接收者的实际消息组成。不同的消息类型有: 文本消息:由javax.jms.TextMessage表示。它用于表示一个文本块。...No2.应用解耦订单和库存系统是两个相爱相杀的系统，订单创建离不开库存操作，如果订单系统直接调用库存系统那么势必造成模块间的强耦合，导致系统复用性、健壮性变低，使用了消息中间件后关系发生了如下变化。

6562 0

ActiveMQ基础学习简单记录

---- JMS Message Type JMS的消息类型支持以下几种：消息类型适用场景通信机制消息传递模型 TextMessage 传递文本消息 String XML JSON 同步或异步...,下面我们来看一下如何创建并发送不同类型的消息: 发布一条不含有任何消息内容的异常文本消息 – 不含有有效负载的简单通知，仅包含JSM消息头和消息属性，用于事件通知 public Message...JMS允许应用程序发送和接收消息，这些消息可以是文本消息、字节消息或对象消息，可以在同步或异步模式下进行发送和接收。...过程中出现异常，会导致此消息也不会redelivery,即"潜在的消息丢失"；如果开启了optimizeACK，则会在unAck数量达到prefetch * 0.65时确认，当然我们可以指定prefetchSize...try-catch,就有可能会因为异常而导致消息重复接收的问题,需要注意你的onMessage方法中逻辑是否能够兼容对重复消息的判断。

1.6K8 0

您找到你想要的搜索结果了吗？

是的

没有找到

一个高性能、轻量级的分布式内存队列系统--beanstalk

我之前在乐视用的是apache的qpid。但是之所以各个系统都在流行，还要看其侧重点。其中ActiveMQ可以称之为传统型，它们完全支持JMS和AMQP规范。...它是Java平台上有关面向消息中间件（Message Oriented Middleware,缩写为MOM）的技术规范，它便于消息系统中的Java应用程序进行消息交换，并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发...JMS对象模型包含：连接工厂、JMS连接、JMS会话、JMS目的、JMS生产者和消费者和JMS消息。...这两者之间的区别就是点对点模式是生产者发送一条消息到queue，一个queue可以有很多消费者，但是一个消息智能被一个消费者接收，当没有消费者可用时，这个消息会被保存直到有一个可用的消费者，所以queue...所以现在的消息队列系统支持AMQP的多，支持JMS的少。 AMQP的特征是面向消息，队列化，消息模型（和JMS一样：点对点和发布订阅），可靠性和安全性。

1.8K9 0

Spring JMS---三种消息监听器

，所以这里可以直接进行强制转换，或者直接把onMessage方法的参数改成Message的子类TextMessage TextMessage textMsg = (TextMessage...) message; System.out.println("接收到一个纯文本消息。")...在onMessage方法中ConsumerSessionAwareMessageListener就是简单的把接收到的纯文本信息的内容打印出来了，之后再往queueDestination发送了一个纯文本消息...MessageListenerAdapter会把接收到的消息做如下转换： TextMessage转换为String对象； BytesMessage转换为byte数组；...System.out.println("ConsumerListener通过receiveMessage接收到一个纯文本消息，消息内容是：" + message);

2.5K1 0

一个高性能、轻量级的分布式内存队列系统--beanstalk

我之前在乐视用的是apache的qpid。但是之所以各个系统都在流行，还要看其侧重点。　　其中ActiveMQ可以称之为传统型，它们完全支持JMS和AMQP规范。　　...它是Java平台上有关面向消息中间件（Message Oriented Middleware,缩写为MOM）的技术规范，它便于消息系统中的Java应用程序进行消息交换，并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发...JMS对象模型包含：连接工厂、JMS连接、JMS会话、JMS目的、JMS生产者和消费者和JMS消息。...这两者之间的区别就是点对点模式是生产者发送一条消息到queue，一个queue可以有很多消费者，但是一个消息只能被一个消费者接收，当没有消费者可用时，这个消息会被保存直到有一个可用的消费者，所以queue...所以现在的消息队列系统支持AMQP的多，支持JMS的少。　　AMQP的特征是面向消息，队列化，消息模型（和JMS一样：点对点和发布订阅），可靠性和安全性。

1.1K2 0

MQ消息中间件（工作+面试）

AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。 AMQP在消息提供者和客户端的行为进行了强制规定，使得不同卖商之间真正实现了互操作能力。...2）Apache Qpid Apache的开源项目，支持C++、Ruby、Java、JMS、Python和.NET。...JMS协议介绍 JMS（Java Messaging Service）是Java平台上有关面向消息中间件的技术规范，它便于消息系统中的Java应用程序进行消息交换,并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发...，面向消息的中间件)设计的简单文本协议。...消息队列可驻留在内存或磁盘上,队列存储消息直到它们被应用程序读走。通过消息队列，应用程序可独立地执行--它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序接收此消息。

2.5K7 0

ActiveMQ进阶学习

介绍知识点包括spring，jms，activemq基于配置文件模式管理消息，消息监听器类型，消息转换类介绍，spring对JMS事物管理。...，所以这里可以直接进行强制转换，或者直接把onMessage方法的参数改成Message的子类TextMessage TextMessage textMsg = (TextMessage) message...; System.out.println("接收到一个纯文本消息。")...MessageListenerAdapter会把接收到的消息做如下转换： TextMessage转换为String对象； BytesMessage转换为byte数组； MapMessage转换为Map对象...Message对象转换成对应的目标对象，这主要是用在接收消息的时候。

1.1K6 0

离线数据推送问题(消息队列)

问题1：队列满了之后尝试了几次后close，只能靠人工重启重置连接的问题　　解决方法：找到几个关键的异常点 Caused by: org.apache.qpid.transport.SessionException...: session closed Caused by: javax.jms.JMSException: Exception when sending message:session closed 异常刚开始的日志...定位到刚开始异常的行： ? 找到异常前后的日志： ?...org.springframework.jms.connection.CachingConnectionFactory的源码里看到reconnectOnException默认是true，也就是说抛出了这个...Jms异常理论上是会新建的，除非新建不成功，不成功是因为SwiftSendMsgTask的新建数量太多，超过了设定的<property name="sessionCacheSize" value="700

1.3K2 0

Spring Boot整合ActiveMQ

这个场景中用到的异步消息服务，也是本文介绍的主要内容，本文将介绍Spring Boot整合基于JMS服务规范的ActiveMQ，实现异步消息服务。...对于消息的发送，调用的是jmsTemplate的convertAndSend方法，这个方法涉及到两点，一个是转换，另一个是发送，对于转换，默认情况下，jmsTemplate会提供一个SimpleMessageConverter...去提供转换规则，它是一个简单的文本消息转换器，能很方便地处理文本消息，根据项目需要，还可以使用序列化消息转换器（SerializerMessageConverter）或者Json消息转换器（Jackson2JsonMessageConverter...验证简单消息发送这里写一个Controller，检验一下从前端传递过来的数据的发送与接收情况。...，也就是User的实体类对象转换后的json数据，但是观察控制台，却发现发生了异常，原因是消息消费者抛出了一个异常。

1.5K2 0

RabbitMQ01-入门介绍

而不是 API 规范（例如 JMS ）。...现在的市面上有很多MQ可以选择，比如ActiveMQ、ZeroMQ、Appche Qpid，那问题来了为什么要选择RabbitMQ？...除了Qpid，RabbitMQ是唯一一个实现了AMQP标准的消息服务器；可靠性，RabbitMQ的持久化支持，保证了消息的稳定性；高并发，RabbitMQ使用了Erlang开发语言，Erlang...多个生产者可以将消息发送到同一个队列中，多个消息者也可以只从同一个队列接收数据。...* @author: 波波烤鸭 * @create: 2019-05-21 23:26 */ @Component public class Receiver { /** * 接收消息的方法

4645 0

spring 整合 ActiveMQ

1.1 JMS简介 JMS即Java Message Service，Java消息服务。主要用于在生产者和消费者之间进行消息传递，生产者负责产生消息，而消费者负责接收消息。...-- Spring提供的JMS工具类，它可以进行消息发送、接收等 --> 2 jms.core.JmsTemplate...10 public void onMessage(Message message) { 11 //这里我们知道生产者发送的就是一个纯文本消息，所以这里可以直接进行强制转换 12...TextMessage textMsg = (TextMessage) message; 13 System.out.println("接收到一个纯文本消息。")...-- Spring提供的JMS工具类，它可以进行消息发送、接收等 --> 15 jms.core.JmsTemplate

4674 0

干货 | JAVA反序列化安全实例解析

什么是序列化序列化 (Serialization)是指将对象的状态信息转换为可以存储或传输的形式的过程。在序列化期间，对象将其当前状态写入到临时或持久性存储区。...简单来说：序列化：将数据结构或对象转换成二进制串的过程。反序列化：将在序列化过程中所生成的二进制串转换成数据结构或者对象的过程。 ?...String obj2 =(String)ois.readObject(); ois.close(); } 反序列化漏洞原理反序列化漏洞的本质就是反序列化机制打破了数据和对象的边界，导致攻击者注入的恶意序列化数据在反序列化过程中被还原成对象...受到影响的消息系统如下： Apache ActiveMQ 5.12.0 and earlier HornetQ 2.4.0 and earlier Oracle OpenMQ 5.1 and earlier...Apache ActiveMQ Artemis client 1.2.0 and earlier Apache Qpid JMS client 0.9.0 and earlier Amazon SQS

1.3K10 0

消息队列的过去、现在和未来

导致很多大企业同时用了多个 MQ 供应商的产品，彼此却无法打通。例如，应用已经订阅了 TIBCO MQ 消息，若需要消费来自 IBM MQ 的消息，则实现起来会非常困难。...但是为了提高消息的质量，RocketMQ 并没有采用消息批量发送和接收的方式，而是单条发、单条收。...第三个问题是 Serverless 需要处理大量的云事件，在传输的过程中可能需要对这些事件进行过滤、转换等处理，而目前主流消息队列处理能力比较弱。...如果想更好的支持 Serverless 场景，从上面分析看，未来的消息系统需要应该具备以下的特点： · 原生支持 HTTP 协议，消息的接收采用 push 模式，push 模式可以直接将消息推送给 Serverless...这导致的结果是企业采用了 EventBrigde 本来是想完成应用之间消息的互通，但却被困在 EventBrigde 中。历史总是惊人的相似，这与 AMQP 协议出现之前的场景非常类似。

1.7K2 0

《Spring实战》摘录 - 25

251 Q: #17.2.2-1 | Spring的JmsTemplate会捕获标准的JMSException异常，再以Spring的非检查型异常JmsException子类重新抛出。...，（所有的消息转换器都位于org.springframework.jms.support.converter包中） A: MappingJacksonMessageConverter --- 使用Jackson...JSON库实现消息与JSON格式之间的相互转换。...catch (JMSException jmsException) { throw JmsUtils.convertJmsAccessException(jmsException); //抛出转换后的异常...} } 使用JmsTemplate从主题或队列中接收消息的时候，只需要简单地调用receive()方法。

5022 0

Java消息服务-JMS 确认和事务【面试+工作】

，直到从消息服务器接收到一个确认为止；底层确认对客户端编程模型来说是不可见的，如果在操作期间发生故障，就会抛出一个异常，同时认为该消息没有被传送；消息服务器接收到消息，如果是持久性消息就会持久化到磁盘，...上图中可能出现的异常 1.1.1.发送消息失败可能由于网络原因导致发送消息失败，服务器没有感知，需要生产者做好异常检测或者重发机制； 1.1.2.持久化失败生产者成功发送消息给服务器，服务器在持久化时失败...，服务器会在通知的时候，把错误信息返回给生产者，需要生产者做好异常检测； 1.1.3.服务器通知生产者失败成功接收消息和持久化，在通知生产者时，出现网络异常导致失败，服务器会将此消息删除，生产者会从阻塞中返回并抛出异常...但是在处理完之后，通知服务器失败，导致服务器没有被删除，消息会被重发，消费者要做好幂等性处理； 1.2.3.删除持久化失败消费者成功接收到消息，服务器成功接收通知信息，在删除持久化数据时失败，导致数据没有被删除...在发送消息的时候，可以指定一个超时时间，在指定时间内没有接收到服务器的通知消息，直接认为获取通知信息失败，抛出超时异常；正常情况下，生产者会接收到Response，此类中有方法isException()

9413 0

JAVA消息确认机制之ACK模式

对于broker而言，只有接收到ACK指令,才会认为消息被正确的接收或者处理成功了,通过ACK，可以在consumer（/producer）与Broker之间建立一种简单的“担保”机制. ...，如果onMessage方法异常，会导致消息不能被ACK，会触发重发。...择机确认"似乎充满了不确定性,这也意味着,开发者必须明确知道"择机确认"的具体时机,否则将有可能导致消息的丢失,或者消息的重复接收.那么在ActiveMQ中,AUTO_ACKNOWLEDGE是如何运作的呢...过程中出现异常，会导致此消息也不会redelivery,即"潜在的消息丢失"；如果开启了optimizeACK，则会在unAck数量达到prefetch * 0.65时确认，当然我们可以指定prefetchSize...try-catch,就有可能会因为异常而导致消息重复接收的问题,需要注意你的onMessage方法中逻辑是否能够兼容对重复消息的判断。

1.4K3 0

Spring消息之JMS.

毫无疑问，消息代理这个东西是多出来的，需要维护成本。暂时的不一致性。异步消息方式可以确保最终的一致性，但是可能存在客户端把消息给了消息队列，而服务端暂时还没处理这个队列导致的暂时不一致性问题。...另外，JmsTemplate可以处理所有抛出的笨拙的JMSException异常。接收消息功能，原因是消息转换器！...发送时，JmsTemplate 先把消息内容转换成对应Message；接收时，JmsTemplate 再把对应Message 转换回消息内容。JmsTemplate 定义了多个消息转换器。...如上，我用了 SimpleMessageConverter 转换器，也就是 JmsTemplate 中默认使用的转换器（不设置用的就是这个转换器）。如果需要，还可自定义转换器呢！ ?

1K5 0

常见消息中间件大 PK

几种协议先来说说消息中间件中常见的几个协议。 1.1 JMS 1.1.1 JMS 介绍先来说说 JMS。...在发布者和订阅者之间存在时间依赖性，发布者需要创建一个订阅（subscription），以便客户能够订阅；订阅者必须保持在线状态以接收消息；当然，如果订阅者创建了持久的订阅，那么在订阅者未连接时，消息生产者发布的消息将会在订阅者重新连接时重新发布...在 AMQP 协议中，消息收发涉及到如下一些概念： Broker: 接收和分发消息的应用，我们日常所用的 RabbitMQ 就是一个 Message Broker。...Apache Qpid Apache ActiveMQ RabbitMQ 可能有小伙伴奇怪咋还有 ActiveMQ？其实 ActiveMQ 不仅支持 JMS，也支持 AMQP，这个松哥后面细说。...批量处理的算法：对于批量的消息，进行了适应性的优化，可以批量的接收和发送消息。

1K1 0

消息队列——ActiveMQ使用及原理浅析

产生背景一开始消息中间件的厂商繁多，且各个厂商之间没有统一的规范，这就导致了各消息中间件非常难以整合协作，因此，后来陆续出现了如JMS和AMQP这样的消息队列规范，提供了统一的标准，而ActiveMQ...在设计JMS时，设计师就计划能够结合现有消息队列的优点，如：不同的消息传送模式或域，例如点对点消息传送和发布/订阅消息传送支持同步和异步消息支持可靠性消息的传输支持常见的消息格式，如：文本、字节...该模式可优化消费者确认消息的性能，但可能会导致消费者收到重复消息（这个参数在优化一节中还会详细讲解）。...刚刚我们提到消息消费失败会导致消息重发，那究竟在哪些情况下会被重发呢？...同时，该方案需要消费端能够容忍重复消息，因为当消息还未确认时消费者就怠机了，那么broker就会将该消息重发给其它消费者，导致消息重复。

3.9K2 1

通信协议详解

你用的工具可能已经自动帮你完成了这个转换，但你很可能会根据你的需要修改一下转换过程。...（2）SOAP WebService通过HTTP协议发送请求和接收结果时，发送的请求内容和结果内容都采用XML格式封装，并增加了一些特定的HTTP消息头，以说明HTTP消息的内容格式，这些特定的HTTP...2.8 JMS (Java Message Service) JMS (Java Message Service)，JAVA 消息服务，这是JAVA 平台中著名的消息队列协议。...JMS 能够通过消息收发服务(有时称为消息中介程序或路由器)从一个JMS 客户机向另一个JMS 客户机发送消息。消息是JMS 中的一种类型对象，由两部分组成：报头和消息主体。...根据有效负载的类型来划分，可以将消息分为几种类型，它们分别携带：简单文本(TextMessage)、可序列化的对象(ObjectMessage)、属性集合(MapMessage)、字节流(BytesMessage

2.5K2 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭