如何通过Spring Integration无需物理文件向Multipart API发送数据

问题1：无需创建物理文件，生成文件对象并发送至目标API #

完全可以实现，直接在内存中构建符合MultipartFile规范的对象即可，结合Spring Integration流程和HTTP客户端完成发送：

1. 处理聚合后的消息：聚合器输出按fileName分组的消息集合（如List<String>），先将这些内容拼接成完整的文件文本（比如每行一条数据）。
2. 构建内存文件对象：使用Spring提供的MockMultipartFile（生产环境可直接使用），基于字节数组创建虚拟文件：

// 假设聚合后的payload是List<String>，拼接为换行分隔的文本
String fileContent = String.join("\n", aggregatedMessages);
byte[] contentBytes = fileContent.getBytes(StandardCharsets.UTF_8);
// 从消息头获取文件名，匹配目标API的参数名
MultipartFile multipartFile = new MockMultipartFile(
    "file",
    message.getHeaders().get("fileName", String.class),
    "text/plain",
    contentBytes
);

3. 发送至目标API：用RestTemplate或Spring Integration的HTTP出站网关实现：

HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.MULTIPART_FORM_DATA);
MultiValueMap<String, Object> requestBody = new LinkedMultiValueMap<>();
requestBody.add("file", multipartFile);
HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(requestBody, headers);
restTemplate.postForEntity("http://目标服务地址/receiveFile", requestEntity, String.class);

将上述逻辑封装为ServiceActivator，接入聚合器之后的通道即可完成流程整合。

问题2：指定时间触发时段内批量数据的发送 #

需要结合时段数据存储和定时触发来实现：

1. 存储时段内的消息：

   • 调整原有流程，轮询到的消息不直接进入聚合器，而是存入MessageStore（如SimpleMessageStore或JDBC实现的JdbcMessageStore），并通过消息头标记所属时段（比如添加timeWindow头，值为"8-20"），后续按该头分组存储。

2. 定时触发发送任务：

   • 用Spring的@Scheduled注解创建定时任务，比如每天20:00触发发送：

@Scheduled(cron = "0 0 20 * * ?")
public void sendDailyTimeWindowData() {
    // 从MessageStore取出8:00-20:00的消息，按fileName分组
    Map<String, List<Message<String>>> groupedMessages = fetchMessagesByTimeWindow("8-20");
    for (Map.Entry<String, List<Message<String>>> entry : groupedMessages.entrySet()) {
        String fileName = entry.getKey();
        List<String> contentList = entry.getValue().stream()
            .map(Message::getPayload)
            .collect(Collectors.toList());
        // 复用问题1的文件构建和发送逻辑
        sendAsMultipartFile(contentList, fileName);
    }
    // 发送完成后清理该时段的历史消息
    clearMessagesByTimeWindow("8-20");
}

• 也可使用Spring Integration的CronTrigger结合入站通道适配器实现定时触发，启动聚合和发送流程。

内容的提问来源于stack exchange，提问作者Nichole