首页 > 其他分享 >SpringBoot集成亚马逊的S3对象存储

SpringBoot集成亚马逊的S3对象存储

时间:2024-03-06 14:58:59浏览次数:23  
标签:String S3 param 亚马逊 keyName bucketName key 上传 SpringBoot

依赖导入:aws-java-sdk-s3

<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.amazonaws</groupId>
                <artifactId>aws-java-sdk-bom</artifactId>
                <version>1.12.642</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
</dependencyManagement>
<dependencies>
        <dependency>
            <groupId>com.amazonaws</groupId>
            <artifactId>aws-java-sdk-s3</artifactId>
        </dependency>
</dependencies>
	

组装好客户端-Service |EdsOssFileUploadService

public interface EdsOssFileUploadService {

    /**
     * 高级API大文件分片上传
     * @param keyName 唯一文件标识
     * @param file file
     * @return keyName 唯一文件标识
     * @throws InterruptedException
     */
    String highLevelMultipartUpload(String keyName, File file) throws InterruptedException;


    /**
     * 文件分片上传
     * @param keyName 唯一文件标识
     * @param bucketName 桶名称
     * @param file file
     * @return CompleteMultipartUploadResult
     */
    CompleteMultipartUploadResult bigFileListShardingUpload(String keyName, String bucketName, File file);


    /**
     * 文件分片上传
     * @param keyName 唯一文件标识
     * @param file file
     * @return CompleteMultipartUploadResult
     */
    CompleteMultipartUploadResult bigFileListShardingUpload(String keyName, File file);


    /**
     *  文件分片上传 指定桶
     * @param bucketName 桶名称
     * @param fileInputStream 文件流
     * @param fileContentLength  原始文件的length
     * @param keyName 唯一文件标识
     * @return CompleteMultipartUploadResult
     */
    CompleteMultipartUploadResult uploadLargeFileToS3(String bucketName, FileInputStream fileInputStream, long fileContentLength, String keyName);


    /**
     *  文件分片上传 默认桶
     * @param fileInputStream 文件流
     * @param fileLength 原始文件的length
     * @param key 唯一文件标识
     * @return CompleteMultipartUploadResult
     */
    CompleteMultipartUploadResult uploadLargeFileToS3(FileInputStream fileInputStream, long fileLength, String key);

    /**
     * 文件下载
     * @param key 唯一文件标识
     * @param bucketName  桶名称
     * @return InputStream
     */
    InputStream downloadToEDS(String key, String bucketName);


    /**
     * 文件下载  默认桶
     * @param key 唯一文件标识
     * @return InputStream
     */
    InputStream downloadToEDS(String key);


    /**
     * 简单文件上传 --流 指定桶
     * @param keyName 唯一文件标识
     * @param inputStream 文件流
     * @param bucketName 桶名称
     * @return PutObjectResult
     */
    PutObjectResult streamUploadToEDS(String keyName, InputStream inputStream, String bucketName);


    /**
     * 简单文件上传 --流 默认桶
     * @param keyName 唯一文件标识
     * @param inputStream 文件流
     * @return PutObjectResult
     */
    PutObjectResult streamUploadToEDS(String keyName, InputStream inputStream);


    /**
     *  简单文件上传 --file 指定桶
     * @param keyName 唯一文件标识
     * @param file 文件
     * @param bucketName 桶名称
     * @return PutObjectResult
     */
    PutObjectResult simpleUploadToEDS(String keyName, File file, String bucketName);


    /**
     *  简单文件上传 --file 默认桶
     * @param keyName 唯一文件标识
     * @param file 文件
     * @return PutObjectResult
     */
    PutObjectResult simpleUploadToEDS(String keyName, File file);

    /**
     * 创建文件上传的预签名--URL
     * @param bucketName 桶名称
     * @param keyName 唯一文件标识
     * @return URL
     */
    URL createSignedUrlForStringPut(String bucketName, String keyName);

    /**
     * 创建文件下载的预签名--URL
     * @param bucketName 桶名称
     * @param keyName 唯一文件标识
     * @return URL
     */
    URL createSignedUrlForStringGet(String bucketName, String keyName);
}

