華為云隱私通話（AXB）

序言：

首先是需要在華為云上申請隱私通話服務的具體的大家可以去看官方檔案：隱私通話接入檔案  在這兒呢我主要介紹AXB模式，其他模式（AX、AXYB等）都是大同小異的，

AXB：是指A用戶和B用戶同時系結隱私號碼X，并且通過X進行通話，注意：1個X號碼允許系結1000對用戶號碼，但用戶號碼不可重復，例如，允許同時系結AXB和CXD，但不允許同時系結AXB和BXC

話不多說直接開整：

1.首先是系結介面

系結介面主要注意他的 msgdgt（簽名摘要），主要構成是：

1）把訊息頭（appkey和ts）、訊息體按key的字母原樣順序排序

2）排序后將密鑰、訊息頭（appkey和ts）和訊息體的所有key、value串起來以UTF-8編碼進行MD5加密，如：MD5(secretkey1value1key2value2..)

3）生成32位大寫的摘要字串，如：BA9854BED1A2986B061E2713F403C752

4）引數釋意

5）回應引數

6）代碼實作

 private String appKey="SXHWD_LJ1"; // APP_Key
    private String appSecret="sxhwd"; // APP_Secret
    private String ompDomainName="http://122.112.233.87:28080"; // APP接入地址

    /**
     * Build the real url of https request | 構建隱私保護通話平臺請求路徑
     *
     * @param path 介面訪問URI
     * @return
     */
    private String buildOmpUrl(String path) {
        return ompDomainName + path;
    }

    @Override
    public AjaxResult axbBindNumber(String relationNum, String callerNum, String calleeNum) {

//       //mode101:APP自帶x號碼
        //mode102:平臺分配x號碼
//        String url = "/v2/axb/mode101";
        String url = "/v2/axb/mode102";
        String realUrl = buildOmpUrl(url);

//       // 封裝JOSN請求
        JSONObject json = new JSONObject();
        //請求標識
        String requestId=UUID.randomUUID().toString();
        String nowData=new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date());
        //系結時長
        Long expiration=24*60*60*30L;
        json.put("requestId", requestId);
        json.put("telA", callerNum); // A方真實號碼(手機或固話)
        json.put("telB", calleeNum); // B方真實號碼(手機或固話)
//        json.put("telX", relationNum); // （虛擬號碼)mode101
        json.put("anucode", "0,0,0"); // 主叫側放音編碼
        json.put("subts", nowData); // 系結時間
        json.put("expiration", expiration); // 系結時間
        JSONObject extra = new JSONObject();
        extra.put("callrecording", "1");
        extra.put("callpickup", "1");
        json.put("extra", extra);
        log.info("請求地址", realUrl);

        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        try {
            URL url1 = new URL(realUrl);
            // 打開和URL之間的連接
            URLConnection conn = url1.openConnection();
            // 設定通用的請求屬性
            conn.setRequestProperty("appkey", "SXHWD_LJ1");
            conn.setRequestProperty("Accept", "application/json;charset=utf-8");
            conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
            conn.setRequestProperty("ts", nowData);
            String msgdgt = pingjie(appKey, nowData, json);
            conn.setRequestProperty("msgdgt", msgdgt);
            log.info("msgdgt{}"+msgdgt);
            // 發送POST請求必須設定如下兩行
            conn.setDoOutput(true);
            conn.setDoInput(true);

            // 獲取URLConnection物件對應的輸出流
            out = new PrintWriter(conn.getOutputStream());
            // 發送請求引數
            out.print(json.toJSONString());
            log.info("請求引數{}" + json);
            // flush輸出流的緩沖
            out.flush();
            // 定義BufferedReader輸入流來讀取URL的回應
            in = new BufferedReader(
                    new InputStreamReader(conn.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("發送 POST 請求出現例外！" + e);
            log.error("發送 POST 請求出現例外！{}", e);
            e.printStackTrace();
        }
        //使用finally塊來關閉輸出流、輸入流
        finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        log.info("回應資料{}" + result);
        JSONObject jsonObject = JSON.parseObject(result);
        String code=jsonObject.getString("code");
        //系結成功
        if ("0".equals(code)) {
            JSONObject data = JSON.parseObject(jsonObject.getString("subid"));
            //唯一標識
            String subid = data.getString("subid");
            String telX = data.getString("telX");
            //寫入資料庫
            LinjiaBindTel tel= bindTelService.selectByPhone(callerNum,calleeNum);
            LinjiaBindTel bindTel= new LinjiaBindTel();
            bindTel.setTelA(callerNum);
            bindTel.setTelB(calleeNum);
            bindTel.setTelX(telX);
            bindTel.setSubid(subid);
            if (tel !=null){
                //更新
                bindTelService.updateBindTel(bindTel);
                log.info("系結成功,telX{},telA{},telB{}",telX,callerNum,calleeNum);
                return AjaxResult.success("系結成功",telX);
            }
            //新增
            bindTelService.insertBindTel(bindTel);
            //開啟定時任務,時間到了洗掉記錄
            new Timer().schedule(new TimerTask() {
                @Override
                public void run() {
                    bindTelService.deleteTelBySubid(subid);
                    log.info("解綁成功,subid{}",subid);
                }
            },expiration);
            return AjaxResult.success("系結成功",telX);
        }else {
            return AjaxResult.error(jsonObject.getString("message"));
        }
    }

    /**
     * 生成 msgdgt 驗證
     * @param appKey
     * @param ts
     * @param json
     * @return
     */
    public String pingjie(String appKey, String ts, JSONObject json) {
        Map map = new HashMap();
        map.put("appkey", appKey);
        map.put("ts", ts);
        //json等于null（解綁），反之系結
        if (json != null){
            JSONObject extra = (JSONObject) json.get("extra");
            json.remove("extra");
            map.putAll(JSON.parseObject(json.toJSONString(), Map.class));
            map.putAll(JSON.parseObject(extra.toJSONString(), Map.class));
            //將extra重新加入
            JSONObject extra2 = new JSONObject();
            extra2.put("callrecording", "1");
            extra2.put("callpickup", "1");
            json.put("extra", extra2);
        }
        String str = appSecret.concat(getMapToString(sortByKey(map)));
        log.info("未加密{}" + str);
        return MD5.MD5Encode(str);
    }

    /**
     * 按map的key排序
     * @param map
     * @return
     */
    private Map<String, Object> sortByKey(Map<String, Object> map) {
        Map<String, Object> result = new LinkedHashMap<>(map.size());
        map.entrySet().stream()
                .sorted(Map.Entry.comparingByKey())
                .forEachOrdered(e -> result.put(e.getKey(), e.getValue()));
        return result;
    }

    /**
     * map轉string
     * @param map
     * @return
     */
    public static String getMapToString(Map<String, Object> map) {
        Set<String> keySet = map.keySet();
        //將set集合轉換為陣列
        String[] keyArray = keySet.toArray(new String[keySet.size()]);
        //因為String拼接效率會很低的，所以轉用StringBuilder
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < keyArray.length; i++) {
            // 引數值為空，則不參與簽名 這個方法trim()是去空格
            if ((String.valueOf(map.get(keyArray[i]))).trim().length() > 0) {
                sb.append(keyArray[i]).append(String.valueOf(map.get(keyArray[i])).trim());
            }

        }
        return sb.toString();
    }

 2.解綁

