import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
@Override
public void upload(String path, File file, String contentType) {
	PluginConfig pluginConfig = getPluginConfig();
	if (pluginConfig != null) {
		String accessId = pluginConfig.getAttribute("accessId");
		String accessKey = pluginConfig.getAttribute("accessKey");
		String bucketName = pluginConfig.getAttribute("bucketName");
		InputStream inputStream = null;
		try {
			inputStream = new FileInputStream(file);
			OSSClient ossClient = new OSSClient(accessId, accessKey);
			ObjectMetadata objectMetadata = new ObjectMetadata();
			objectMetadata.setContentType(contentType);
			objectMetadata.setContentLength(file.length());
			ossClient.putObject(bucketName, StringUtils.removeStart(path, "/"), inputStream, objectMetadata);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			IOUtils.closeQuietly(inputStream);
		}
	}
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
@Override
public String add(InputStream input, String dir, String filename, long lenght, String contentType) throws IOException {
	if (input == null) {
		throw new NullPointerException("input不能为空.");
	}
	
	OSSClient client = new OSSClient(endpoint, accessKeyId, secretAccessKey);
	// System.err.println("endpoint:" + endpoint);
	ObjectMetadata meta = new ObjectMetadata();
	meta.setContentLength(lenght);
	if (contentType != null) {
		meta.setContentType(contentType);
	}
	filename = toUuidFileName(filename);
	String uri;
	if (dir == null || dir.length() == 0) {
		uri = filename;
	}
	else {
		uri = dir + "/" + filename;
	}
	System.out.println("uri:" + uri + " lenght:" + lenght);
	PutObjectResult result = client.putObject(bucketName, uri, input, meta);
	System.out.println(result.getETag());
	return "/" + uri;
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
@SuppressWarnings("deprecation")
@Override
public String save(GenericFile genericFile){
	OSSClient client = new OSSClient(accessKeyId, accessKeySecret);
	if(!client.doesBucketExist(bucketName)){
		client.createBucket(bucketName);
	}
	ObjectMetadata metadata = new ObjectMetadata();
	metadata.setContentLength(genericFile.getLength());
	if(fileNameGenerator == null){
		throw new RuntimeException("no file name generator configed");
	}
	String path = fileNameGenerator.gen() + genericFile.getExtend();
	client.putObject(bucketName, path, genericFile.getIs(), metadata);
	return path;
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
public StorageFolder getRootFolder() {
    if (root == null) {
        StorageBucket bucket = bucketService.singleFileBucket();
        OSSClient client = new OSSClient(bucket.getUploadUrl(), bucket.getAccessKeyId(),
            bucket.getAccessKeySecret());
        root = StorageFolder.getRootFolder(client, bucket.getName());
    }
    return root;
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
@Override
public void initialize(URI uri, Configuration conf) throws IOException {
  uri = checkNotNull(uri);
  conf = checkNotNull(conf);

  OSSCredentials ossCredentials = new OSSCredentials();
  ossCredentials.initialize(uri, conf);

  client = new OSSClient(ossCredentials.getAccessKeyId(), ossCredentials.getSecretAccessKey());
  bucket = checkNotNull(uri.getHost(), "URI must include a host: %s", uri);

  // TODO deal with server-side encryption for store, copy
  multiPartUploader = new MultiPartUploader(client, bucket, conf);
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
MultiPartUploader(OSSClient client, String bucket, Configuration conf) {
  this.client = checkNotNull(client);
  this.bucket = checkNotNull(bucket);

  checkNotNull(conf);

  multipartEnabled = conf.getBoolean(OSSFileSystemConfigKeys.OSS_MULTIPART_UPLOADS_ENABLED, true);
  partSize = conf.getLong(OSS_MULTIPART_UPLOADS_BLOCK_SIZE_PROPERTY, DEFAULT_MULTIPART_BLOCK_SIZE);
  maxThreads = conf.getInt(OSS_MULTIPART_UPLOADS_MAX_THREADS_PROPERTY, Integer.MAX_VALUE);

  checkArgument(partSize <= MAX_PART_SIZE, "%s must be at most %s", OSS_MULTIPART_UPLOADS_BLOCK_SIZE_PROPERTY, MAX_PART_SIZE);
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
@Override
public void delete(String file) {
    OSSClient client = new OSSClient(uploadUrl, accessKeyId, accessKeySecret);
    client.deleteObject(bucketName, file);
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
@Before
public void setUp() {
  client = mock(OSSClient.class);
  Configuration conf = new Configuration();
  uploader = new MultiPartUploader(client, bucket, conf);
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
@PostConstruct
public void init() {
    client = new OSSClient(url, key,
            secret);
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
public OSSClient getClient() {
    return client;
}
 

import com.aliyun.openservices.oss.OSSClient; //导入依赖的package包/类
public void setClient(OSSClient client) {
    this.client = client;
}