OSS签名Header实现Demo(Java)-阿里云开发者社区

开发者社区> 开发与运维> 正文

OSS签名Header实现Demo(Java)

简介:

概述

OSS的集成上传和下载提供了SDK可以直接使用,但实际使用中一些用户受限环境或者设备限制需要使用api方式来实现上传和下载,本文以PutObject接口为例,提供了java实现的demo。
注:建议优先使用OSS提供SDK,本文提供的只是签名实现上传demo,实际使用中需要结合业务来进行改动代码

详细信息

PutObject实现demo(测试环境JDK1.8):


import org.apache.commons.codec.binary.Base64;

import javax.crypto.Mac;

import javax.crypto.spec.SecretKeySpec;

import java.io.*;

import java.net.HttpURLConnection;

import java.net.URL;

import java.text.SimpleDateFormat;

import java.util.*;

public class OssSignHeader {

private static final String HMAC_SHA1_ALGORITHM = "HmacSHA1"; 

private final static String CHARSET_UTF8 = "utf8";

private final static String ALGORITHM = "HmacSHA1";

public static String hmacSha1(String data, String key) {

try {

Mac mac = Mac.getInstance(HMAC_SHA1_ALGORITHM);

SecretKeySpec keySpec = new SecretKeySpec(key.getBytes(), ALGORITHM);

mac.init(keySpec);

byte[] rawHmac;

rawHmac = mac.doFinal(data.getBytes(CHARSET_UTF8));

return new String(Base64.encodeBase64(rawHmac));

} catch (Exception e) {

throw new RuntimeException(e);

}

}

public static String buildSignData(String Date,String VERB,String CanonicalizedResource){

String signData = "PUT" + "\n"+ "\n"+ "\n"

+ Date + "\n"

+ CanonicalizedResource;

return signData;

}

public static String getGMTDate(){

Calendar cd = Calendar.getInstance();

SimpleDateFormat sdf = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss 'GMT'", Locale.US);

sdf.setTimeZone(TimeZone.getTimeZone("GMT"));

String str = sdf.format(cd.getTime());

return str;

}

public static void main(String[] args) throws Exception{

String date = getGMTDate();

String ossBucket= "您的bucket名称";

String accessKeyId= "您的AccessKey";

String secretAccessKey= "您的AccessSecret";

String resourcePath = "/xx/panda/102283/111.txt";

String resourcePath1 = "panda/102283/111.txt";

String VERB = "GET";

String url = "http://"+ossBucket+".oss-cn-hangzhou.aliyuncs.com/";

String Signature = (hmacSha1(buildSignData(date,VERB,resourcePath),secretAccessKey));

String Authorization = "OSS " + accessKeyId + ":" + Signature;

System.out.println(Authorization);

Map<String,String> head = new HashMap<String,String>();

head.put("Date",date);

head.put("Authorization",Authorization);

URL url1 = new URL(url + resourcePath1);

HttpURLConnection connection ;

StringBuffer sbuffer=null;

try {

//添加 请求内容

connection= (HttpURLConnection) url1.openConnection();

//设置http连接属性

connection.setDoOutput(true);// http正文内,因此需要设为true, 默认情况下是false;

connection.setRequestMethod("PUT"); // 可以根据需要 提交 GET、POST、DELETE、PUT等http提供的功能

//connection.setUseCaches(false);//设置缓存,注意设置请求方法为post不能用缓存

// connection.setInstanceFollowRedirects(true);

connection.setRequestProperty("Date", date);  //设置请 求的服务器网址,域名,例如***.**.***.***

connection.setRequestProperty("Authorization", Authorization);//设定 请求格式 json,也可以设定xml格式的

//connection.setRequestProperty("Content-Length", obj.toString().getBytes().length + ""); //设置文件请求的长度 

 

connection.setReadTimeout(10000);//设置读取超时时间          

connection.setConnectTimeout(10000);//设置连接超时时间           

connection.connect();            

OutputStream out = connection.getOutputStream();//向对象输出流写出数据,这些数据将存到内存缓冲区中          

out.write(new String("测试数据").getBytes());            //out.write(new String("测试数据").getBytes());            //刷新对象输出流,将任何字节都写入潜在的流中       

out.flush();     

// 关闭流对象,此时,不能再向对象输出流写入任何数据,先前写入的数据存在于内存缓冲区中          

out.close();           

//读取响应           

if (connection.getResponseCode()==200)            {

// 从服务器获得一个输入流

InputStreamReader inputStream =new InputStreamReader(connection.getInputStream());//调用HttpURLConnection连接对象的getInputStream()函数, 将内存缓冲区中封装好的完整的HTTP请求电文发送到服务端。

BufferedReader reader = new BufferedReader(inputStream); 

 

String lines;                

sbuffer= new StringBuffer(""); 

 

while ((lines = reader.readLine()) != null) {                

lines = new String(lines.getBytes(), "utf-8");                    

sbuffer.append(lines);                }                

reader.close();         

}else{          

System.out.println(connection.getResponseCode()); 

}    

//断开连接           

connection.disconnect();

System.out.println("OK  "+url1);

} catch (IOException e) { 

e.printStackTrace();     

}   

}

}

相关文档

OSS在Header中包含签名

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

其他文章