java利用oss實(shí)現(xiàn)下載功能
更新時(shí)間：2019年10月31日 09:31:01 作者：汪家人
這篇文章主要為大家詳細(xì)介紹了java利用oss實(shí)現(xiàn)下載功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
本文實(shí)例為大家分享了如何利用oss實(shí)現(xiàn)下載功能的具體代碼，供大家參考，具體內(nèi)容如下
目前我接觸的實(shí)現(xiàn)下載功能有3種方式。第一種，就是把要下載的內(nèi)容寫到本地目錄，然后把目錄返回給前端，利用a標(biāo)簽下載。第二種，本地不允許訪問，掛載目錄，使目錄可以對(duì)外訪問，同樣的，把目錄返給前端下載。第三種，使用第三方存儲(chǔ)，其中阿里云oss就是一種可以用來實(shí)現(xiàn)的對(duì)象存儲(chǔ)。
首先，導(dǎo)入依賴包
<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;
/**
* 先做單例對(duì)象調(diào)用，防止多線程并發(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實(shí)例。
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標(biāo)志位，true為新文件，false為追加文件
*
* @param data
* @param flag
* @param objectName
* @return
*/
private AppendObjectRequest getAppendObjectRequest(String data, Boolean flag, String objectName) {
ObjectMetadata meta = new ObjectMetadata();
// 指定上傳的內(nèi)容類型。
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());
}
}
}
調(diào)用方法
WriteLeadsOssUtils.getInstance().writeJSONObjectFile("hello");
//將hello作為內(nèi)容存入oss，并獲得可以下載的url
利用上述方式，可以直接將可以下載的url返回給前端，直接用窗口打開就可以下載。
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
基于java web獲取網(wǎng)頁訪問次數(shù)代碼實(shí)例
這篇文章主要介紹了基于java web獲取網(wǎng)頁訪問次數(shù)代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-02-02
使用spring.profiles.active來分區(qū)配置的方法示例
這篇文章主要介紹了使用spring.profiles.active來分區(qū)配置的方法示例，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2019-01-01
Java實(shí)現(xiàn)中國(guó)象棋的示例代碼
中國(guó)象棋是起源于中國(guó)的一種棋，屬于二人對(duì)抗性游戲的一種，在中國(guó)有著悠久的歷史。由于用具簡(jiǎn)單，趣味性強(qiáng)，成為流行極為廣泛的棋藝活動(dòng)。本文將利用Java實(shí)現(xiàn)這一經(jīng)典游戲，需要的可以參考一下2022-02-02
MyBatis?攔截器是?MyBatis?提供的一個(gè)強(qiáng)大特性,它允許你在?MyBatis?執(zhí)行其核心邏輯的關(guān)鍵節(jié)點(diǎn)插入自定義邏輯,從而改變?MyBatis?的默認(rèn)行為,本文給大家詳細(xì)介紹了如何使用Mybatis的攔截器,需要的朋友可以參考下2024-03-03
Spring中Transactional注解使用的心得(推薦)
這篇文章主要介紹了Spring中Transactional注解使用的心得,事務(wù)是用來控制數(shù)據(jù)的ACID特性的，用于保證數(shù)據(jù)的正確性和完整性，需要的朋友可以參考下2022-10-10
JAVA中JSONObject對(duì)象的使用方法2013-11-11
簡(jiǎn)單了解Spring Boot及idea整合jsp過程解析
這篇文章主要介紹了簡(jiǎn)單了解Spring Boot及idea整合jsp過程解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-11-11
java錯(cuò)誤:?不支持發(fā)行版本?22的簡(jiǎn)單解決方法
這篇文章主要給大家介紹了關(guān)于java錯(cuò)誤:?不支持發(fā)行版本?22的簡(jiǎn)單解決方法,這個(gè)錯(cuò)誤通常是由于Java版本不兼容導(dǎo)致的,請(qǐng)檢查您的項(xiàng)目所使用的Java版本是否與您當(dāng)前安裝的Java版本一致,需要的朋友可以參考下2024-06-06
Spring擴(kuò)展點(diǎn)之BeanFactoryPostProcessor詳解
這篇文章主要介紹了Spring擴(kuò)展點(diǎn)之BeanFactoryPostProcessor詳解,Spring的設(shè)計(jì)非常優(yōu)雅,有很多的擴(kuò)展點(diǎn)供我們對(duì)項(xiàng)目進(jìn)行擴(kuò)展,今天學(xué)習(xí)一下Spring其中擴(kuò)展點(diǎn)之一的BeanFactoryPostProcessor,需要的朋友可以參考下2023-11-11
Java實(shí)現(xiàn)在線編輯預(yù)覽office文檔詳解
PageOffice是一款在線的office編輯軟件,幫助Web應(yīng)用系統(tǒng)或Web網(wǎng)站實(shí)現(xiàn)用戶在線編輯Word、Excel、PowerPoint文檔,下面我們就來看看如何使用Java實(shí)現(xiàn)在線預(yù)覽office吧2024-01-01