客户端请求代码

Java

  1. import java.io.IOException;
  2. import java.net.URLEncoder;
  3. import java.security.MessageDigest;
  4. import java.text.SimpleDateFormat;
  5. import java.util.ArrayList;
  6. import java.util.Collections;
  7. import java.util.Date;
  8. import java.util.HashMap;
  9. import java.util.List;
  10. import java.util.Map;
  11. import java.util.Set;
  13. import org.junit.Test;
  15. import com.alibaba.fastjson.JSON;
  17. import junit.framework.TestCase;
  19. public class PostTest extends TestCase {
  21.     @Test
  22.     public void testPost() throws IOException {
  23.         String appKey = "test";
  24.         String secret = "123456";
  25.         // 业务参数
  26.         Map<String, String> jsonMap = new HashMap<String, String>();
  27.         jsonMap.put("goodsName", "iphoneX");
  29.         String json = JSON.toJSONString(jsonMap);
  30.         json = URLEncoder.encode(json, "utf-8");
  32.         // 系统参数
  33.         Map<String, Object> param = new HashMap<String, Object>();
  34.         param.put("name", "goods.get");
  35.         param.put("app_key", appKey);
  36.         param.put("data", json);
  37.         param.put("timestamp", getTime());
  38.         param.put("version", "");
  40.         String sign = buildSign(param, secret);
  42.         param.put("sign", sign);
  44.         System.out.println("=====请求数据=====");
  45.         System.out.println(JSON.toJSON(param));
  46.     }
  48.     /**
  49.      * 构建签名
  50.      *
  51.      * @param paramsMap
  52.      *            参数
  53.      * @param secret
  54.      *            密钥
  55.      * @return
  56.      * @throws IOException
  57.      */
  58.     public static String buildSign(Map<String, ?> paramsMap, String secret) throws IOException {
  59.         Set<String> keySet = paramsMap.keySet();
  60.         List<String> paramNames = new ArrayList<String>(keySet);
  62.         Collections.sort(paramNames);
  64.         StringBuilder paramNameValue = new StringBuilder();
  66.         for (String paramName : paramNames) {
  67.             paramNameValue.append(paramName).append(paramsMap.get(paramName));
  68.         }
  70.         String source = secret + paramNameValue.toString() + secret;
  72.         return md5(source);
  73.     }
  75.     /**
  76.      * 生成md5,全部大写
  77.      *
  78.      * @param message
  79.      * @return
  80.      */
  81.     public static String md5(String message) {
  82.         try {
  83.             // 1 创建一个提供信息摘要算法的对象，初始化为md5算法对象
  84.             MessageDigest md = MessageDigest.getInstance("MD5");
  86.             // 2 将消息变成byte数组
  87.             byte[] input = message.getBytes();
  89.             // 3 计算后获得字节数组,这就是那128位了
  90.             byte[] buff = md.digest(input);
  92.             // 4 把数组每一字节（一个字节占八位）换成16进制连成md5字符串
  93.             return byte2hex(buff);
  94.         } catch (Exception e) {
  95.             throw new RuntimeException(e);
  96.         }
  97.     }
  99.     /**
  100.      * 二进制转十六进制字符串
  101.      *
  102.      * @param bytes
  103.      * @return
  104.      */
  105.     private static String byte2hex(byte[] bytes) {
  106.         StringBuilder sign = new StringBuilder();
  107.         for (int i = 0; i < bytes.length; i++) {
  108.             String hex = Integer.toHexString(bytes[i] & 0xFF);
  109.             if (hex.length() == 1) {
  110.                 sign.append("0");
  111.             }
  112.             sign.append(hex.toUpperCase());
  113.         }
  114.         return sign.toString();
  115.     }
  117.     public String getTime() {
  118.         return new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
  119.     }
  120. }

