如何使用Java在华为云OBS上传大文件？

Love The Way You Lie 2023-10-15 10:19 54阅读 0赞

在互联网时代，数据量的快速增长已成为了一种普遍的趋势。随着云计算技术的发展，云存储服务成为了存储和管理大量数据的一种重要手段。华为云对象存储服务（OBS）作为一种高可靠、高可用、高性能的云存储服务，得到了广泛的应用和认可。在使用华为云OBS上传大文件时，我们可以使用Java代码实现，本文将介绍利用Java代码上传大文件至华为云OBS的方法。

### 一、准备工作 ###

在开始编写Java代码之前，我们需要先完成一些准备工作。

#### 1.注册华为云账号并创建OBS存储桶 ####

如果您还没有华为云账号，可以先注册一个。注册成功后，登录华为云控制台，在对象存储服务（OBS）中创建一个存储桶（Bucket）。存储桶的名称必须是全局唯一的，并且符合DNS命名规范。

华为云官网地址：

https://www.huaweicloud.com/

![202303262223744.png][]

#### 2.下载OBS Java SDK ####

华为云提供了OBS Java SDK，可以方便地使用Java代码实现OBS的相关操作。您可以在OBS Java SDK官网下载相应的SDK。

#### 3.配置OBS Java SDK ####

下载OBS Java SDK后，需要进行相应的配置。首先，将下载的SDK解压到本地目录下。然后，在Java项目中引入OBS Java SDK相关的jar包。最后，将配置文件obs.properties复制到Java项目的classpath下，并填写华为云账号的Access Key和Secret Key等信息。

### 二、Java代码实现上传大文件 ###

在完成上述准备工作之后，我们可以开始编写Java代码实现上传大文件至华为云OBS。下面是一个简单的Java代码示例：

import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    
    import com.obs.services.ObsClient;
    import com.obs.services.model.ObjectMetadata;
    import com.obs.services.model.PutObjectRequest;
    
    public class UploadLargeFileToOBS {
        
    
        public static void main(String[] args) throws IOException {
        
            // 配置OBS连接信息
            String endPoint = "obs.cn-north-1.myhuaweicloud.com";
            String ak = "AccessKey";
            String sk = "SecretKey";
            String bucketName = "my-bucket";
            
            // 创建OBS客户端
            ObsClient obsClient = new ObsClient(ak, sk, endPoint);
            
            // 创建上传请求
            String objectKey = "my-large-file.zip";
            File file = new File("D:/my-large-file.zip");
            ObjectMetadata metadata = new ObjectMetadata();
            metadata.setContentLength(file.length());
            PutObjectRequest request = new PutObjectRequest(bucketName, objectKey, new FileInputStream(file), metadata);
            
            // 执行上传操作
            obsClient.putObject(request);
            
            // 关闭OBS客户端
            obsClient.close();
        }
    
    }

上述代码中，首先配置了OBS连接信息，包括OBS服务的EndPoint、Access Key、Secret Key和Bucket名称。然后，创建OBS客户端，并创建上传请求。上传请求中包括要上传的文件、文件的元数据和存储桶名称等信息。最后，执行上传操作并关闭OBS客户端。

需要注意的是，如果要上传的文件较大，需要分片上传。华为云OBS Java SDK已经封装了分片上传的方法，我们只需要调用相应的API即可。下面是一个Java代码示例，演示如何使用OBS Java SDK进行分片上传：

