本文實例為大家分享了如何利用oss實現(xiàn)下載功能的具體代碼,供大家參考,具體內(nèi)容如下
目前創(chuàng)新互聯(lián)已為1000多家的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)絡(luò)空間、網(wǎng)站托管、服務(wù)器租用、企業(yè)網(wǎng)站設(shè)計、鄖西網(wǎng)站維護等服務(wù),公司將堅持客戶導(dǎo)向、應(yīng)用為本的策略,正道將秉承"和諧、參與、激情"的文化,與客戶和合作伙伴齊心協(xié)力一起成長,共同發(fā)展。
目前我接觸的實現(xiàn)下載功能有3種方式。第一種,就是把要下載的內(nèi)容寫到本地目錄,然后把目錄返回給前端,利用a標(biāo)簽下載。第二種,本地不允許訪問,掛載目錄,使目錄可以對外訪問,同樣的,把目錄返給前端下載。第三種,使用第三方存儲,其中阿里云oss就是一種可以用來實現(xiàn)的對象存儲。
首先,導(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; /** * 先做單例對象調(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實例。 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返回給前端,直接用窗口打開就可以下載。
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。
網(wǎng)頁題目:java利用oss實現(xiàn)下載功能
文章地址:http://muchs.cn/article2/jpshic.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供服務(wù)器托管、虛擬主機、定制網(wǎng)站、品牌網(wǎng)站制作、響應(yīng)式網(wǎng)站、建站公司
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)