Sprint AI 并不是孤立存在它Ke以与 Spring Cloud Stream 的管道无缝衔接。下面演示一种常见场景：前端发送 HTTP 请求 → Spring MVC 接收 → 把请求包装成带有业务标签的 UserMessage → 推送到 RabbitMQ → 消费端取出并继续对话。

    org.springframework.boot
    spring-boot-starter-cloud-stream


    org.springframework.cloud
    spring-cloud-starter-stream-rabbit


    org.springframework.ai
    spring-ai-spring-boot-starter
    1.1.0

@Configuration
@EnableBinding   // 自动装配绑定通道
public class StreamConfig {
    @Bean
    public RabbitProperties rabbitProperties {
        return new RabbitProperties;   // 自动读取 application.yml 中 rabbit.* 配置
    }
}
interface MyChannels {
    @Output
    MessageChannel outbound;
    @Input
    SubscribableChannel inbound;
}

@RestController
@RequiredArgsConstructor
public class ChatController {
    private final MessageChannel outbound;
    @PostMapping
    public ResponseEntity chat {
        // 构造带业务上下文的 UserMessage
        UserMessage userMsg = UserMessage.from)
                                         .metadata(Map.of(
                                             "requestId", UUID.randomUUID.toString,
                                             "tenantId", req.getTenant,
                                             "originIp", req.getRemoteAddr));
        // 包装成 Spring Messaging Message 并投递到 RabbitMQ
        outbound.send.build);
        return ResponseEntity.accepted.body;
     }
}

@Component
@RequiredArgsConstructor
public class ChatConsumer {
   private final ChatClient chatClient;
   @StreamListener
   public void handle {
       // 打印一下携带过来的全部 metadata，以便排查问题
       System.out.println);
       String reply = chatClient.prompt
               .user)
                         .metadata))   // 原封不动转发过去
               .call
               .content;
       // TODO：将 reply 再回传至前端或持久化...
   }
}

🔎 小经验：RabbitMQ 本身只负责字节流，Ru果想保留原始结构，需要让序列化器使用 Jackson，并确保 `@JsonTypeInfo` 注解Yi经标记好抽象基类，否则消费端可Neng只Neng收到字符串而失去类型信息。