import java.io.File;
    import java.io.IOException;
    
    import com.obs.services.ObsClient;
    import com.obs.services.exception.ObsException;
    import com.obs.services.model.AbortMultipartUploadRequest;
    import com.obs.services.model.CompleteMultipartUploadRequest;
    import com.obs.services.model.InitiateMultipartUploadRequest;
    import com.obs.services.model.InitiateMultipartUploadResult;
    import com.obs.services.model.ObjectMetadata;
    import com.obs.services.model.PartEtag;
    import com.obs.services.model.UploadPartRequest;
    import com.obs.services.model.UploadPartResult;
    
    public class UploadLargeFileToOBS {
        
    
        public static void main(String[] args) throws IOException {
        
            // 配置OBS连接信息
            String endPoint = "obs.cn-north-1.myhuaweicloud.com";
            String ak = "AccessKey";
            String sk = "SecretKey";
            String bucketName = "my-bucket";
            
            // 创建OBS客户端
            ObsClient obsClient = new ObsClient(ak, sk, endPoint);
            
            // 创建上传请求
            String objectKey = "my-large-file.zip";
            File file = new File("D:/my-large-file.zip");
            ObjectMetadata metadata = new ObjectMetadata();
            metadata.setContentLength(file.length());
            InitiateMultipartUploadRequest initiateRequest = new InitiateMultipartUploadRequest(bucketName, objectKey, metadata);
            InitiateMultipartUploadResult initiateResult = obsClient.initiateMultipartUpload(initiateRequest);
            String uploadId = initiateResult.getUploadId();
            
            // 分片上传
            long partSize = 5 * 1024 * 1024; // 分片大小为5MB
            long filePosition = 0;
            int partNumber = 1;
            while (filePosition < file.length()) {
        
                long currentPartSize = Math.min(partSize, file.length() - filePosition);
                UploadPartRequest uploadRequest = new UploadPartRequest();
                uploadRequest.setBucketName(bucketName);
                uploadRequest.setObjectKey(objectKey);
                uploadRequest.setUploadId(uploadId);
                uploadRequest.setFile(file);
                uploadRequest.setPartSize(currentPartSize);
                uploadRequest.setPartNumber(partNumber);
                uploadRequest.setPosition(filePosition);
                UploadPartResult uploadResult = obsClient.uploadPart(uploadRequest);
                PartEtag partEtag = new PartEtag(uploadResult.getEtag(), uploadResult.getPartNumber());
                partNumber++;
                filePosition += currentPartSize;
            }
            
            // 完成分片上传
            CompleteMultipartUploadRequest completeRequest = new CompleteMultipartUploadRequest(bucketName, objectKey, uploadId);
            obsClient.completeMultipartUpload(completeRequest);
            
            // 关闭OBS客户端
            obsClient.close();
        }
    
    }

上述代码中，首先配置了OBS连接信息，创建OBS客户端，并创建上传请求。然后，进行分片上传操作。分片大小为5MB，在上传过程中，逐个上传每个分片.

接下来，我们将使用Java代码实现将大文件上传到华为云OBS。

首先，我们需要确保已经在华为云平台上创建了OBS桶，并已经获取了AK/SK密钥。然后，我们需要在Java项目中导入OBS SDK。

在Maven项目中，我们可以添加以下依赖：

然后，我们可以使用以下Java代码实现将大文件上传到OBS：

import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    
    import com.obs.services.ObsClient;
    import com.obs.services.exception.ObsException;
    import com.obs.services.model.PutObjectRequest;
    import com.obs.services.model.PutObjectResult;
    
    public class OBSUploader {
        
        
        private static final String endPoint = "obs.cn-north-1.myhuaweicloud.com";
        private static final String ak = "your access key";
        private static final String sk = "your secret key";
        private static final String bucketName = "your bucket name";
        private static final String objectKey = "your object key";
        
        public static void main(String[] args) {
        
            
            ObsClient obsClient = new ObsClient(ak, sk, endPoint);
            
            File file = new File("path/to/your/file");
            
            PutObjectRequest request = new PutObjectRequest(bucketName, objectKey, file);
            
            try {
        
                PutObjectResult result = obsClient.putObject(request);
                System.out.println("Upload successful! ETag: " + result.getEtag());
            } catch (ObsException e) {
        
                System.out.println("Error uploading file: " + e.getErrorCode() + " - " + e.getErrorMessage());
            } finally {
        
                obsClient.close();
            }
        }
    }

在上面的代码中，我们首先定义了OBS服务的端点、AK/SK密钥、OBS桶的名称和要上传的对象的对象键。然后，我们使用ObsClient类创建了一个OBS客户端对象。接下来，我们创建了一个File对象，该对象表示我们要上传的文件。然后，我们创建了一个PutObjectRequest对象，并将其用于向OBS桶中上传文件。最后，我们使用putObject方法将文件上传到OBS，并打印出ETag以表示上传成功。

需要注意的是，在实际使用中，我们还需要处理异常和关闭OBS客户端对象。此外，我们还可以在PutObjectRequest对象中指定许多其他选项，例如存储类型、元数据等。

### 总结 ###

在本文中，我们介绍了华为云OBS的概念和特点，以及如何使用Java代码将大文件上传到OBS。OBS作为一种高可用、高可靠、高性能的对象存储服务，在云计算、大数据等领域有着广泛的应用。通过学习和使用OBS，我们可以更好地管理和存储大量的数据，提高数据的安全性和可靠性，提高工作效率和服务质量。

[202303262223744.png]: https://img-wljslmz-1259086031.cos.ap-nanjing.myqcloud.com/picgo/202303262223744.png