Caused by: java.lang.NullPointerException: Cannot invoke "org.springframework.messaging.Message.getHeaders()" because "message" is null
at org.springframework.messaging.support.MessageHeaderAccessor.getAccessor(MessageHeaderAccessor.java:587)
at org.springframework.cloud.sleuth.instrument.messaging.TraceMessageHandler.mutableHeaderAccessor(TraceMessageHandler.java:297)
at org.springframework.cloud.sleuth.instrument.messaging.TraceMessageHandler.wrapInputMessage(TraceMessageHandler.java:136)
at org.springframework.cloud.sleuth.instrument.messaging.TraceFunctionAroundWrapper.doApply(TraceFunctionAroundWrapper.java:76)
at org.springframework.cloud.function.context.catalog.FunctionAroundWrapper.apply(FunctionAroundWrapper.java:47)
at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$1.doApply(SimpleFunctionRegistry.java:256)
at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.apply(SimpleFunctionRegistry.java:550)
at org.springframework.cloud.function.context.catalog.SimpleFunctionRegistry$FunctionInvocationWrapper.get(SimpleFunctionRegistry.java:561)
at org.springframework.cloud.stream.function.PartitionAwareFunctionWrapper.get(PartitionAwareFunctionWrapper.java:83)
at jdk.internal.reflect.GeneratedMethodAccessor173.invoke(Unknown Source)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.springframework.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:282)
at org.springframework.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:266)
at org.springframework.integration.endpoint.MethodInvokingMessageSource.doReceive(MethodInvokingMessageSource.java:113)
... 17 more
解决方法：
spring:
cloud:
stream:
function:
autodetect: false
赠送jar包：spring-messaging-4.3.20.RELEASE.jar；
赠送原API文档：spring-messaging-4.3.20.RELEASE-javadoc.jar；
赠送源代码：spring-messaging-4.3.20.RELEASE-sources.jar；
包含翻译后的API文档：spring-messaging-4.3.20.RELEASE-javadoc-API文档-中文(简体)版.zip
对应Maven信息：groupId：org.springframework，artifactId：spring-messaging，version：4.3.20.RELEASE
使用方法：解压翻译后的API文档，用浏览器打开“index.html”文件，即可纵览文档内容。
人性化翻译，文档中的代码和结构保持不变，注释和说明精准翻译，请放心使用。
以下异常使用的是spring是3.1.1，是我自己学习中遇到的错误笔记，有可能不是都适用，仅做参考
异常1：java.lang.NoClassDefFoundError: org/apache/commons/logging/LogFactory
缺少包commons-logging的jar，本人下载了一个commons-logging-1.1.1.jar，引入，问题解决，下载地址点击打开链接
Message<Mdds> message = MessageBuilder.withPayload(mdds).build();
// 延迟第3级发送（延迟10秒）
rocketMQTemplate.syncSend(MessageConstant.TOPIC_ORDER, message, 1000, 3)
历尽千辛万坑、终于把RocketMQ起起来–Broker无法启动，本以为万事大吉了，直接跑起项目，结果忽如一夜春风来、野火把梨花烧尽了。
一看报错信息是timeout，就差RocketMQ的超时配置，然而并没有用。那么只能使用完成的google/百度大法了。然后一看、结论就是一层窗户纸，不知道就全是坑。
二、完整异常
Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [
Spring Integration提供了Spring框架的扩展，以支持著名的企业集成模式。 它在基于Spring的应用程序中启用轻量级消息传递，并支持与外部系统的集成。 Spring Integration的最重要目标之一是为构建可维护且可测试的企业集成解决方案提供一个简单的模型。
消息：它是任何Java对象的通用包装，这些对象与框架在处理该对象时使用的元数据结合在一起。 它...
在使用rocketmq消息中间件发送消息的时候,会出现标题这种错误。
其实意思很明显,就是提示我们中间件中不存在queue_test这个topic。
所以我们应该先创建这个topic。
我们可以使用这种可视化工具
先添加queue_test这个topic,发现在进行发送消息时,就不会发生这个异常。
这辈子坚持与不坚持都不可怕,怕的是独自走在坚持的道路上。。。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
2. RabbitMQ配置
Spring
Caused by: org.springframework.messaging.MessagingException: Exception thrown while invoking com.mmtvip.frontprovider.mq.ReceiverServer#receiveR00001[1 args]; nested exception is java.lang.Ille...
第一步：首先来到rocketmq目录下，修改conf文件夹下broker.conf 文件当中的配置。第二步：如果正在运行mqnamesvr还有mqbroker的话，需要先shutdown它们。启动broker时，需用-c conf/broker.conf，读取配置文件。第三步：重新运行mqnamesvr和mqbroker。需修改broker.conf，设置公网IP。需要开放10911、10909这两个端口。
org.springframework.messaging.converter.MessageConversionException: Could not read JSON: Cannot construct instance of `com.example.mqtest.mq.User` (although at least one Creator exists): cannot deser...