组装好客户端-ServiceImpl |EdsOssFileUploadServiceImpl

@Service
public class EdsOssFileUploadServiceImpl implements EdsOssFileUploadService {
    private Logger logger = LoggerFactory.getLogger(EdsOssFileUploadServiceImpl.class);

    /**
     * 深信服EDS云对象存储用户的access key :示例L8O3KRQZTXGVDIBQ0WON
     */
    @Value("${eds.cloud.oss.accessKey:MOTNMUS8FJ8P3YTXQSB5}")
    private String accessKey;


    /**
     * 深信服EDS云对象存储用户的的secret key:示例Bm0kLoFdLu70RKTOtjdP5Q9oOVDgEXHOmbrelxeb
     */
    @Value("${eds.cloud.oss.secretKey:sOMNfGbrCP9vv3OwGyHrc3ET4OQGIt5QqHCVAMW5}")
    private String secretKey;

    /**
     * EDS对象存储的地址:对象存储服务的端口号:示例http://10.212.27.56:12001
     */
    @Value("${eds.cloud.oss.endPoint:10.1.2.16:12001}")
    private String endPoint;

    /**
     * EDS对象存储的bucket名称:示例eds-cloud-oss
     */
    @Value("${eds.cloud.oss.bucketName:digtal_resources}")
    private String bucketName;

    /**
     * EDS对象存储的region:示例cn-north-1
     */
    @Value("${eds.cloud.oss.region:}")
    private String region;

    private AmazonS3 amazonS3Client;


    private TransferManager transferManager;

