更新 oss-sdk

oss-sdk/src/main/java/cn/reghao/oss/sdk/ObjectBasicService.java

@@ -10,6 +10,8 @@ import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
 import com.amazonaws.services.s3.model.ObjectMetadata;
 import com.amazonaws.services.s3.model.PutObjectResult;
+import com.amazonaws.services.s3.model.S3Object;
+import com.amazonaws.services.s3.model.S3ObjectInputStream;
 import lombok.extern.slf4j.Slf4j;
 
 import java.io.*;
@@ -55,4 +57,27 @@ public class ObjectBasicService {
         byte[] bytes = ByteHex.hex2Bytes(eTag);
         String md5Base64 = Base64Util.encode(DigestUtil.md5sum(bytes));
     }
+
+    public void getObject(String key) {
+        S3Object s3Object = s3Client.getObject(bucketName, key);
+        S3ObjectInputStream inputStream = s3Object.getObjectContent();
+    }
+
+    public boolean objectExist(String key) {
+        return s3Client.doesObjectExist(bucketName, key);
+    }
+
+    public ObjectMetadata headObject(String key) {
+        ObjectMetadata objectMetadata = s3Client.getObjectMetadata(bucketName, key);
+        return objectMetadata;
+    }
+
+    public static void main(String[] args) {
+        String endpoint = "http://oss.reghao.cn";
+        String bucketName = "tnb";
+        ObjectBasicService objectBasicService = new ObjectBasicService(endpoint, bucketName);
+
+        String key = "";
+        boolean exist = objectBasicService.objectExist(key);
+    }
 }

oss-sdk/src/test/java/ObjectTest.java

@@ -1,11 +1,8 @@
-import cn.reghao.jutil.jdk.converter.ByteHex;
 import cn.reghao.jutil.jdk.http.UploadParam;
 import cn.reghao.jutil.jdk.http.WebRequest;
 import cn.reghao.jutil.jdk.http.WebResponse;
 import cn.reghao.jutil.jdk.io.FilePart;
 import cn.reghao.jutil.jdk.result.WebResult;
-import cn.reghao.jutil.jdk.security.Base64Util;
-import cn.reghao.jutil.jdk.security.DigestUtil;
 import cn.reghao.jutil.jdk.serializer.JsonConverter;
 import cn.reghao.jutil.tool.http.DefaultWebRequest;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
@@ -22,7 +19,6 @@ import java.lang.reflect.Type;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.time.LocalDate;
-import java.time.LocalDateTime;
 import java.util.*;
 
 /**
@@ -48,19 +44,6 @@ public class ObjectTest {
     }
     static FilePart filePart = new FilePart();
 
-    static void put(String key, File file) {
-        PutObjectResult putObjectResult = s3Client.putObject(bucketName, key, file);
-        String eTag = putObjectResult.getETag();
-        byte[] bytes = ByteHex.hex2Bytes(eTag);
-        try {
-            String md5Base64 = Base64Util.encode(DigestUtil.md5sum(bytes));
-            System.out.println();
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-        System.out.println();
-    }
-
     static WebRequest webRequest = new DefaultWebRequest();
     static void post(String key, File file) throws IOException {
         String url = "http://localhost:8020/ajax/policy";
@@ -102,16 +85,6 @@ public class ObjectTest {
         int statusCode = webResponse.getStatusCode();
     }
 
-    static boolean objectExist(String bucketName, String objectName) {
-        return s3Client.doesObjectExist(bucketName, objectName);
-    }
-
-    static void get() {
-        String key = "";
-        S3Object s3Object = s3Client.getObject(bucketName, key);
-        ObjectMetadata objectMetadata = s3Client.getObjectMetadata(bucketName, key);
-    }
-
     static void upload(String key, File file) {
         ObjectMetadata objectMetadata = new ObjectMetadata();
         objectMetadata.setContentType("application/xml");
@@ -194,7 +167,6 @@ public class ObjectTest {
         String filePath = "/home/reghao/Downloads/sxd.mp4";
         File file = new File(filePath);
         String key = String.format("a/b/c/d/%s", file.getName());
-        put(key, file);
         //upload(key, file);
         //post(key, file);