`
kfcman
  • 浏览: 384453 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

java中获取oauth_token的简单方法(包含Oauth协议计算签名的方法)

 
阅读更多

 
package com.feng.test;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.URL;
import java.net.URLEncoder;
import java.security.InvalidKeyException;
import java.security.Key;
import java.security.NoSuchAlgorithmException;
import java.util.Random;
import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
public class GetRequest {
/*
  * 拼接URL
  */
public static String getUrl(String baseUrl,String consumerKey,String consumer_secret,String nonce,String signatureMethord,String version) throws InvalidKeyException, NoSuchAlgorithmException, UnsupportedEncodingException {
  //获取当前系统时间
  Long test = System.currentTimeMillis();
  //时间戳只有10位,需要处理
  String time = test.toString().substring(0,10);
  if("".equals(nonce) || nonce == null){
   nonce = getRandomString(8);
  }
  if("".equals(signatureMethord) || signatureMethord == null){
   signatureMethord = "HMAC-SHA1";
  }
  if("".equals(version) || version == null){
   version = "1.0";
  }
  StringBuffer term  = new StringBuffer("https://openapi.kuaipan.cn/open/requestToken?");
  String signature = getSignature(baseUrl, consumerKey, consumer_secret, nonce, signatureMethord, version,time);
  term.append("oauth_signature="+ signature +"");
  term.append("&oauth_consumer_key="+ consumerKey +"");
  term.append("&oauth_nonce="+ nonce +"");
  term.append("&oauth_signature_method="+signatureMethord+"");
  term.append("&oauth_timestamp="+ time +"");
  term.append("&oauth_version="+version+"");
  return term.toString();
}
/*
  * 依据传递的参数拼接baseString
  */
public static String initBaseString(String baseUrl,String consumerKey,String nonce,String signatureMethord,String version,String time){
  if(baseUrl.indexOf("GET") > -1 || baseUrl.indexOf("&") > -1){
   System.out.println("初始URL不正确");
  }
  StringBuffer baseString = new StringBuffer("GET&"+encoderStr(baseUrl)+"&");
  StringBuffer paramsStr = new StringBuffer();
  paramsStr.append("oauth_consumer_key="+consumerKey);
  paramsStr.append("&oauth_nonce="+nonce);
  paramsStr.append("&oauth_signature_method="+signatureMethord);
  paramsStr.append("&oauth_timestamp="+time);
  paramsStr.append("&oauth_version="+version);
 
  baseString.append(encoderStr(paramsStr.toString()));
  return baseString.toString();
}

//生成密钥
public static String getSignature(String baseUrl,String consumerKey,String consumer_secret,String nonce,String signatureMethord,String version,String time){
  String signature = "";
  String base_string = initBaseString(baseUrl, consumerKey, nonce, signatureMethord, version,time);
  String secret = consumer_secret + "&";
  signature = new BASE64Encoder().encode(encodeHmacSHA(base_string.getBytes(), secret.getBytes())) ;
  return signature;
}
  /** 
     * 使用HmacSHA算法计算 
     *  
     * @param data 字符基串
     * @param key 密钥 
     * @return 加密后的签名(长度为16的字节数组) 
     */ 
    public static byte[] encodeHmacSHA(byte[] data, byte[] key){
     String method = "HmacSHA1";
        Key k = new SecretKeySpec(key,method);
        Mac mac = null;
        try {
   mac = Mac.getInstance(method);
   mac.init(k);
  } catch (NoSuchAlgorithmException e) {
   e.printStackTrace();
  } catch (InvalidKeyException e) {
   e.printStackTrace();
  }
       
        return mac.doFinal(data);  
    }
/*
  * 获取随机字符
  */
public static String getRandomString(int length){
     StringBuffer buffer=new StringBuffer("0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ");
     StringBuffer sb=new StringBuffer();
     Random r=new Random();
     int range=buffer.length();
     for(int i=0;i<length;i++){
      sb.append(buffer.charAt(r.nextInt(range)));
     }
     return sb.toString();
}

public static String encoderStr(String str){
  String result = "";
  try {
   result = URLEncoder.encode(str, "UTF-8");
  } catch (UnsupportedEncodingException e) {
   e.printStackTrace();
  }
  return result;
}

public static void main(String[] args) {
  String baseURL = "https://openapi.kuaipan.cn/open/requestToken";
  String consumer_key = "应用的consumer_key";
  String consumer_secret = "应用的consumer_secret";
  String hmacMethod = "HMAC-SHA1"; 
  String version = "1.0";
  String url = "";
  try {
   url = getUrl(baseURL,consumer_key,consumer_secret,getRandomString(8),hmacMethod,version);
  } catch (InvalidKeyException e1) {
   e1.printStackTrace();
  } catch (NoSuchAlgorithmException e1) {
   e1.printStackTrace();
  } catch (UnsupportedEncodingException e1) {
   e1.printStackTrace();
  }
  try {
   URL my_url = new URL(url);
   BufferedReader br = new BufferedReader(new InputStreamReader(my_url.openStream()));
   String strTemp = "";
   while(null != (strTemp = br.readLine())){
    System.out.println(strTemp);
   }
  } catch (Exception e) {
   e.printStackTrace();
  }
}
}


package com.feng.util;
public class BASE64Encoder
{
  private static final char last2byte = (char)Integer.parseInt("00000011", 2);
  private static final char last4byte = (char)Integer.parseInt("00001111", 2);
  private static final char last6byte = (char)Integer.parseInt("00111111", 2);
  private static final char lead6byte = (char)Integer.parseInt("11111100", 2);
  private static final char lead4byte = (char)Integer.parseInt("11110000", 2);
  private static final char lead2byte = (char)Integer.parseInt("11000000", 2);
  private static final char[] encodeTable = { 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z', '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', '+', '/' };
  public String encode(byte[] from)
  {
    StringBuffer to = new StringBuffer((int)(from.length * 1.34D) + 3);
    int num = 0;
    char currentByte = '\000';
    for (int i = 0; i < from.length; i++) {
      num %= 8;
      while (num < 8) {
        switch (num) {
        case 0:
          currentByte = (char)(from[i] & lead6byte);
          currentByte = (char)(currentByte >>> '\002');
          break;
        case 2:
          currentByte = (char)(from[i] & last6byte);
          break;
        case 4:
          currentByte = (char)(from[i] & last4byte);
          currentByte = (char)(currentByte << '\002');
          if (i + 1 >= from.length) break;
          currentByte = (char)(currentByte | (from[(i + 1)] & lead2byte) >>> 6);
          break;
        case 6:
          currentByte = (char)(from[i] & last2byte);
          currentByte = (char)(currentByte << '\004');
          if (i + 1 >= from.length) break;
          currentByte = (char)(currentByte | (from[(i + 1)] & lead4byte) >>> 4);
        case 1:
        case 3:
        case 5:
        }to.append(encodeTable[currentByte]);
        num += 6;
      }
    }
    if (to.length() % 4 != 0) {
      for (int i = 4 - to.length() % 4; i > 0; i--) {
        to.append("=");
      }
    }
    return to.toString();
  }
}

 

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics