Spring Boot中通过URL传输Cloud Event

核心问题在于Cloud Event的序列化/反序列化配置以及请求头的正确设置，以下是两种可行的实现方式：

方法一：基于Spring Cloud OpenFeign实现 #

1. 引入依赖 #

确保项目中包含Spring Cloud OpenFeign和CloudEvent的Spring Boot集成依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
    <groupId>io.cloudevents</groupId>
    <artifactId>cloudevents-spring-boot-starter</artifactId>
</dependency>

2. 定义Feign Client #

指定正确的请求ContentType，并直接使用CloudEvent作为请求体参数：

@FeignClient(name = "cloudEventSender", url = "${event.target.url}")
public interface CloudEventFeignClient {

    @PostMapping(value = "/event/endpoint", consumes = "application/cloudevents+json")
    ResponseEntity<Void> sendBinaryDataEvent(@RequestBody CloudEvent cloudEvent);
}

3. 配置Feign消息转换器 #

确保Feign使用Spring的消息转换器来处理CloudEvent的序列化：

@Configuration
public class FeignConfig {
    @Bean
    public Encoder feignEncoder(ObjectFactory<HttpMessageConverters> messageConverters) {
        return new SpringEncoder(messageConverters);
    }

    @Bean
    public Decoder feignDecoder(ObjectFactory<HttpMessageConverters> messageConverters) {
        return new SpringDecoder(messageConverters);
    }
}

方法二：基于RestTemplate实现 #

1. 配置RestTemplate #

添加CloudEvent专用的消息转换器，确保字节数据能正确序列化：

@Bean
public RestTemplate cloudEventRestTemplate() {
    RestTemplate restTemplate = new RestTemplate();
    restTemplate.getMessageConverters().add(new CloudEventHttpMessageConverter());
    return restTemplate;
}

2. 构造并发送Cloud Event #

手动构建带字节数据的CloudEvent，并设置正确的请求头：

@Autowired
private RestTemplate cloudEventRestTemplate;

public void sendEvent(byte[] binaryData, String targetUrl) {
    // 构建含字节数据的CloudEvent
    CloudEvent event = CloudEventBuilder.v1()
            .withId(UUID.randomUUID().toString())
            .withType("com.example.binary.event")
            .withSource(URI.create("/app/source"))
            .withData(binaryData)
            .withDataContentType(MediaType.APPLICATION_OCTET_STREAM)
            .build();

    // 构造请求实体
    HttpHeaders headers = new HttpHeaders();
    headers.setContentType(MediaType.parseMediaType("application/cloudevents+json"));
    HttpEntity<CloudEvent> requestEntity = new HttpEntity<>(event, headers);

    // 发送请求
    cloudEventRestTemplate.exchange(
            targetUrl + "/event/endpoint",
            HttpMethod.POST,
            requestEntity,
            Void.class
    );
}

关键注意事项 #

• 必须引入cloudevents-spring-boot-starter，它提供了Spring生态与CloudEvent标准的适配，自动处理消息格式转换，和Quarkus的@RegisterRestClient功能类似。
• 确保CloudEvent的datacontenttype字段与实际字节数据类型匹配（比如二进制数据设为application/octet-stream）。
• Feign Client必须显式指定consumes属性为application/cloudevents+json，避免序列化错误。

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