| | |
| | | package com.iplatform.file; |
| | | |
| | | import com.iplatform.file.support.AwsOssFileEngine; |
| | | import com.walker.infrastructure.utils.FileCopyUtils; |
| | | import org.junit.Test; |
| | | |
| | | import java.io.File; |
| | | import java.io.FileInputStream; |
| | | import java.io.InputStream; |
| | | import java.util.concurrent.TimeUnit; |
| | | |
| | | public class TestOss { |
| | | |
| | | /** |
| | | * 2:后下载,根据1中生成的key,获取文件内容 |
| | | * @throws Exception |
| | | */ |
| | | //package com.iplatform.file; |
| | | // |
| | | //import com.iplatform.file.support.AwsOssFileEngine; |
| | | //import com.walker.infrastructure.utils.FileCopyUtils; |
| | | //import org.junit.Test; |
| | | // |
| | | //import java.io.File; |
| | | //import java.io.FileInputStream; |
| | | //import java.io.InputStream; |
| | | //import java.util.concurrent.TimeUnit; |
| | | // |
| | | //public class TestOss { |
| | | // |
| | | // /** |
| | | // * 2:后下载,根据1中生成的key,获取文件内容 |
| | | // * @throws Exception |
| | | // */ |
| | | //// @Test |
| | | // public void downloadFile() throws Exception{ |
| | | // String id = "1064987848085008"; |
| | | // AwsOssFileEngine engine = this.awsOssFileEngine(); |
| | | //// byte[] content = engine.downloadFile(id); |
| | | // byte[] content = engine.testDownload(id); |
| | | //// FileUtils.writeFile(content, "f:/图片/test_oss_down.jpg"); |
| | | //// FileCopyUtils.copy(content, new File("f:/图片/test_oss_down.jpg")); |
| | | // FileCopyUtils.copy(content, new File("f:/图片/corda_1.zip")); |
| | | // |
| | | // TimeUnit.SECONDS.sleep(10); |
| | | // |
| | | // content = engine.testDownload(id); |
| | | // FileCopyUtils.copy(content, new File("f:/图片/corda_2.zip")); |
| | | // } |
| | | // |
| | | // /** |
| | | // * 1:先上传,控制台获取key |
| | | // * @throws Exception |
| | | // */ |
| | | // @Test |
| | | public void downloadFile() throws Exception{ |
| | | String id = "1064987848085008"; |
| | | AwsOssFileEngine engine = this.awsOssFileEngine(); |
| | | // byte[] content = engine.downloadFile(id); |
| | | byte[] content = engine.testDownload(id); |
| | | // FileUtils.writeFile(content, "f:/图片/test_oss_down.jpg"); |
| | | // FileCopyUtils.copy(content, new File("f:/图片/test_oss_down.jpg")); |
| | | FileCopyUtils.copy(content, new File("f:/图片/corda_1.zip")); |
| | | |
| | | TimeUnit.SECONDS.sleep(10); |
| | | |
| | | content = engine.testDownload(id); |
| | | FileCopyUtils.copy(content, new File("f:/图片/corda_2.zip")); |
| | | } |
| | | |
| | | /** |
| | | * 1:先上传,控制台获取key |
| | | * @throws Exception |
| | | */ |
| | | @Test |
| | | public void uploadFile() throws Exception{ |
| | | String fileName = "f:/图片/3300.jpg_wh1200.jpg"; |
| | | // String fileName = "D:/360极速浏览器下载/corda-release-os-4.12.zip"; |
| | | AwsOssFileEngine engine = this.awsOssFileEngine(); |
| | | // engine.uploadFile("f:/图片/3300.jpg_wh1200.jpg", null); |
| | | InputStream inputStream = new FileInputStream(fileName); |
| | | engine.uploadFile(inputStream, "3300.jpg_wh1200.jpg", "", (long)inputStream.available(), 0, "-1"); |
| | | |
| | | TimeUnit.SECONDS.sleep(5); |
| | | |
| | | fileName = "D:/360极速浏览器下载/corda-release-os-4.12.zip"; |
| | | inputStream = new FileInputStream(fileName); |
| | | engine.uploadFile(inputStream, "corda-release-os-4.12.zip", "", (long)inputStream.available(), 0, "-1"); |
| | | |
| | | engine.close(); |
| | | } |
| | | |
| | | private AwsOssFileEngine awsOssFileEngine(){ |
| | | AwsOssFileEngine engine = new AwsOssFileEngine(); |
| | | engine.setAccessKey("HDKSYC2Y4FELF5CL5FIB"); |
| | | engine.setSecretKey("ktf8Px9uTvLFFpQNGsO41ehRsgJ0hWnLtxZnDBCX"); |
| | | engine.setEndpoint("http://eos-beijing-1.cmecloud.cn"); |
| | | engine.setBucketName("ctoms-file"); |
| | | engine.initS3Client(); |
| | | return engine; |
| | | } |
| | | } |
| | | // public void uploadFile() throws Exception{ |
| | | // String fileName = "f:/图片/3300.jpg_wh1200.jpg"; |
| | | //// String fileName = "D:/360极速浏览器下载/corda-release-os-4.12.zip"; |
| | | // AwsOssFileEngine engine = this.awsOssFileEngine(); |
| | | //// engine.uploadFile("f:/图片/3300.jpg_wh1200.jpg", null); |
| | | // InputStream inputStream = new FileInputStream(fileName); |
| | | // engine.uploadFile(inputStream, "3300.jpg_wh1200.jpg", "", (long)inputStream.available(), 0, "-1"); |
| | | // |
| | | // TimeUnit.SECONDS.sleep(5); |
| | | // |
| | | // fileName = "D:/360极速浏览器下载/corda-release-os-4.12.zip"; |
| | | // inputStream = new FileInputStream(fileName); |
| | | // engine.uploadFile(inputStream, "corda-release-os-4.12.zip", "", (long)inputStream.available(), 0, "-1"); |
| | | // |
| | | // engine.close(); |
| | | // } |
| | | // |
| | | // private AwsOssFileEngine awsOssFileEngine(){ |
| | | // AwsOssFileEngine engine = new AwsOssFileEngine(); |
| | | // engine.setAccessKey("HDKSYC2Y4FELF5CL5FIB"); |
| | | // engine.setSecretKey("ktf8Px9uTvLFFpQNGsO41ehRsgJ0hWnLtxZnDBCX"); |
| | | // engine.setEndpoint("http://eos-beijing-1.cmecloud.cn"); |
| | | // engine.setBucketName("ctoms-file"); |
| | | // engine.initS3Client(); |
| | | // return engine; |
| | | // } |
| | | //} |