亚马逊Amazon S3 对象存储WEB服务接口

1.需要的依赖jar包

<dependency>

　　<groupId>com.amazonaws</groupId>

　　<artifactId>aws-java-sdk-s3</artifactId>

　　<version>1.11.233</version>

</dependency>

2.访问参数实体

public class AmazonS3Bean {

    private static String access_key_id = "access_key_id";// 访问密钥ID
    private static String secret_key = "secret_key";// 访问密钥
    private static String end_point = "end_point"; //访问IP及端口号
    private static String bucketname = "bucketname";//桶名

    private String storageobjectvopath = "";

    public static String getAccess_key_id() {
        return access_key_id;
    }

    public static void setAccess_key_id(String access_key_id) {
        AmazonS3Bean.access_key_id = access_key_id;
    }

    public static String getSecret_key() {
        return secret_key;
    }

    public static void setSecret_key(String secret_key) {
        AmazonS3Bean.secret_key = secret_key;
    }

    public static String getEnd_point() {
        return end_point;
    }

    public static void setEnd_point(String end_point) {
        AmazonS3Bean.end_point = end_point;
    }

    public static String getBucketname() {
        return bucketname;
    }

    public void setBucketname(String bucketname) {
        AmazonS3Bean.bucketname = bucketname;
    }

    public String getStorageobjectvopath() {
        return storageobjectvopath;
    }

    public void setStorageobjectvopath(String storageobjectvopath) {
        this.storageobjectvopath = storageobjectvopath;
    }

}

3.获取连接

 1 public class AmazonUtil {
 2     private static AmazonS3 conn; 3 public static BasicAWSCredentials credentials; 4 5 // 创建连接 6 public void creatConnect(AmazonS3Bean s3bean) { 7 8 credentials = new BasicAWSCredentials(AmazonS3Bean.getAccess_key_id(), AmazonS3Bean.getSecret_key()); 9 10 ClientConfiguration clientConfiguration = new ClientConfiguration().withMaxConnections(500) 11  .withProtocol(Protocol.HTTP).withRetryPolicy(PredefinedRetryPolicies.NO_RETRY_POLICY); 12 clientConfiguration.setSignerOverride("S3SignerType"); 13 14 conn = new AmazonS3Client(credentials, clientConfiguration); 15  conn.setEndpoint(AmazonS3Bean.getEnd_point()); 16 17  } 18 19 // 获取连接 20 public AmazonS3 getConnect() { 21 return conn; 22  } 23 24 // 创建存储桶是否存在 25 public Bucket createBucket(String bucketName) { 26 if (bucketName.isEmpty()) { 27 return null; 28  } 29 Bucket bucket = conn.createBucket(bucketName); 30 31 return bucket; 32  } 33 34 // 查询存储桶是否存在 35 public Bucket getBuketsByname(String bucketName) { 36 Bucket resultBucket = null; 37 if (bucketName.isEmpty()) { 38 return null; 39  } 40 List<Bucket> buckets = conn.listBuckets(); 41 if (buckets == null) { 42 return resultBucket; 43  } 44 for (Bucket bucket : buckets) { 45 if (bucketName.equals(bucket.getName())) { 46 resultBucket = bucket; 47 break; 48  } 49  } 50 return resultBucket; 51  } 52 53 public PutObjectResult createObject(String bucketName, String StorageObjectVoPath, String fileName, InputStream inputStream) 54 throws FileNotFoundException { 55 if (StorageObjectVoPath == null || StorageObjectVoPath.isEmpty() || "null".equals(StorageObjectVoPath)) { 56 StorageObjectVoPath = ""; 57  } 58 if (inputStream == null) { 59 return null; 60  } 61 String fileAllPath = StorageObjectVoPath + fileName; 62 63 PutObjectResult result = conn.putObject(bucketName, fileAllPath, inputStream, new ObjectMetadata()); 64 return result; 65  } 66 67 }

 

4.上传文件

public class AmazonS3Upload {

    public static AmazonUtil Upload(AmazonS3Bean s3bean, MultipartFile file, String path) {
        //创建连接
        AmazonUtil amazonutil = new AmazonUtil();
        amazonutil.creatConnect(s3bean);
        //获取连接
        //获取桶
        Bucket bucket = amazonutil.getBuketsByname(s3bean.getBucketname());
        if (bucket == null) {
            //说明桶不存在，则创建一个默认的桶
            bucket = amazonutil.creatBucket(s3bean.getBucketname());
        }
        //检查当前容器下该文件目录是否存在
        try {
            //上传文件对象到容器
            amazonutil.creatObject(bucket.getName(), path + "/", file.getOriginalFilename(), file.getInputStream());
        } catch (FileNotFoundException e) {
            e.printStackTrace();
            System.out.println("文件上传失败");
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("文件上传失败");
        }
        return amazonutil;
    }

}

5.文件下载，将临时连接url返回给web页面

 AmazonUtil amazonutil = new AmazonUtil();
 amazonutil.creatConnect(new AmazonS3Bean());
 GeneratePresignedUrlRequest httpRequest = new GeneratePresignedUrlRequest(AmazonS3Bean.getBucketname(), filePath);
 //临时链接
 String url = amazonutil.getConnect().generatePresignedUrl(httpRequest).toString();

6.文件删除

AmazonUtil amazonutil = new AmazonUtil();
2 amazonutil.creatConnect(new AmazonS3Bean());
3 amazonutil.getConnect().deleteObject(AmazonS3Bean.getBucketname(), filePath);