如何在Spring Boot @MessageMapping Controller中获取有效负载(io.rsocket.Payload)

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

@Controller
public class RSocketController {

    @MessageMapping("yourMapping")
    public Mono<Void> handlePayload(Payload payload) {
        // 处理有效负载
        // ...
        return Mono.empty();
    }
}

@Controller
public class RSocketController {

    @MessageMapping("yourMapping")
    public Mono<Void> handlePayload(Payload payload) {
        byte[] data = new byte[payload.data().readableBytes()];
        payload.data().readBytes(data);
        
        String payloadString = new String(data, StandardCharsets.UTF_8);
        // 或者将字节数组转换为其他数据类型
        // ...
        
        // 处理有效负载
        // ...
        
        return Mono.empty();
    }
}

@Controller
public class RSocketController {

    @MessageMapping("yourMapping")
    public Mono<Void> handlePayload(Payload payload) {
        byte[] data = new byte[payload.data().readableBytes()];
        payload.data().readBytes(data);
        
        String payloadString = new String(data, StandardCharsets.UTF_8);
        
        String metadata = payload.getMetadataUtf8();
        // 处理元数据
        // ...
        
        // 处理有效负载
        // ...
        
        return Mono.empty();
    }
}