    @PostConstruct
    public void init() {
        AWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey);
        ClientConfiguration clientConfig = new ClientConfiguration();
        clientConfig.setProtocol(Protocol.HTTP);
        clientConfig.setConnectionTimeout(300000);
        clientConfig.setClientExecutionTimeout(300000);
        clientConfig.setConnectionMaxIdleMillis(300000);
        // 初始化AmazonS3Client
        this.amazonS3Client = AmazonS3ClientBuilder.standard().
                withClientConfiguration(clientConfig).
                withCredentials(new AWSStaticCredentialsProvider(credentials)).
                withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration(endPoint, region)).
                build();
        this.transferManager = TransferManagerBuilder.standard().withS3Client(amazonS3Client).build();
    }


    /**
     * AWS SDK 公开了一个名为 TransferManager 的高级别 API,用于简化分段上传。有关更多信息,请参阅 使用分段上传来上传和复制对象。
     * <p>
     * 您可以从文件或流上传数据。您还可以设置高级选项,例如,您想要用于分段上传的分段大小或在上传分段时要使用的并发线程数。
     * 您也可以设置可选的对象属性、存储类或访问控制列表 (ACL)。您可以使用 PutObjectRequest 和 TransferManagerConfiguration 类来设置这些高级选项。
     *
     * @param keyName keyName
     * @param file    file
     * @return CompleteMultipartUploadResult
     */
    @Override
    public String highLevelMultipartUpload(String keyName, File file) throws InterruptedException {
        String upPrefix = UUID.randomUUID().toString();
        String key = upPrefix + "/" + keyName;
        // 使用 TransferManager 上传
        Upload upload = transferManager.upload(bucketName, key, file);
        upload.waitForCompletion();
        logger.info("Object upload complete");
        return key;
    }


    /**
     * EDS提供的分片上传(Multipart Upload)功能,将要上传的较大文件(object)分成多个分片(Part)来分别上传
     * 上传完成后再调用completeMultipartUpload接口将这些Part组合成一个object来达到断点续传的效果。
     *
     * @param keyName    keyName
     * @param bucketName yourBucketName
     * @param file       file
     * @return CompleteMultipartUploadResult
     */
    @Override
    public CompleteMultipartUploadResult bigFileListShardingUpload(String keyName, String bucketName, File file) {
        List<PartETag> partETags = new ArrayList<>();
        long filePosition = 0;
        CompleteMultipartUploadResult result = null;
        String uploadId = null;
        InitiateMultipartUploadRequest initRequest = new InitiateMultipartUploadRequest(bucketName, keyName);
        InitiateMultipartUploadResult initResponse = amazonS3Client.initiateMultipartUpload(initRequest);
        uploadId = initResponse.getUploadId();
        try {
            long contentLength = file.length();
            long partSize = 25 * 1024 * 1024; // Set part size to 25 MB.
            logger.info("-------开始只能进入分片上传阶段-------");
            for (int i = 1; filePosition < contentLength; i++) {
                partSize = Math.min(partSize, (contentLength - filePosition));
                UploadPartRequest uploadRequest = new UploadPartRequest()
                        .withBucketName(bucketName)
                        .withKey(keyName)
                        .withUploadId(uploadId)
                        .withPartNumber(i)
                        .withFileOffset(filePosition)
                        .withFile(file)
                        .withPartSize(partSize);
                UploadPartResult uploadResult = amazonS3Client.uploadPart(uploadRequest);
                // 返回文件的ETag值,用于验证文件是否被正确上传
                partETags.add(uploadResult.getPartETag());
                filePosition += partSize;
                logger.info("文件分片上传--->" + filePosition);
            }
            logger.info("-------所有分片上传完整------->进入分片合并阶段-------");
            // 完成分片上传
            CompleteMultipartUploadRequest compRequest = new CompleteMultipartUploadRequest(bucketName, keyName,
                    initResponse.getUploadId(), partETags);
            result = amazonS3Client.completeMultipartUpload(compRequest);
        } catch (SdkClientException e) {
            logger.error("分片上传错误,第{}片发生意外", filePosition, e);
            throw new RuntimeException(e);
        }
        logger.info("-------大文件分片上传完成--->" + filePosition);
        return result;
    }

    @Override
    public CompleteMultipartUploadResult bigFileListShardingUpload(String keyName, File file) {
        return bigFileListShardingUpload(keyName, bucketName, file);
    }

    /**
     * 分片上传
     *
     * @param bucketName        桶名称
     * @param fileInputStream   文件流
     * @param fileContentLength 原始文件的length
     * @param keyName           唯一文件标识
     * @return
     */
    @Override
    public CompleteMultipartUploadResult uploadLargeFileToS3(String bucketName, FileInputStream fileInputStream, long fileContentLength, String keyName) {
        InitiateMultipartUploadResult initResponse = null;
        InitiateMultipartUploadRequest initRequest = null;
        CompleteMultipartUploadResult completeMultipartUploadResult = null;
        try {
            // 初始化多部分上传
            initRequest = new InitiateMultipartUploadRequest(bucketName, keyName);
            initResponse = amazonS3Client.initiateMultipartUpload(initRequest);
            // 每个分片大小(例如:5MB)
            long partSize = 5 * 1024 * 1024;

            List<PartETag> partETags = new ArrayList<>();
            long bytePosition = 0;

            for (int i = 1; bytePosition < fileContentLength; i++) {
                long bytesRemaining = fileContentLength - bytePosition;
                partSize = Math.min(bytesRemaining, partSize);

                UploadPartRequest uploadRequest = new UploadPartRequest()
                        .withBucketName(bucketName)
                        .withKey(keyName)
                        .withUploadId(initResponse.getUploadId())
                        .withPartNumber(i)
                        .withFileOffset(bytePosition)
                        .withInputStream(fileInputStream)
                        .withPartSize(partSize);

                UploadPartResult uploadResult = amazonS3Client.uploadPart(uploadRequest);
                partETags.add(uploadResult.getPartETag());
                bytePosition += partSize;
            }
            // 完成多部分上传
            CompleteMultipartUploadRequest compRequest = new CompleteMultipartUploadRequest(
                    bucketName,
                    keyName,
                    initResponse.getUploadId(),
                    partETags);
            completeMultipartUploadResult = amazonS3Client.completeMultipartUpload(compRequest);
        } catch (SdkClientException e) {
            // 处理异常,可能需要回滚已上传的部分
            logger.error("Error uploading file to S3", e);
            // 如果有错误,尝试取消上传
            AbortMultipartUploadRequest abortMPURequest = new AbortMultipartUploadRequest(
                    bucketName,
                    keyName,
                    initResponse.getUploadId());
            amazonS3Client.abortMultipartUpload(abortMPURequest);
        } finally {
            try {
                fileInputStream.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return completeMultipartUploadResult;
    }

    @Override
    public CompleteMultipartUploadResult uploadLargeFileToS3(FileInputStream fileInputStream, long fileLength, String key) {
        return uploadLargeFileToS3(bucketName, fileInputStream, fileLength, key);
    }

    /**
     * 简单下载文件流
     *
     * @param key key
     * @return InputStream
     */
    @Override
    public InputStream downloadToEDS(String key, String bucketName) {
        logger.info("Downloading {} from S3 bucket {}...\n", key, bucketName);
        S3Object object = amazonS3Client.getObject(new GetObjectRequest(bucketName, key));
        return object.getObjectContent();
    }

    @Override
    public InputStream downloadToEDS(String key) {
        return downloadToEDS(key, bucketName);
    }


    /**
     * 流式上传文件到EDS
     *
     * @param keyName    fileName
     * @param inputStream InputStream
     * @return PutObjectResult
     */
    @Override
    public PutObjectResult streamUploadToEDS(String keyName, InputStream inputStream, String bucketName) {
        try {
            //创建上传Object的Metadata
            ObjectMetadata metadata = new ObjectMetadata();
            //上传的文件的长度
            metadata.setContentLength(inputStream.available());
            //指定该Object被下载时的网页的缓存行为
            metadata.setCacheControl("no-cache");
            //指定该Object下设置Header
            metadata.setHeader("Pragma", "no-cache");
            //指定该Object被下载时的内容编码格式
            metadata.setContentEncoding("utf-8");
            //文件的MIME,定义文件的类型及网页编码,决定浏览器将以什么形式、什么编码读取文件。如果用户没有指定则根据Key或文件名的扩展名生成,
            //如果没有扩展名则填默认值application/octet-stream
            metadata.setContentType("application/octet-stream");
            return amazonS3Client.putObject(bucketName, keyName, inputStream, metadata);
        } catch (IOException e) {
            logger.error("文件上传失败。。。。" + e.getMessage());
            throw new RuntimeException(e);
        } catch (SdkClientException e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public PutObjectResult streamUploadToEDS(String keyName, InputStream inputStream) {
        return streamUploadToEDS(keyName,inputStream,bucketName);
    }


    /**
     * 简单上传文件到EDS
     *
     * @param keyName fileName
     * @param file     file
     * @return PutObjectResult
     */
    @Override
    public PutObjectResult simpleUploadToEDS(String keyName, File file, String bucketName) {
        return amazonS3Client.putObject(bucketName, keyName, file);
    }

    @Override
    public PutObjectResult simpleUploadToEDS(String keyName, File file) {
        return amazonS3Client.putObject(bucketName, keyName, file);
    }

    /**
     * 创建文件上传的预签名--URL
     * @param bucketName 桶名称
     * @param keyName 唯一文件标识
     * @return URL
     */
    @Override
    public URL createSignedUrlForStringPut(String bucketName, String keyName) {
        Date expiration = new Date();
        long expirationNumber = expiration.getTime()+3600*1000;
        expiration.setTime(expirationNumber);
        GeneratePresignedUrlRequest generatePresignedUrlRequest = new GeneratePresignedUrlRequest(bucketName, keyName,HttpMethod.PUT);
        generatePresignedUrlRequest.setExpiration(expiration);
        return amazonS3Client.generatePresignedUrl(generatePresignedUrlRequest);
    }

    /**
     * 创建文件下载的预签名--URL
     * @param bucketName 桶名称
     * @param keyName 唯一文件标识
     * @return URL
     */
    @Override
    public URL createSignedUrlForStringGet(String bucketName, String keyName) {
        Date expiration = new Date();
        long expirationNumber = expiration.getTime()+3600*1000;
        expiration.setTime(expirationNumber);
        GeneratePresignedUrlRequest generatePresignedUrlRequest = new GeneratePresignedUrlRequest(bucketName, keyName,HttpMethod.GET);
        generatePresignedUrlRequest.setExpiration(expiration);
        return amazonS3Client.generatePresignedUrl(generatePresignedUrlRequest);
    }
}

SpringBoot测试:@SpringBootTest

@SpringBootTest(classes = FilestoreApplication.class)
@Import(EdsOssFileUploadServiceImpl.class)
public class FilestoreApplicationTest {
    private Logger logger = LoggerFactory.getLogger(FilestoreApplicationTest.class);
    @Autowired
    private EdsOssFileUploadService edsOssFileUploadService;

    /**
     * 文件上传EDS云对象存储测试:通过
     * <p>
     * 2024-03-06 14:07:03.079  INFO 15144 --- [           main] c.c.c.f.FilestoreApplicationTest         : Started FilestoreApplicationTest in 2.059 seconds (JVM running for 2.728)
     * 2024-03-06 14:07:03.270  INFO 15144 --- [           main] c.c.c.f.FilestoreApplicationTest         : 上传生成的=26438e0c-e379-4343-b645-03e8056baaf6/硬件检测.jpg
     * 2024-03-06 14:07:03.628  INFO 15144 --- [           main] c.c.c.f.a.i.EdsOssFileUploadServiceImpl  : -------开始只能进入分片上传阶段-------
     * 2024-03-06 14:07:03.918  INFO 15144 --- [           main] c.c.c.f.a.i.EdsOssFileUploadServiceImpl  : 文件分片上传--->196369
     * 2024-03-06 14:07:03.919  INFO 15144 --- [           main] c.c.c.f.a.i.EdsOssFileUploadServiceImpl  : -------所有分片上传完整------->进入分片合并阶段-------
     * 2024-03-06 14:07:03.969  INFO 15144 --- [           main] c.c.c.f.a.i.EdsOssFileUploadServiceImpl  : -------大文件分片上传完成--->196369
     * 2024-03-06 14:07:03.969  INFO 15144 --- [           main] c.c.c.f.FilestoreApplicationTest         : 上传执行时间(ms):699
     * 2024-03-06 14:07:03.969  INFO 15144 --- [           main] c.c.c.f.FilestoreApplicationTest         : 上传成功:1afe99dec706c24e174f5d22e08b48b7-1
     */
    @Test
    void contextLoads() {
        try {
            File fileLocal = new File("D:\\硬件检测.jpg");
            String originalFilename = fileLocal.getName();
            String key = UUID.randomUUID() + "/" + originalFilename;
            logger.info("上传生成的=" + key);
            StopWatch stopWatch = new StopWatch();
            stopWatch.start();
            CompleteMultipartUploadResult result = edsOssFileUploadService.bigFileListShardingUpload(key, fileLocal);
            stopWatch.stop();
            logger.info("上传执行时间(ms):" + stopWatch.getTotalTimeMillis());
            // 处理上传结果
            String eTag = result.getETag();
            // ...
            logger.info("上传成功:" + eTag);
        } catch (Exception e) {
            logger.error("上传失败", e);
        }
    }

    /**
     * 高级API大文件上传EDS云对象存储测试
     */
    @Test
    void contextLoadsBigFile() {
        try {
            File fileLocal = new File("D:\\fileTemp\\深信服OSS\\aws-java-sdk-1.12.643.zip");
            String originalFilename = fileLocal.getName();
            String key = UUID.randomUUID() + "/" + originalFilename;
            logger.info("上传生成的=" + key);
            StopWatch stopWatch = new StopWatch();
            stopWatch.start();
            String eTag = edsOssFileUploadService.highLevelMultipartUpload(key, fileLocal);
            stopWatch.stop();
            logger.info("上传执行时间(ms):" + stopWatch.getTotalTimeMillis());
            // ...
            logger.info("上传成功:" + eTag);
        } catch (Exception e) {
            logger.error("上传失败", e);
        }
    }

    /**
     * 分片API大文件上传EDS云对象存储测试
     */
    @Test
    void contextLoadsBigFileShare() {
        try {
            File fileLocal = new File("D:\\fileTemp\\深信服OSS\\aws-java-sdk-1.12.643.zip");
            String originalFilename = fileLocal.getName();
            String key = UUID.randomUUID() + "/" + originalFilename;
            logger.info("上传生成的=" + key);
            StopWatch stopWatch = new StopWatch();
            stopWatch.start();
            CompleteMultipartUploadResult result = edsOssFileUploadService.uploadLargeFileToS3(new FileInputStream(fileLocal), fileLocal.length(), key);
            stopWatch.stop();
            logger.info("上传执行时间(ms):" + stopWatch.getTotalTimeMillis());
            // 处理上传结果
            String eTag = result.getETag();
            // ...
            logger.info("上传成功:" + eTag);
        } catch (Exception e) {
            logger.error("上传失败", e);
        }
    }

    /**
     * 文件下载
     */
    @Test
    void contextLoadsDownFile() {
        try {

            String key = "26438e0c-e379-4343-b645-03e8056baaf6/硬件检测.jpg";
            logger.info("文件下载的key=" + key);
            StopWatch stopWatch = new StopWatch();
            stopWatch.start();
            InputStream inputStream = edsOssFileUploadService.downloadToEDS(key);
            stopWatch.stop();
            logger.info("文件下载执行时间(ms):" + stopWatch.getTotalTimeMillis());
            // 处理结果
            if (inputStream != null) {
                // ...
                logger.info("文件下载:");
            }
        } catch (Exception e) {
            logger.error("文件下载", e);
        }
    }

    /**
     * 预签名URL+文件下载: 测试通过
     * 2024-03-06 14:10:26.721  INFO 29356 --- [           main] c.c.c.f.FilestoreApplicationTest         : 文件下载的key=26438e0c-e379-4343-b645-03e8056baaf6/硬件检测.jpg
     * 2024-03-06 14:10:26.763  INFO 29356 --- [           main] c.c.c.f.FilestoreApplicationTest         : 文件下载执行时间(ms):41
     * 2024-03-06 14:10:26.763  INFO 29356 --- [           main] c.c.c.f.FilestoreApplicationTest         : 文件下载:http://10.1.2.16:12001/digtal_resources/26438e0c-e379-4343-b645-03e8056baaf6/%E7%A1%AC%E4%BB%B6%E6%A3%80%E6%B5%8B.jpg?X-Amz-Algorithm=AWS4-HMAC-SHA256&X-Amz-Date=20240306T061026Z&X-Amz-SignedHeaders=host&X-Amz-Expires=3599&X-Amz-Credential=MOTNMUS8FJ8P3YTXQSB5%2F20240306%2F%2Fs3%2Faws4_request&X-Amz-Signature=9536999bbc0f1b6de5bb3cf910af0def5ee1f04389446a1688724f27d5655e65
     */
    @Test
    void createSignedUrlForStringGet() {
        try {

            String key = "26438e0c-e379-4343-b645-03e8056baaf6/硬件检测.jpg";
            logger.info("文件下载的key=" + key);
            StopWatch stopWatch = new StopWatch();
            stopWatch.start();
            URL url = edsOssFileUploadService.createSignedUrlForStringGet("digtal_resources", key);
            stopWatch.stop();
            logger.info("文件下载执行时间(ms):" + stopWatch.getTotalTimeMillis());
            // 处理结果
            if (url != null) {
                // ...
                logger.info("文件下载:" + url);
            }
        } catch (Exception e) {
            logger.error("文件下载", e);
        }
    }

    /**
     * 预签名文件上传
     */
    @Test
    void createSignedUrlForStringPut() {
        try {

            String key = "26438e0c-e379-4343-b645-03e8056baaf6/硬件检测.jpg";
            logger.info("文件上传的key=" + key);
            StopWatch stopWatch = new StopWatch();
            stopWatch.start();
            URL url = edsOssFileUploadService.createSignedUrlForStringPut("digtal_resources", key);
            stopWatch.stop();
            logger.info("文件上传执行时间(ms):" + stopWatch.getTotalTimeMillis());
            // 处理结果
            if (url != null) {
                // ...
                logger.info("文件上传:" + url);
            }
        } catch (Exception e) {
            logger.error("文件上传", e);
        }
    }
}

标签:String,S3,param,亚马逊,keyName,bucketName,key,上传,SpringBoot
From: https://www.cnblogs.com/gtnotgod/p/18056597

相关文章

  • SpringBoot中集成LiteFlow(轻量、快速、稳定可编排的组件式规则引擎)实现复杂业务解耦
    场景在业务开发中,经常遇到一些串行或者并行的业务流程问题,而业务之间不必存在相关性。使用策略和模板模式的结合可以解决这个问题,但是使用编码的方式会使得文件太多,在业务的部分环节可以这样操作,在项目角度就无法一眼洞穿其中的环节和逻辑。一些拥有复杂业务逻辑的系统,核心业......
  • SpringBoot整合Caffeine本地缓存
    一、Caffeine性能二、Caffeine配置注意:1、weakValues和softValues不可以同时使用。2、maximumSize和maximumWeight不可以同时使用。3、expireAfterWrite和expireAfterAccess同事存在时,以expireAfterWrite为准。三、软引用和弱引用软引用:如果一个对象只具有......
  • springboot集成neo4j
    1创建一个springboot项目引入neo4j的依赖<!--neo4j依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-neo4j</artifactId></dependency>......
  • springboot 应用程序 pom节点版本冲突问题解决思路
    springboot应用程序pom节点版本冲突问题解决思路一、首先 mavenhelper 查看是否有冲突 conflicts 二、allDenpendencies  查询如poi 查询冲突 ps: <scope>compile</scope>  compile:这是默认的依赖项范围。指定为compile的依赖项将在编译、测试和......
  • Claude 3 Sonnet 模型现已在亚马逊云科技的 Amazon Bedrock 正式可用!
    今天,我们宣布一个激动人心的里程碑:Anthropic的Claude3Sonnet模型现已在亚马逊云科技的AmazonBedrock正式可用。下一代Claude(Claude3)的三个模型Claude3Opus、Claude3Sonnet和Claude3Haiku将陆续登陆AmazonBedrock。AmazonBedrock是目前第一个也是唯一......
  • 01_尚硅谷_SpringBoot课件
    框架高级课程系列之SpringBoot-2.3.6尚硅谷JavaEE教研组版本:V3.3一.SpringBoot概述与入门(掌握) 1.1SpringBoot概述1.1.1什么是SpringBootSpringBoot是Spring项目中的一个子工程,与我们所熟知的Spring-framework同属于spring的产品:其最主要作用就是帮助开发人员快速的......
  • springboot - 配置文件 @ConfigurationProperties
    1.简单属性@Configuration@ConfigurationProperties(prefix="mail")publicclassConfigProperties{privateStringhostName;privateintport;privateStringfrom;//standardgettersandsetters}注意:如果我们不在POJO中使用@Configurati......
  • SpringBoot中try/catch异常并回滚事务(自动回滚/手动回滚/部分回滚)
    https://www.cnblogs.com/cfas/p/16423510.html https://www.cnblogs.com/konglxblog/p/16229175.htmlSpringBoot异常处理回滚事务详解(自动回滚、手动回滚、部分回滚)(事务失效) 参考:https://blog.csdn.net/zzhongcy/article/details/102893309概念事务定义事务,就是一......
  • SpringBoot3整合Druid数据源的解决方案
    druid-spring-boot-3-starter目前最新版本是1.2.20,虽然适配了SpringBoot3,但缺少自动装配的配置文件,会导致加载时报加载驱动异常。<dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-3-starter</artifactId><version>1.2.20</version......
  • SpringBoot常用注解
    SpringBoot常用注解  @SpringBootApplication=@SpringBootConfiguration+@ComponentScan+@EnableAutoConfiguration@Configuration注解能够将一个类定义为SpringBoot应用程序中的配置类,等同于spring的XML配置文件,从而使该类中的Bean对象能够被SpringIoC容器进行自动管......