Spring-messaging-Message接口/环境依赖

参考文档1：https://docs.spring.io/spring-integration/reference/index.html
参考文档2：https://www.jackssybin.cn/articles/2021/03/16/1615897840354.html#b3_solo_h4_44

环境配置

由于我使用的是spring boot，所以只有一个依赖，如下

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-integration</artifactId>
</dependency>

创建Message实例对象

消息的传递是通过Message接口的实例传递的，Message包含两部分，一个header，一个payload，其中header包含消息的元数据，比如时间戳什么的，payload就是我们自己的业务数据，我们自己愿意放什么就放什么，下面的代码创建了一个Message接口的实例

import org.springframework.messaging.Message;
import org.springframework.messaging.support.GenericMessage;public static void main(String[] args) {String payload = "见一面，少一面";Message<String> message = new GenericMessage<>(payload);System.out.println("消息内容: " + message.getPayload());// 也可以自定义头部元数据Map<String, Object> headerMap = new HashMap<>();headerMap.put("key1", "value1");Message<String> message2 = new GenericMessage<>(payload,new MessageHeaders(headerMap));System.out.println("消息内容: " + message2.getPayload());System.out.println("消息头部: " + message2.getHeaders());
}

Message接口最常用的实现类就是GenericMessage，所以本文到这里就结束了