Java调用示例代码
更新日期： 2016-02-06访问次数： 53432
主要步骤
输入通用参数
输入业务参数
通过计算签名
启动API调用
获取API结果
示例代码
import java.io.IOException；
import java.io.InputStream；
import Java.io.input streamreader；
import java.io.OutputStream；
import java.io.Reader；
import Java.net.httpurl connection；
import java.net.URL；
import java.net.URLEncoder；
import Java.security.generalsecurityexception；
import Java.security.message digest；
导入Java.text.date format；
导入Java.text.simple date format；
import java.util.Arrays；
import java.util.Date；
import java.util.HashMap；
import java.util.Map；
import java.util.Map.Entry；
import java.util.Set；
import Java.util.zip.gzip inputstream；
import javax.crypto.Mac；
导入javax.crypto.secret key；
import javax.crypto.spec.secret key spec；
公共类应用程序{
privatestaticfinalstringsign _ method _ MD5=' MD5 '； 私有身份证明stringsign _ method _ hmac=' hmac '； privatestaticfinalstringcharset _ utf8=' utf-8 '； privatestaticfinalstringcontent _ encoding _ gzip=' gzip '； //TOP服务地址，正式环境为http://GW.API.Taobao.com/router/restprivatestaticfinalstringserverurl=' 3358 GW.API.TB sandbbao //沙箱环境APP应用程序中的appkeyprivatestaticfinalstringappsecret=' test '； //沙箱环境APP应用程序中的appsecretprivatestaticfinalstringsessionkey=' test '； //通过沙箱帐户许可证获得的实际有效的sessionkeypublicstaticvoidmain (字符串[ ] args ) throws exception (system.out.println )。 私有状态字符串(throwsioexception )映射，字符串参数=新散列字符串，字符串)； //公共参数params.put(method，) taobao.item.seller.get )； Params.put(app_key )，appKey )； Params.put('session '，sessionKey )； date format df=newsimpledateformat (yyyy-mm-ddhh : mm : ss )； Params.put('timestamp '，df.format ) newdate ) )； params.put (格式，) json )； Params.put('v )、' 2.0 )； Params.put(sign_method )、(hmac )； //业务参数params.put('fields '，' num_iid，title，nick，price，num ' )； Params.put(num_iid )，) 123456789 )； //签名参数params.put(sign )，signtoprequest ) params，appSecret，SIGN_METHOD_HMAC )； 请使用//APIreturncallapi(newURL )、params； (签署/* *顶级请求。 * /私有静态字符串(映射字符串)
g, String> params, String secret, String signMethod) throws IOException {// 第一步：检查参数是否已经排序String[] keys = params.keySet().toArray(new String[0]);Arrays.sort(keys);// 第二步：把所有参数名和参数值串在一起StringBuilder query = new StringBuilder();if (SIGN_METHOD_MD5.equals(signMethod)) {query.append(secret);}for (String key : keys) {String value = params.get(key);if (isNotEmpty(key) && isNotEmpty(value)) {query.append(key).append(value);}}// 第三步：使用MD5/HMAC加密byte[] bytes;if (SIGN_METHOD_HMAC.equals(signMethod)) {bytes = encryptHMAC(query.toString(), secret);} else {query.append(secret);bytes = encryptMD5(query.toString());}// 第四步：把二进制转化为大写的十六进制return byte2hex(bytes);}/** * 对字节流进行HMAC_MD5摘要。 */private static byte[] encryptHMAC(String data, String secret) throws IOException {byte[] bytes = null;try {SecretKey secretKey = new SecretKeySpec(secret.getBytes(CHARSET_UTF8), "HmacMD5");Mac mac = Mac.getInstance(secretKey.getAlgorithm());mac.init(secretKey);bytes = mac.doFinal(data.getBytes(CHARSET_UTF8));} catch (GeneralSecurityException gse) {throw new IOException(gse.toString());}return bytes;}/** * 对字符串采用UTF-8编码后，用MD5进行摘要。 */private static byte[] encryptMD5(String data) throws IOException {return encryptMD5(data.getBytes(CHARSET_UTF8));}/** * 对字节流进行MD5摘要。 */private static byte[] encryptMD5(byte[] data) throws IOException {byte[] bytes = null;try {MessageDigest md = MessageDigest.getInstance("MD5");bytes = md.digest(data);} catch (GeneralSecurityException gse) {throw new IOException(gse.toString());}return bytes;}/** * 把字节流转换为十六进制表示方式。 */private static String byte2hex(byte[] bytes) {StringBuilder sign = new StringBuilder();for (int i = 0; i < bytes.length; i++) {String hex = Integer.toHexString(bytes[i] & 0xFF);if (hex.length() == 1) {sign.append("0");}sign.append(hex.toUpperCase());}return sign.toString();}private static String callApi(URL url, Map<String, String> params) throws IOException {String query = buildQuery(params, CHARSET_UTF8);byte[] content = {};if (query != null) {content = query.getBytes(CHARSET_UTF8);}HttpURLConnection conn = null;OutputStream out = null;String rsp = null;try {conn = (HttpURLConnection) url.openConnection();conn.setRequestMethod("POST");conn.setDoInput(true);conn.setDoOutput(true);conn.setRequestProperty("Host", url.getHost());conn.setRequestProperty("Accept", "text/xml,text/javascript");conn.setRequestProperty("User-Agent", "top-sdk-java");conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=" + CHARSET_UTF8);out = conn.getOutputStream();out.write(content);rsp = getResponseAsString(conn);} finally {if (out != null) {out.close();}if (conn != null) {conn.disconnect();}}return rsp;}private static String buildQuery(Map<String, String> params, String charset) throws IOException {if (params == null || params.isEmpty()) {return null;}StringBuilder query = new StringBuilder();Set<Entry<String, String>> entries = params.entrySet();boolean hasParam = false;for (Entry<String, String> entry : entries) {String name = entry.getKey();String value = entry.getValue();// 忽略参数名或参数值为空的参数if (isNotEmpty(name) && isNotEmpty(value)) {if (hasParam) {query.append("&");} else {hasParam = true;}query.append(name).append("=").append(URLEncoder.encode(value, charset));}}return query.toString();}private static String getResponseAsString(HttpURLConnection conn) throws IOException {String charset = getResponseCharset(conn.getContentType());if (conn.getResponseCode() < 400) {String contentEncoding = conn.getContentEncoding();if (CONTENT_ENCODING_GZIP.equalsIgnoreCase(contentEncoding)) {return getStreamAsString(new GZIPInputStream(conn.getInputStream()), charset);} else {return getStreamAsString(conn.getInputStream(), charset);}} else {// Client Error 4xx and Server Error 5xxthrow new IOException(conn.getResponseCode() + " " + conn.getResponseMessage());}}private static String getStreamAsString(InputStream stream, String charset) throws IOException {try {Reader reader = new InputStreamReader(stream, charset);StringBuilder response = new StringBuilder();final char[] buff = new char[1024];int read = 0;while ((read = reader.read(buff)) > 0) {response.append(buff, 0, read);}return response.toString();} finally {if (stream != null) {stream.close();}}}private static String getResponseCharset(String ctype) {String charset = CHARSET_UTF8;if (isNotEmpty(ctype)) {String[] params = ctype.split(";");for (String param : params) {param = param.trim();if (param.startsWith("charset")) {String[] pair = param.split("=", 2);if (pair.length == 2) {if (isNotEmpty(pair[1])) {charset = pair[1].trim();}}break;}}}return charset;}private static boolean isNotEmpty(String value) {int strLen;if (value == null || (strLen = value.length()) == 0) {return false;}for (int i = 0; i < strLen; i++) {if ((Character.isWhitespace(value.charAt(i)) == false)) {return true;}}return false;}}
注：该示例是在沙箱环境下调用，获取的是沙箱中的数据。若要获取线上环境的数据，请填写自己创建应用获取过来的AppKey与AppSecret，并更改调用接口的环境地址为线上地址，同时使用线上淘宝账号获取授权SessionKey。