camel+minio实现预签名URL上传

// For the generate Pre signed Url route
from(direct("createUploadLink"))
        .to(minio(CamelConst.BUCKET_TEMPLATE).operation(MinioOperations.createUploadLink));

import cn.hutool.core.io.IoUtil;
import cn.hutool.core.util.URLUtil;
import cn.hutool.http.HttpUtil;
import cn.hutool.http.Method;
import io.minio.GetObjectResponse;
import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.component.minio.MinioComponent;
import org.apache.camel.component.minio.MinioConstants;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.io.IOException;
import java.time.Duration;
import java.time.temporal.ChronoUnit;
import java.util.Map;

@Test
void testGeneratePresignedUrl() throws IOException {
    var presignedUrl = producerTemplate.requestBodyAndHeaders("direct:createUploadLink", "",
            Map.of(MinioConstants.BUCKET_NAME, "testbucket",
                    MinioConstants.OBJECT_NAME, "test.txt",
                    MinioConstants.PRESIGNED_URL_EXPIRATION_TIME, Duration.of(1, ChronoUnit.DAYS)));
    Assertions.assertNotNull(presignedUrl);
    var content = "Hello, Minio! Again!";
    try (var response = HttpUtil.createRequest(Method.PUT, presignedUrl.toString())
            .body(content, "application/octet-stream").execute()) {
        Assertions.assertTrue(response.isOk());
    }
    var minio = (MinioComponent) camelContext.getComponent("minio");
    Assertions.assertEquals(content,
            IoUtil.readUtf8(URLUtil.url(minio.getConfiguration().getEndpoint() + "/testbucket/test.txt").openStream()));
}