文档章节

阿里大于调用代码

 放牧少年
发布于 2017/05/23 17:00
字数 898
阅读 25
收藏 0
package com.ykt.mq.queue.msg;

import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.Reader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.security.GeneralSecurityException;
import java.security.MessageDigest;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
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.GZIPInputStream;

import javax.crypto.Mac;
import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;

public class Snd {

	private static final String SIGN_METHOD_MD5 = "md5";
	private static final String SIGN_METHOD_HMAC = "hmac";
	private static final String CHARSET_UTF8 = "utf-8";
	private static final String CONTENT_ENCODING_GZIP = "gzip";

	// TOP服务地址,正式环境需要设置为http://gw.api.taobao.com/router/rest
	private static final String serverUrl = "http://gw.api.taobao.com/router/rest";
	private static final String appKey = "23858379"; // 可替换为您的沙箱环境应用的appKey
	private static final String appSecret = "1b8802c9e6c19c732cef6eb62a8404e2"; // 可替换为您的沙箱环境应用的appSecret
//	private static final String sessionKey = "test"; // 必须替换为沙箱账号授权得到的真实有效sessionKey

	public static void main(String[] args) throws Exception {
		System.out.println(getSellerItem());
	}

	private static String getSellerItem() throws IOException {
		Map<String, String> params = new HashMap<String, String>();
		// 公共参数
		params.put("method", "alibaba.aliqin.fc.sms.num.send");
		params.put("app_key", appKey);
		params.put("sign_method", SIGN_METHOD_MD5);
		DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		params.put("timestamp", df.format(new Date()));
		params.put("format", "json");
		params.put("v", "2.0");
		// 业务参数
		params.put("sms_type", "normal");
		params.put("sms_free_sign_name", "放牧少年");
		params.put("sms_param", "{aaa:'66666622345',bbb:'34.00'}");
		params.put("rec_num", "18221148872");
		params.put("sms_template_code", "SMS_67965123");
		params.put("rec_num", "13022111307");
		// 签名参数
		params.put("sign", signTopRequest(params, appSecret, SIGN_METHOD_MD5));
		// 请用API
		return callApi(new URL(serverUrl), params);
	}

	/**
	 * 对TOP请求进行签名。
	 */
	private static String signTopRequest(Map<String, 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 5xx
			throw 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;
	}

}

 

© 著作权归作者所有

粉丝 0
博文 31
码字总数 17279
作品 0
浦东
程序员
私信 提问
flc1125/alidayu

阿里大于(鱼) - v2.0 PS:阿里短信 https://github.com/flc1125/dysms 更新 v2.0.6 (2017-08-12) fixed #6 v2.0.5 (2017-01-25) 修复autoload.php https://github.com/flc1125/alidayu/issue......

flc1125
2017/03/10
0
0
程序员的我是这样抢票的(Python)

马上就要回家过年了,你的票买好了吗。 虽然我不用抢票,但是还是研究了一下怎么抢票。 程序员嘛,就是要对一切问题进行解构,探索原理本质,寻找规律,将其自动化。。。 好了,言归正传,开...

敲铁震锁
2018/01/13
0
0
【2017-12-06】王颖墅:工作日志

1.协助修改用户APP 2.修改阿里大于版本代码1.0升级2.0以适配新申请APPID

wys_
2017/12/06
3
0
像Google一样构建机器学习系统3 - 利用MPIJob运行ResNet101

本系列将利用阿里云容器服务,帮助您上手Kubeflow Pipelines. 第一篇:在阿里云上搭建Kubeflow Pipelines 第二篇:开发你的机器学习工作流 第三篇:利用MPIJob运行ResNet101 从上篇文章中,我...

必嘫
05/17
0
0
智能媒体管理产品“文档标准型”使用介绍

一、导语 智能媒体管理 (Intelligent Media Management, IMM) 是阿里云的云服务它通过 文档标准型 实例提供了 Cloud Native 架构的文档转换/预览功能本文介绍功能使用、计费相关的配置。 二、...

luoqingchao
2018/09/27
0
0

没有更多内容

加载失败,请刷新页面

加载更多

cleanLastUpdated.bat

@echo offrem create by AnXiaole rem 这里写你的仓库路径set REPOSITORY_PATH=C:\Users\AnXiaole\.m2\repositoryrem 正在搜索...for /f "delims=" %%i in ('dir /b /s "%REPO......

安小乐
8分钟前
1
0
操作放大器的用法是什么?

  有区别   1、单级放大的倍数比较有限,一般在100倍以下。放大倍数很大的话,负反馈就比较浅,对于放大倍数的稳定性不利。假如需要放大倍数更高,就不得不动用多级放大电路了。单级放大...

仙溪
11分钟前
2
0
c++ 上传文件 curl

bool uploadFile(std::string url, std::string file, std::string auth) { boost::filesystem::path p(file); CURL *curl; CURLcode res; struct curl_httppost *for......

青黑
17分钟前
2
0
冒泡与插入排序的代码实现

// 冒泡排序,a 表示数组,n 表示数组大小public void bubbleSort(int[] a, int n) { if (n <= 1) return; for (int i = 0; i < n; ++i) { // 提前退出冒泡循环的标志位 ...

无名氏的程序员
20分钟前
3
0
centos7.6 +mhvtl1.6安装

以前的mhvtl都是在centos6.x,5.x上安装的mhvtl以前版本为1.4,现在最新的1.6出来,可以安装在centos7.6上,下面是安装过程: 1.安装基础包 centos7.6只要能上外网,默认是配置了yun源的,这些...

突突突酱
21分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部