文档章节

Amazon S3 Java API学习笔记

Mercy_丶
 Mercy_丶
发布于 2016/04/05 22:39
字数 562
阅读 126
收藏 0

1、需要包的Maven依赖

        

                <dependency>
			<groupId>com.amazonaws</groupId>
			<artifactId>aws-java-sdk-s3</artifactId>
			<version>1.10.61</version>
		</dependency>

		<dependency>
			<groupId>com.amazonaws</groupId>
			<artifactId>aws-java-sdk-core</artifactId>
			<version>1.10.61</version>
		</dependency>

		<dependency>
			<groupId>xerces</groupId>
			<artifactId>xerces</artifactId>
			<version>2.4.0</version>
		</dependency>
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpclient</artifactId>
			<version>4.5.1</version>
		</dependency>

		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpcore</artifactId>
			<version>4.4.4</version>
		</dependency>

		<dependency>
			<groupId>joda-time</groupId>
			<artifactId>joda-time</artifactId>
			<version>2.9.1</version>
		</dependency>

2、获取s3连接

    

                // String accessKey = "××××××××";
		// String secretKey = "××××××××";
		AWSCredentialsProvider credentials = new ClasspathPropertiesFileCredentialsProvider(
				"AwsCredentials.properties");
		ClientConfiguration configuration = new ClientConfiguration();
		/**配置代理连接**/
		/*
		configuration.setProxyHost("172.26.100.238");
		configuration.setProxyPort(64000);
		 configuration.setProxyUsername("××");
		 configuration.setProxyPassword("××");
		*/
		configuration.setProtocol(Protocol.HTTP);
		AmazonS3 conn = new AmazonS3Client(credentials, configuration);

3、详细Object的CRUD操作请看:这里   or  这里

4、自己写的AmazonS3Service

package com.sanminasci.owi.amazons3.impl;

import java.io.File;
import java.net.URL;

import com.amazonaws.ClientConfiguration;
import com.amazonaws.Protocol;
import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.auth.ClasspathPropertiesFileCredentialsProvider;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.GeneratePresignedUrlRequest;
import com.amazonaws.services.s3.model.ListObjectsRequest;
import com.amazonaws.services.s3.model.ObjectListing;
import com.amazonaws.services.s3.model.S3ObjectSummary;
import com.sanminasci.owi.amazons3.AmazonS3Service;
import com.sanminasci.owi.util.DateUtil;

/**
 * 
 * @author mercy_yang
 *
 */
public class AmazonS3ServiceImpl implements AmazonS3Service {

	private static final String BUCKETNAME = "××";
	private static final String PRIFIX = "××";

	/**
	 * This method is get AmazonS3 connection
	 * 
	 * @return AmazonS3
	 */
	protected static AmazonS3 getS3Conn() {
		AWSCredentialsProvider credentials = new ClasspathPropertiesFileCredentialsProvider(
				"AwsCredentials.properties");
		ClientConfiguration configuration = new ClientConfiguration();
		// configuration.setProxyHost("172.26.100.190");
		// configuration.setProxyPort(3128);
		configuration.setProxyHost("172.26.100.238");
		configuration.setProxyPort(64000);
		configuration.setProxyUsername("××");
		configuration.setProxyPassword("××");
		configuration.setProtocol(Protocol.HTTP);
		AmazonS3 s3 = new AmazonS3Client(credentials, configuration);
		return s3;
	}

	/**
	 * This method is upload Local File to AmazonS3 And Generate URL
	 * 
	 * @return URL
	 */
	@Override
	public String uploadLocalFile2S3GetUrl(File file, String plantCode) {

		// Get AmazonS3 Connect
		AmazonS3 s3 = getS3Conn();

		// Upload File to S3
		s3.putObject(BUCKETNAME, PRIFIX + plantCode + DateUtil.generateDateFolder() + file.getName(), file);

		// Generate URL
		GeneratePresignedUrlRequest request = new GeneratePresignedUrlRequest(BUCKETNAME,
				PRIFIX + plantCode + DateUtil.generateDateFolder() + file.getName());
		URL url = s3.generatePresignedUrl(request);

		return url.toString();
	}

	@Override
	public boolean deleteFile(String fileName, String plantCode) {
		return false;
	}

	@Override
	public String updateExistFile(String fileName, String plantCode, File file) {
		AmazonS3 s3 = getS3Conn();
		String exits = null;
		String fileNames[] = null;
		String filePath = null;
		ListObjectsRequest request = new ListObjectsRequest(BUCKETNAME, PRIFIX + plantCode, "", "", 10000);
		ObjectListing objects = s3.listObjects(request);
		do {
			for (S3ObjectSummary summary : objects.getObjectSummaries()) {
				filePath = summary.getKey();
				if (!(filePath.equals("") || filePath == null)) {
					fileNames = filePath.split("/");
					if (fileName.equals(fileNames[fileNames.length - 1])) {
						exits = filePath;
					}
				}
			}
		} while (objects.isTruncated());
		System.out.println(exits);
		if (exits != null) {
			s3.deleteObject(BUCKETNAME, exits);
			s3.putObject(BUCKETNAME, PRIFIX + plantCode + DateUtil.generateDateFolder() + file.getName(), file);
			GeneratePresignedUrlRequest urlRequest = new GeneratePresignedUrlRequest(BUCKETNAME,
					PRIFIX + plantCode + DateUtil.generateDateFolder() + file.getName());
			URL url = s3.generatePresignedUrl(urlRequest);
			return url.toString();
		} else {
			return null;
		}
	}