1）引數

2）回應引數

  {

"code": "0",

"message": "success"
}

3）解綁代碼

String url = "/v2/axb/";
String realUrl = buildOmpUrl(url)+subscriptionId;
String nowData=new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date());
HttpURLConnection httpURLConnection = null;
try {
    URL url1 = new URL(realUrl);
    httpURLConnection = (HttpURLConnection) url1.openConnection();
    httpURLConnection.setRequestProperty("Content-Type","application/x-www-form-urlencoded");
    httpURLConnection.setRequestProperty("appkey", "SXHWD_LJ1");
    httpURLConnection.setRequestProperty("Accept", "application/json;charset=utf-8");
    httpURLConnection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
    httpURLConnection.setRequestProperty("ts", nowData);
    String msgdgt = pingjie(appKey, nowData, null);
    httpURLConnection.setRequestProperty("msgdgt", msgdgt);
    httpURLConnection.setRequestMethod("DELETE");
    //請求不能使用快取
    httpURLConnection.setUseCaches(false);
    //允許向urlConnection寫出
    httpURLConnection.setDoOutput(true);
    //允許從urlConnection讀入
    httpURLConnection.setDoInput(true);

    //獲取連接
    httpURLConnection.connect();
    //得到輸出流物件
    OutputStream outputStream = httpURLConnection.getOutputStream();
    DataOutputStream dataOutPutStream = new DataOutputStream(outputStream);
    //向輸出流寫資料，這些資料將存到記憶體緩沖區
    //重繪物件輸出流,將位元組都寫入到流中
    dataOutPutStream.flush();
    //呼叫getInputStream()函式時才把準備好的http請求正式發送到服務器，getInputStream的回傳值是InputStream
    InputStream inputStream = httpURLConnection.getInputStream();
    //回傳的輸入流用于讀取服務器對此次http請求回傳的資訊
    BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream,"utf-8"));
    String s = "";
    StringBuilder stringBuilder = new StringBuilder();
    while((s = bufferedReader.readLine()) != null){
        stringBuilder.append(s);
    }
    bufferedReader.close();
    dataOutPutStream.close();

    System.out.println(stringBuilder.toString());
} catch (IOException exception) {
    exception.printStackTrace();
} finally {
    if (httpURLConnection != null) {
        httpURLConnection.disconnect();
    }
}

歡迎大家補充哦！！！

標籤：其他

上一篇：如何有效地遍歷Java Map中的每個條目？

下一篇：Java基礎——File類與IO流