JavaScript

  1. /**
  2. //需要发布到服务器上运行，并且server端需要处理跨域
  3. //在IndexController.java上加@CrossOrigin(origins={"*"})
  5. sdk.config({
  6.     url : 'http://localhost:8080/api'
  7.     ,app_key : 'test'
  8.     ,secret : '123456'
  9.     ,jwt : 'xxx'
  10. });
  12. sdk.post({
  13.     name   : 'goods.get' // 接口名
  14. //     ,version:'1.0'
  15. //     ,access_token:''
  16.     ,data  : {'goods_name':'iphone'} // 请求参数
  17.     ,callback:function(resp) { // 成功回调
  18.         console.log(resp)
  19.     }
  20. });
  22. sdk.post({
  23.     name   : 'goods.get' // 接口名
  24.     ,data  : {'goods_name':'iphone'} // 请求参数
  25.     ,callback:function(resp) { // 成功回调
  26.         console.log(resp)
  27.     }
  28. });
  29.  */
  30. ;(function(){
  32.     var config = {
  33.         url : 'http://127.0.0.1:8080/api'
  34.         ,app_key : 'test'
  35.         ,secret : '123456'
  36.         ,default_version : ''
  38.         ,api_name : "name"
  39.         ,version_name : "version"
  40.         ,app_key_name : "app_key"
  41.         ,data_name : "data"
  42.         ,timestamp_name : "timestamp"
  43.         ,sign_name : "sign"
  44.         ,format_name : "format"
  45.         ,access_token_name : "access_token"
  46.         ,jwt : ''
  47.     }
  49.     var DEFAULT_FORMAT = 'json';
  50.     var UPLOAD_FORM_DATA_NAME = 'body_data';
  51.     var CONTENT_TYPE_JSON = 'application/json';
  53.     var CONTENT_TYPE_KEY = 'Content-Type';
  54.     var POST_TYPE = 'POST';
  55.     var GET_TYPE = 'GET';
  57.     function copy(source, target) {
  58.         if (target && source && typeof source == 'object') {
  59.             for (var p in source) {
  60.                 target[p] = source[p];
  61.             }
  62.         }
  63.         return target;
  64.     }
  66.     function add0(m){return m<10?'0'+m:m }
  68.     function formatDate(time)
  69.     {
  70.         var y = time.getFullYear();
  71.         var m = time.getMonth()+1;
  72.         var d = time.getDate();
  73.         var h = time.getHours();
  74.         var mm = time.getMinutes();
  75.         var s = time.getSeconds();
  76.         return y+'-'+add0(m)+'-'+add0(d)+' '+add0(h)+':'+add0(mm)+':'+add0(s);
  77.     }
  79.     /** 构建签名 */
  80.     function buildSign(postData,secret) {
  81.         var paramNames = [];
  82.         for(var key in postData) {
  83.             paramNames.push(key);
  84.         }
  86.         paramNames.sort();
  88.         var paramNameValue = [];
  90.         for(var i=0,len=paramNames.length;i<len;i++) {
  91.             var paramName = paramNames[i];
  92.             paramNameValue.push(paramName);
  93.             paramNameValue.push(postData[paramName]);
  94.         }
  96.         var source = secret + paramNameValue.join('') + secret;
  97.         // MD5算法参见http://pajhome.org.uk/crypt/md5/
  98.         return hex_md5(source).toUpperCase();
  99.     }
  101.     var ajax = {
  102.         /**
  103.          * 提交请求
  104.          * @param opts.url 请求url
  105.          * @param opts.params 请求参数json
  106.          * @param opts.headers 请求header，json
  107.          * @param opts.form 表单dom对象
  108.          * @param opts.callback 回调
  109.          * @param opts.error 错误回调
  110.          */
  111.         request:function(opts) {
  112.             var url = opts.url;
  113.             var params = opts.params;
  114.             var headers = opts.headers;
  115.             var form = opts.form;
  116.             var callback = opts.callback;
  117.             var error = opts.error || function(e){alert('数据请求失败')};
  118.             var method = opts.method;
  119.             var paramStr = JSON.stringify(params);
  121.             var xhr = this.createXhrObject();
  123.             xhr.onreadystatechange = function() {
  124.                 var jsonData = '';
  125.                 if (xhr.readyState == 4){
  126.                     var status = xhr.status;
  127.                     if ((status >= 200 && status < 300) || status == 304){
  128.                         jsonData = JSON.parse(xhr.responseText);
  129.                         callback(jsonData, paramStr);
  130.                     } else {
  131.                         jsonData = JSON.parse('{"message":"后台请求错误(status:' + status + ')"}');
  132.                         console.log(xhr.responseText)
  133.                         error(jsonData, paramStr);
  134.                     }
  135.                 }
  136.             };
  138.             // 添加header
  139.             if(headers) {
  140.                 for (var key in headers) {
  141.                     xhr.setRequestHeader(key,headers[key]);
  142.                 }
  143.             }
  145.             if(method == GET_TYPE) {
  146.                 var queryString = [];
  147.                 for (var key in params) {
  148.                     var p = key + '=' + encodeURIComponent(params[key]);
  149.                     queryString.push(p);
  150.                 }
  151.                 url = url + '?' + queryString.join('&');
  152.                 xhr.open(method, url, true);
  153.                 xhr.send();
  154.             } else if(method == POST_TYPE) {
  155.                 xhr.open(method, url, true);
  156.                 if(form) {
  157.                     var formData = new FormData(form);
  158.                     // 添加json
  159.                     formData.append(UPLOAD_FORM_DATA_NAME, paramStr);
  160.                     xhr.send(formData);
  161.                 } else {
  162.                     xhr.setRequestHeader(CONTENT_TYPE_KEY, CONTENT_TYPE_JSON);
  163.                     xhr.send(paramStr);
  164.                 }
  165.             } else {
  166.                 throw new Error('不支持的method：' + method);
  167.             }
  169.         }
  170.         /**
  171.          * 创建XHR对象
  172.          * @private
  173.          */
  174.         ,createXhrObject:function() {
  175.             var methods = [
  176.                 function(){ return new XMLHttpRequest();}
  177.                 ,function(){ return new ActiveXObject('Msxml2.XMLHTTP');}
  178.                 ,function(){ return new ActiveXObject('Microsoft.XMLHTTP');}
  179.             ];
  181.             var xhr = null;
  182.             for(var i=0,len=methods.length; i<len; i++) {
  183.                 try {
  184.                     xhr = methods[i]();
  185.                 } catch (e) {
  186.                     continue;
  187.                 }
  189.                 this.createXhrObject = methods[i];
  191.                 return xhr;
  192.             }
  194.             throw new Error("创建XHR对象失败");
  195.         }
  196.     }
  198.     /**
  199.      * 请求
  200.      * @param opts.name 接口名
  201.      * @param opts.version 版本号
  202.      * @param opts.method 请求方式
  203.      * @param opts.data 请求数据，json对象
  204.      * @param opts.access_token
  205.      * @param opts.form 表单dom
  206.      * @param opts.callback 响应回调
  207.      * @param opts.jwt jwt
  208.      */
  209.     function request(opts) {
  210.         var name         = opts.name,
  211.         version     = opts.version || config.default_version,
  212.         data         = opts.data || {},
  213.         callback     = opts.callback,
  214.         accessToken = opts.access_token,
  215.         url            = opts.url || config.url;
  217.         var headers = {};
  218.         var postData = {};
  220.         postData[config.api_name] = name;
  221.         postData[config.version_name] = version;
  222.         postData[config.app_key_name] = config.app_key;
  223.         postData[config.data_name] = encodeURIComponent(JSON.stringify(data));
  224.         postData[config.timestamp_name] = formatDate(new Date());
  225.         postData[config.format_name] = DEFAULT_FORMAT;
  227.         if(accessToken) {
  228.             postData[config.access_token_name] = accessToken;
  229.         }
  231.         postData[config.sign_name] = buildSign(postData,config.secret);
  233.         var jwt = opts.jwt || config.jwt; // 优先使用opts中的jwt
  234.         if(jwt) {
  235.             headers['Authorization'] = 'Bearer ' + jwt;
  236.         }
  238.         ajax.request({
  239.             url:url
  240.             ,method:opts.method
  241.             ,params:postData
  242.             ,headers:headers
  243.             ,form:opts.form
  244.             ,callback:callback
  245.             ,error:opts.error
  246.         });
  247.     }
  249.     var sdk = {
  250.         config:function(cfg) {
  251.             copy(cfg,config);
  252.         }
  253.         /**
  254.          * post请求
  255.          * @param opts.name 接口名
  256.          * @param opts.version 版本号
  257.          * @param opts.data 请求数据，json对象
  258.          * @param opts.access_token
  259.          * @param opts.form 表单dom
  260.          * @param opts.callback 响应回调
  261.          * @param opts.jwt jwt
  262.          */
  263.         ,post:function(opts) {
  264.             opts.method = POST_TYPE;
  265.             request(opts);
  266.         }
  267.         /**
  268.          * get请求
  269.          * @param opts.name 接口名
  270.          * @param opts.version 版本号
  271.          * @param opts.data 请求数据，json对象
  272.          * @param opts.access_token
  273.          * @param opts.callback 响应回调
  274.          * @param opts.jwt jwt
  275.          */
  276.         ,get:function(opts) {
  277.             if(opts.form) {
  278.                 throw new Error('get方式不支持上传功能');
  279.             }
  280.             opts.method = GET_TYPE;
  281.             request(opts);
  282.          }
  284.     }
  286.     window.sdk = sdk;
  288. })();