	@Override
	public boolean isFileExist(String fileName, String plantCode) {
		boolean flag = false;
		String fileNames[] = null;
		String filePath = null;
		AmazonS3 s3 = getS3Conn();
		ListObjectsRequest request = new ListObjectsRequest(BUCKETNAME, PRIFIX + plantCode, "", "", 10000);
		ObjectListing objects = s3.listObjects(request);
		do {
			for (S3ObjectSummary summary : objects.getObjectSummaries()) {
				filePath = summary.getKey();
				if (!(filePath.equals("") || filePath == null)) {
					fileNames = filePath.split("/");
					if (fileName.equals(fileNames[fileNames.length - 1])) {
						flag = true;
					}
				}
			}
		} while (objects.isTruncated());

		return flag;
	}
	
	@Override
	public String generateUrl(String plantCode,String fileName) {
		String fileNames[] = null;
		String filePath = null;
		GeneratePresignedUrlRequest urlRequest = null;
		AmazonS3 s3 = getS3Conn();
		ListObjectsRequest request = new ListObjectsRequest(BUCKETNAME, PRIFIX + plantCode, "", "", 10000);
		ObjectListing objects = s3.listObjects(request);
		do {
			for (S3ObjectSummary summary : objects.getObjectSummaries()) {
				filePath = summary.getKey();
				if (!(filePath.equals("") || filePath == null)) {
					fileNames = filePath.split("/");
					if (fileName.equals(fileNames[fileNames.length - 1])) {
						 urlRequest = new GeneratePresignedUrlRequest(BUCKETNAME,filePath);
					}
				}
			}
		} while (objects.isTruncated());
		URL url = s3.generatePresignedUrl(urlRequest);
		return url.toString();
	}

	public static void main(String[] args) {
		AmazonS3Service service = new AmazonS3ServiceImpl();
		// if (service.isFileExist("hellopdf.pdf", "E81")) {
		// String url = service.uploadLocalFile2S3GetUrl(new
		// File("/home/mercy/3.pdf"), "E81");
		// System.out.println(url);
		// }
		//
		// System.out.println(service.isFileExist("hellopdf.pdf", "E81"));
//		service.updateExistFile("hellopdf.pdf", "E81", new File(""));
		String url =service.generateUrl("E81", "ubuntu.pdf");
		System.out.println(url);
	}

	

}

 

 

 

 

 

 

© 著作权归作者所有

Mercy_丶
粉丝 8
博文 40
码字总数 16292
作品 0
私信 提问
云计算环境下的 JVM 虚拟化特性初探

目前对于到底什么是云计算,什么样的平台属于云计算平台,等等围绕云计算相关的问题,不同的软硬件厂商对此都有自己不同的理解,有着自己不同的定 义。他们所提供的云计算平台也是千差万别。...

IBMdW
2011/10/18
370
1
持久层框架 DataNucleus Access 2.0 发布

DataNucleus Access Platform 是一个兼容各种标准的 Java 数据持久化框架,完全兼容 JDO1, JDO2, JDO2.1, JDO2.2, JDO2.3, 和 JPA1 等 Java 标准。提供一个基于 REST 的API。通过它可以访问所...

红薯
2010/01/09
379
0
BAT等大厂Android面试书单和知识点清单

java是Android开发的基础,在BAT的初面中,会涉及到比较多的java基础知识,所以比较重要,下面我介绍的书籍内容是由浅到深。 1.Thinking in java:这本书被称为Java的三大圣经之一,虽然书比...

android自学
2018/07/25
0
0
给大家分享一个JAVA技术大牛的课程笔记

目前,Java语言已经广泛应用于生活中的各个领域,无论是网络编程还是数据库编程,甚至是web开发都有Java语言的身影 很多小伙伴想学习java却布置从何学起,现在给大家分享一个JAVA大神课程笔记...

dadaxiaoxiao
2015/12/31
432
1
111 多线程JUC包下代码分析

Java多线程系列目录(共43篇) AtomicLongFieldUpdater:通过反射+CAS实现对传入对象的指定long字段实现类似AtomicLong的操作 http://www.cnblogs.com/skywang12345/p/javathreadscategory.ht...

素雷
2017/10/31
51
0

没有更多内容

加载失败,请刷新页面

加载更多

Java读取Excel 2007

可以先读一下 【Excel 2007 底层实现方式】 1. 依赖的jar包 <dependencies> <dependency> <groupId>org.apache.poi</groupId> <artifactId>poi</artifa......

时刻在奔跑
28分钟前
4
0
谷歌助手

https://www.lanzous.com/GoogleDownUrl

chenhongjiang
33分钟前
4
0
Makefile中.PHONY的作用是什么?

.PHONY在Makefile中是什么意思? 我已经经历过了 ,但是它太复杂了。 有人可以简单地向我解释吗? #1楼 .PHONY: install 表示“安装”一词在此Makefile中不代表文件名; 表示Makefile与同一...

技术盛宴
34分钟前
4
0
vmware 共享文件夹不显示文件的问题

安装vmtools后还是不显示执行以下操作//但是只有root权限才行 1:输入命令 sudo apt install open-vm-tools 安装工具 2:输入命令 sudo vmhgfs-fuse .host:/ /mnt/hgfs 完成设置 去除root,编...

漫步海边小路
40分钟前
4
0
mysql对子查询的优化改写

《高性能mysql第三版》提到mysql会将in子查询改写成exists查询(书中基于的mysql版本是5.1.50和5.5) 但是在5.6之后,已经优化成使用半连接查询 SELECT class_num, class_name FROM class WH...

os_m
42分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部