java利用oss實現(xiàn)下載功能
更新時間：2019年10月31日 09:31:01 作者：汪家人
這篇文章主要為大家詳細介紹了java利用oss實現(xiàn)下載功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
本文實例為大家分享了如何利用oss實現(xiàn)下載功能的具體代碼，供大家參考，具體內容如下
目前我接觸的實現(xiàn)下載功能有3種方式。第一種，就是把要下載的內容寫到本地目錄，然后把目錄返回給前端，利用a標簽下載。第二種，本地不允許訪問，掛載目錄，使目錄可以對外訪問，同樣的，把目錄返給前端下載。第三種，使用第三方存儲，其中阿里云oss就是一種可以用來實現(xiàn)的對象存儲。
首先，導入依賴包
<dependency> <groupId>com.aliyun.oss</groupId> <artifactId>aliyun-sdk-oss</artifactId> <version>3.6.0</version> </dependency>
參數(shù)類
public class OssParams {
public static final String endpoint = "oss-cn-hangzhou.aliyuncs.com";
public static final String accessKeyId = "";
public static final String accessKeySecret = "";
public static final String bucketName = "";
public static final String rootName = "";//根目錄
}
工具類
import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.AppendObjectRequest;
import com.aliyun.oss.model.ObjectMetadata;
import org.joda.time.DateTime;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.ByteArrayInputStream;
import java.net.URL;
import java.util.Date;
import java.util.concurrent.atomic.AtomicLong;
import static OssParams.bucketName;
/**
* 先做單例對象調用，防止多線程并發(fā)bug
* 后期加入線程鎖控制后，做成公共utils
*/
public class WriteLeadsOssUtils {
private static Logger LOG = LoggerFactory.getLogger(WriteLeadsOssUtils.class.getName());
private static final String fileSub = ".csv";
private AtomicLong atomicLong = new AtomicLong(0L);
private WriteLeadsOssUtils() {
}
private static class BuildWriteOSS {
private static final WriteLeadsOssUtils instance = new WriteLeadsOssUtils();
}
public static WriteLeadsOssUtils getInstance() {
return BuildWriteOSS.instance;
}
private OSS getOssClient() {
return new OSSClientBuilder().build(OssParams.endpoint, OssParams.accessKeyId, OssParams.accessKeySecret);
}
public URL writeJSONObjectFile(String content,String fileName) {
// 創(chuàng)建OSSClient實例。
OSS ossClient = getOssClient();
try {
DateTime currentTime = new DateTime(System.currentTimeMillis());
// String objectName = OssParams.rootName + currentTime.toString("yyyy-MM-dd-HH") + fileSub;
String objectName = OssParams.rootName + fileName;
// AppendObjectRequest appendObjectRequest = null;
String data = content;
ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(content.getBytes()));
Date expiration = new Date(System.currentTimeMillis() + 3600L * 1000 * 24 * 180);
URL url = ossClient.generatePresignedUrl(bucketName, objectName, expiration);
LOG.info("{} saved to OSS, url={}", objectName,url.toString());
// for (IngestLeadingRequest param : params) {
// String jsonStr = JSONObject.toJSONString(param);
// JSONObject object = JSONObject.parseObject(jsonStr);
// data += object.toJSONString() + "\n";
// }
//文件不存在
// if (!ossClient.doesObjectExist(OssParams.bucketName, objectName)) {
// atomicLong.set(0L);
// appendObjectRequest = getAppendObjectRequest(data, true, objectName);
// appendObjectRequest.setPosition(0L);
// } else {
// appendObjectRequest = getAppendObjectRequest(data, false, objectName);
// }
// AppendObjectResult appendObjectResult = ossClient.appendObject(appendObjectRequest);
// atomicLong.set(appendObjectResult.getNextPosition());
// System.gc();
return url;
} catch (OSSException e) {
e.printStackTrace();
return null;
} catch (ClientException e) {
e.printStackTrace();
return null;
} finally {
ossClient.shutdown();
}
}
/**
* flag標志位，true為新文件，false為追加文件
*
* @param data
* @param flag
* @param objectName
* @return
*/
private AppendObjectRequest getAppendObjectRequest(String data, Boolean flag, String objectName) {
ObjectMetadata meta = new ObjectMetadata();
// 指定上傳的內容類型。
meta.setContentType("text/plain;charset=utf-8");
if (flag == true) {
return new AppendObjectRequest(bucketName, objectName,
new ByteArrayInputStream(data.getBytes()), meta);
} else {
return new AppendObjectRequest(bucketName, objectName,
new ByteArrayInputStream(data.getBytes()), meta).withPosition(atomicLong.get());
}
}
}
調用方法
WriteLeadsOssUtils.getInstance().writeJSONObjectFile("hello");
//將hello作為內容存入oss，并獲得可以下載的url
利用上述方式，可以直接將可以下載的url返回給前端，直接用窗口打開就可以下載。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
基于java web獲取網(wǎng)頁訪問次數(shù)代碼實例
這篇文章主要介紹了基于java web獲取網(wǎng)頁訪問次數(shù)代碼實例,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-02-02
使用spring.profiles.active來分區(qū)配置的方法示例
這篇文章主要介紹了使用spring.profiles.active來分區(qū)配置的方法示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-01-01
中國象棋是起源于中國的一種棋，屬于二人對抗性游戲的一種，在中國有著悠久的歷史。由于用具簡單，趣味性強，成為流行極為廣泛的棋藝活動。本文將利用Java實現(xiàn)這一經(jīng)典游戲，需要的可以參考一下2022-02-02
MyBatis?攔截器是?MyBatis?提供的一個強大特性,它允許你在?MyBatis?執(zhí)行其核心邏輯的關鍵節(jié)點插入自定義邏輯,從而改變?MyBatis?的默認行為,本文給大家詳細介紹了如何使用Mybatis的攔截器,需要的朋友可以參考下2024-03-03
Spring中Transactional注解使用的心得(推薦)
這篇文章主要介紹了Spring中Transactional注解使用的心得,事務是用來控制數(shù)據(jù)的ACID特性的，用于保證數(shù)據(jù)的正確性和完整性，需要的朋友可以參考下2022-10-10
JAVA中JSONObject對象的使用方法2013-11-11
這篇文章主要介紹了簡單了解Spring Boot及idea整合jsp過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11
這篇文章主要給大家介紹了關于java錯誤:?不支持發(fā)行版本?22的簡單解決方法,這個錯誤通常是由于Java版本不兼容導致的,請檢查您的項目所使用的Java版本是否與您當前安裝的Java版本一致,需要的朋友可以參考下2024-06-06
Spring擴展點之BeanFactoryPostProcessor詳解
這篇文章主要介紹了Spring擴展點之BeanFactoryPostProcessor詳解,Spring的設計非常優(yōu)雅,有很多的擴展點供我們對項目進行擴展,今天學習一下Spring其中擴展點之一的BeanFactoryPostProcessor,需要的朋友可以參考下2023-11-11
PageOffice是一款在線的office編輯軟件,幫助Web應用系統(tǒng)或Web網(wǎng)站實現(xiàn)用戶在線編輯Word、Excel、PowerPoint文檔,下面我們就來看看如何使用Java實現(xiàn)在線預覽office吧2024-01-01