1. 程式人生 > 其它 >JAVA中呼叫阿里雲語音通知Api並接收訊息回執

JAVA中呼叫阿里雲語音通知Api並接收訊息回執

技術標籤:java

JAVA中呼叫阿里雲語音通知Api並接收訊息回執

配置檔案

在這裡插入圖片描述
需要的包

<dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-dyvmsapi</artifactId>
            <version>1.2.2</version>
        </dependency>
        <dependency>
            <
groupId>
com.aliyun</groupId> <artifactId>aliyun-java-sdk-core</artifactId> <version>4.5.0</version> <scope>compile</scope> </dependency> <dependency> <groupId>com.aliyun.mns</groupId>
<artifactId>aliyun-sdk-mns</artifactId> <version>1.1.8</version> </dependency> <dependency> <groupId>com.aliyun</groupId> <artifactId>dyvmsapi20170525</artifactId> <version>
0.0.2</version> </dependency> <dependency> <groupId>com.meiyuan</groupId> <artifactId>alicom-mns-receive-sdk-0.0.1-SNAPSHOT</artifactId> <version>1.0.0</version> </dependency>

具體程式碼及步驟

1.獲取配置檔案中的引數


package com.meiyuan.reservation.dto.call;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

import java.io.Serializable;

/**
 * 功能描述:ali雲 語音通知輔助類實體
 *
 * @author tc
 * @version 1.0
 * @since 2020/12/15 17:24
 */
@Data
@Configuration
@ConfigurationProperties(prefix = "aliyun")
public class ClientConfigDto implements Serializable {

    private static final long serialVersionUID = 7736942314547915021L;

    private String accessKeyId;
    
    private String accessKeySecret;

    private String regionId;

    private String voiceCode;

    private String product;

    private String domain;
}

2.呼叫阿里雲語音Api,三種不同的呼叫方式,根據需要選擇呼叫


package com.meiyuan.reservation.call;

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.dyvmsapi.model.v20170525.IvrCallRequest;
import com.aliyuncs.dyvmsapi.model.v20170525.IvrCallResponse;
import com.aliyuncs.dyvmsapi.model.v20170525.SingleCallByTtsRequest;
import com.aliyuncs.dyvmsapi.model.v20170525.SingleCallByTtsResponse;
import com.aliyuncs.dyvmsapi.model.v20170525.SingleCallByVoiceRequest;
import com.aliyuncs.dyvmsapi.model.v20170525.SingleCallByVoiceResponse;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;
import com.meiyuan.reservation.dao.ReservationDao;
import com.meiyuan.reservation.dto.call.ClientConfigDto;
import com.meiyuan.reservation.entity.ReservationEntity;
import com.meiyuan.reservation.enums.ResTypeEnum;
import lombok.extern.slf4j.Slf4j;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 功能描述:ali雲 語音通知輔助類
 *
 * @author tc
 * @version 1.0
 * @since 2020/12/15 17:17
 */
@Slf4j
public class VmsDemo {

    @Resource
    private ReservationDao reservationDao;

    /**
     * 文字轉語音外呼
     * @return
     * @throws ClientException
     */
    public SingleCallByTtsResponse singleCallByTts(ClientConfigDto dto, String calledNumber, String reservationId) throws ClientException {
        //設定訪問超時時間
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");
        //初始化acsClient 暫時不支援多region
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", dto.getAccessKeyId(), dto.getAccessKeySecret());
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", dto.getProduct(), dto.getDomain());
        IAcsClient acsClient = new DefaultAcsClient(profile);
        SingleCallByTtsRequest request = new SingleCallByTtsRequest();
        // 被叫顯號,若您使用的模板為公共號池號碼外呼模板,則該欄位值必須為空;
        // 若您使用的模板為專屬號碼外呼模板,則必須傳入已購買的號碼,僅支援一個號碼,您可以在語音服務控制檯上檢視已購買的號碼。
        //TODO:目前使用號碼池隨機號碼,後續可能會改為專屬號碼
        request.setCalledShowNumber("");
        //必填-被叫號碼(店長)
        request.setCalledNumber(calledNumber);
        //必填-Tts模板ID
        request.setTtsCode(dto.getVoiceCode());
        // 這裡主要是填寫我們語音文字模板裡面的引數 ${param}
        ReservationEntity reservationEntity = reservationDao.selectById(reservationId);
        String tailNumber = reservationEntity.getContactPhone().substring(7, 10);
        String type = "";
        if (ResTypeEnum.RES_GOODS.getValue().equals(reservationEntity.getType())) {
            type = "提貨";
        } else if (ResTypeEnum.RES_SERVICE.getValue().equals(reservationEntity.getType())) {
            type = "服務";
        } else if (ResTypeEnum.RES_SERVICE_GOODS.getValue().equals(reservationEntity.getType())) {
            type = "提貨和服務";
        }
        Date time = reservationEntity.getReservationTime();
        request.setTtsParam("{\"tailNumber\":\"" + tailNumber + "\", \"type\":\"" + type + "\",\"time\":\"" + time + "\"\"}");
        //可選-音量 取值範圍 0--200
        request.setVolume(200);
        //可選-播放次數
        request.setPlayTimes(2);
        //可選-外部擴充套件欄位,此ID將在回執訊息中帶回給呼叫方
        request.setOutId(reservationId);
        SingleCallByTtsResponse singleCallByTtsResponse = acsClient.getAcsResponse(request);
        if (singleCallByTtsResponse.getCode() != null && singleCallByTtsResponse.getCode().equals("OK")) {
            //請求成功
            log.info("請求成功");
        }
        return singleCallByTtsResponse;
    }

    /**
     * 語音檔案外呼
     *
     * @return
     * @throws ClientException
     */
    public SingleCallByVoiceResponse singleCallByVoice(ClientConfigDto dto) throws ClientException {

        //可自助調整超時時間
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");

        //初始化acsClient,暫不支援region化
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", dto.getAccessKeyId(), dto.getAccessKeySecret());
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", dto.getProduct(), dto.getDomain());
        IAcsClient acsClient = new DefaultAcsClient(profile);

        //組裝請求物件-具體描述見控制檯-文件部分內容
        SingleCallByVoiceRequest request = new SingleCallByVoiceRequest();
        //必填-被叫顯號,可在語音控制檯中找到所購買的顯號
        request.setCalledShowNumber("025000000");
        //必填-被叫號碼
        request.setCalledNumber("15000000000");
        //必填-語音檔案ID
        request.setVoiceCode("3a7c382b-ee87-493f-bfa0-b9fd6f31f8bb.wav");
        //可選-外部擴充套件欄位
        request.setOutId("yourOutId");

        //hint 此處可能會丟擲異常,注意catch
        SingleCallByVoiceResponse singleCallByVoiceResponse = acsClient.getAcsResponse(request);

        return singleCallByVoiceResponse;
    }

    /**
     * 互動式語音應答
     *
     * @return
     * @throws ClientException
     */
    public IvrCallResponse ivrCall(ClientConfigDto dto) throws ClientException {
        //可自助調整超時時間
        System.setProperty("sun.net.client.defaultConnectTimeout", "10000");
        System.setProperty("sun.net.client.defaultReadTimeout", "10000");

        //初始化acsClient,暫不支援region化
        IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", dto.getAccessKeyId(), dto.getAccessKeySecret());
        DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou", dto.getProduct(), dto.getDomain());
        IAcsClient acsClient = new DefaultAcsClient(profile);

        //組裝請求物件-具體描述見控制檯-文件部分內容
        IvrCallRequest request = new IvrCallRequest();
        //必填-被叫顯號,可在語音控制檯中找到所購買的顯號
        request.setCalledShowNumber("057156210000");
        //必填-被叫號碼
        request.setCalledNumber("15000000000");
        request.setPlayTimes(3L);

        //必填-語音檔案ID或者tts模板的模板號,有引數的模板需要設定模板變數的值
        //request.setStartCode("ebe3a2b5-c287-42a4-8299-fc40ae79a89f.wav");
        request.setStartCode("TTS_713900000");
        request.setStartTtsParams("{\"product\":\"aliyun\",\"code\":\"123\"}");
        List<IvrCallRequest.MenuKeyMap> menuKeyMaps = new ArrayList<IvrCallRequest.MenuKeyMap>();
        IvrCallRequest.MenuKeyMap menuKeyMap1 = new IvrCallRequest.MenuKeyMap();
        menuKeyMap1.setKey("1");
        menuKeyMap1.setCode("9a9d7222-670f-40b0-a3af.wav");
        menuKeyMaps.add(menuKeyMap1);
        IvrCallRequest.MenuKeyMap menuKeyMap2 = new IvrCallRequest.MenuKeyMap();
        menuKeyMap2.setKey("2");
        menuKeyMap2.setCode("44e3e577-3d3a-418f-932c.wav");
        menuKeyMaps.add(menuKeyMap2);
        IvrCallRequest.MenuKeyMap menuKeyMap3 = new IvrCallRequest.MenuKeyMap();
        menuKeyMap3.setKey("3");
        menuKeyMap3.setCode("TTS_71390000");
        menuKeyMap3.setTtsParams("{\"product\":\"aliyun\",\"code\":\"123\"}");
        menuKeyMaps.add(menuKeyMap3);
        request.setMenuKeyMaps(menuKeyMaps);
        //結束語可以使一個無參模板或者一個語音檔案ID
        request.setByeCode("TTS_71400007");

        //可選-外部擴充套件欄位
        request.setOutId("yourOutId");

        //hint 此處可能會丟擲異常,注意catch
        IvrCallResponse ivrCallResponse = acsClient.getAcsResponse(request);

        return ivrCallResponse;
    }
}

3.呼叫完成之後,如果想要接收訊息的回執


package com.meiyuan.reservation.call;

/**
 * 功能描述:接收aliyun語音回執訊息
 *
 * @author tc
 * @version V1.0.0
 * @since 2020/12/17 15:45
 */

import com.alicom.mns.tools.DefaultAlicomMessagePuller;
import com.alicom.mns.tools.MessageListener;
import com.alicp.jetcache.anno.CreateCache;
import com.aliyun.mns.model.Message;
import com.aliyuncs.exceptions.ClientException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.google.gson.Gson;
import com.meiyuan.commons.tools.redis.JetcacheNames;
import com.meiyuan.commons.tools.utils.JsonUtils;
import com.meiyuan.commons.tools.utils.SpringContextUtils;
import com.meiyuan.marsh.jetcache.AdvancedCache;
import com.meiyuan.marsh.jetcache.anno.AdvancedCreateCache;
import com.meiyuan.reservation.entity.VoiceReportEntity;
import com.meiyuan.reservation.enums.ResCallStatusEnum;
import com.meiyuan.reservation.enums.TimeEnum;
import com.meiyuan.reservation.mq.sender.ReservationMqSender;
import dao.VoiceReportDao;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;

import java.text.ParseException;
import java.util.HashMap;

import static java.lang.System.currentTimeMillis;

/**
 * 只能用於接收雲通訊的訊息,不能用於接收其他業務的訊息
 * 語音上行訊息接收demo
 */
@Slf4j
public class CallReceive {

    private static Log logger = LogFactory.getLog(CallReceive.class);

    @AdvancedCreateCache(@CreateCache(name = JetcacheNames.PREFIX_SEQ_RESERVATION))
    private AdvancedCache cache;

    @Autowired
    private VoiceReportDao voiceReportDao;

    public void callReceive(String accessKeyId, String accessKeySecret) throws ClientException, ParseException {
        log.info("開始接收回執訊息");
        DefaultAlicomMessagePuller puller = new DefaultAlicomMessagePuller();
        /*
         * TODO 將messageType和queueName替換成您需要的訊息型別名稱和對應的佇列名稱
         */
        String messageType = "VoiceReport";//此處應該替換成相應產品的訊息型別
        String queueName = "your_queueName";//在雲通訊頁面開通相應業務訊息後,就能在頁面上獲得對應的queueName,每一個訊息型別
        puller.startReceiveMsg(accessKeyId, accessKeySecret, messageType, queueName, new MyMessageListener());
    }

    class MyMessageListener implements MessageListener {
        private Gson gson = new Gson();

        @Override
        public boolean dealMessage(Message message) {

            try {
                String messageBody = message.getMessageBodyAsString();
                VoiceReportEntity voiceReportEntity = JsonUtils.jsonToObject(messageBody, new TypeReference<VoiceReportEntity>() {
                });
                //這裡是自己的業務邏輯
                //將回執資訊存入資料庫
                voiceReportDao.insert(voiceReportEntity);
                String statusCode = voiceReportEntity.getStatusCode();
                String phoneNumber = voiceReportEntity.getCallee();
                String reservationId = voiceReportEntity.getOutId();
                //根據狀態碼判斷下一步處理邏輯
                //1.未接聽,佔線,關機(10分鐘後重試,重試一次)
                if (statusCode.equals(ResCallStatusEnum.USER_NOT_ANSWER.getValue()) || statusCode.equals(ResCallStatusEnum.USER_BUSY.getValue())
                        || statusCode.equals(ResCallStatusEnum.USER_SWITCH_OFF.getValue())) {
                    if ((Integer) cache.get(reservationId) == 1) {
                        long millis = currentTimeMillis() + TimeEnum.INTERVAL_TIME.getValue();
                        ReservationMqSender reservationMqSender = SpringContextUtils.getBean(ReservationMqSender.class);
                        HashMap<String, String> map = new HashMap<>();
                        map.put("phone", phoneNumber);
                        map.put("reservationId", reservationId);
                        reservationMqSender.sendLaunchMsg(map, millis);
                        cache.increment(reservationId, 1);
                    }
                } else {
                    //2.無效號碼,無法接通,停機(不處理)
                    logger.error("使用者停機或無法接通");
                }
            } catch (com.google.gson.JsonSyntaxException e) {
                logger.error("error_json_format:" + message.getMessageBodyAsString(), e);
                //理論上不會出現格式錯誤的情況,所以遇見格式錯誤的訊息,只能先delete,否則重新推送也會一直報錯
                return true;
            } catch (Throwable e) {
                //您自己的程式碼部分導致的異常,應該return false,這樣訊息不會被delete掉,而會根據策略進行重推
                return false;
            }
            //訊息處理成功,返回true, SDK將呼叫MNS的delete方法將訊息從佇列中刪除掉
            return true;
        }

    }

}

我們對Markdown編輯器進行了一些功能拓展與語法支援,除了標準的Markdown編輯器功能,在這裡插入程式碼片我們增加了如下幾點新功能,幫助你用它寫部落格:

  1. 全新的介面設計 ,將會帶來全新的寫作體驗;
  2. 在創作中心設定你喜愛的程式碼高亮樣式,Markdown 將程式碼片顯示選擇的高亮樣式 進行展示;
  3. 增加了 圖片拖拽 功能,你可以將本地的圖片直接拖拽到編輯區域直接展示;
  4. 全新的 KaTeX數學公式 語法;
  5. 增加了支援甘特圖的mermaid語法1 功能;
  6. 增加了 多螢幕編輯 Markdown文章功能;
  7. 增加了 焦點寫作模式、預覽模式、簡潔寫作模式、左右區域同步滾輪設定 等功能,功能按鈕位於編輯區域與預覽區域中間;
  8. 增加了 檢查列表 功能。

功能快捷鍵

撤銷:Ctrl/Command + Z
重做:Ctrl/Command + Y
加粗:Ctrl/Command + B
斜體:Ctrl/Command + I
標題:Ctrl/Command + Shift + H
無序列表:Ctrl/Command + Shift + U
有序列表:Ctrl/Command + Shift + O
檢查列表:Ctrl/Command + Shift + C
插入程式碼:Ctrl/Command + Shift + K
插入連結:Ctrl/Command + Shift + L
插入圖片:Ctrl/Command + Shift + G
查詢:Ctrl/Command + F
替換:Ctrl/Command + G

合理的建立標題,有助於目錄的生成

直接輸入1次#,並按下space後,將生成1級標題。
輸入2次#,並按下space後,將生成2級標題。
以此類推,我們支援6級標題。有助於使用TOC語法後生成一個完美的目錄。

如何改變文字的樣式

強調文字 強調文字

加粗文字 加粗文字

標記文字

刪除文字

引用文字

H2O is是液體。

210 運算結果是 1024.

插入連結與圖片

連結: link.

圖片: Alt

帶尺寸的圖片: Alt

居中的圖片: Alt

居中並且帶尺寸的圖片: Alt

當然,我們為了讓使用者更加便捷,我們增加了圖片拖拽功能。

如何插入一段漂亮的程式碼片

部落格設定頁面,選擇一款你喜歡的程式碼片高亮樣式,下面展示同樣高亮的 程式碼片.

// An highlighted block
var foo = 'bar';

生成一個適合你的列表

  • 專案
    • 專案
      • 專案
  1. 專案1
  2. 專案2
  3. 專案3
  • 計劃任務
  • 完成任務

建立一個表格

一個簡單的表格是這麼建立的:

專案Value
電腦$1600
手機$12
導管$1

設定內容居中、居左、居右

使用:---------:居中
使用:----------居左
使用----------:居右

第一列第二列第三列
第一列文字居中第二列文字居右第三列文字居左

SmartyPants

SmartyPants將ASCII標點字元轉換為“智慧”印刷標點HTML實體。例如:

TYPEASCIIHTML
Single backticks'Isn't this fun?'‘Isn’t this fun?’
Quotes"Isn't this fun?"“Isn’t this fun?”
Dashes-- is en-dash, --- is em-dash– is en-dash, — is em-dash

建立一個自定義列表

Markdown
Text-to- HTML conversion tool
Authors
John
Luke

如何建立一個註腳

一個具有註腳的文字。2

註釋也是必不可少的

Markdown將文字轉換為 HTML

KaTeX數學公式

您可以使用渲染LaTeX數學表示式 KaTeX:

Gamma公式展示 Γ ( n ) = ( n − 1 ) ! ∀ n ∈ N \Gamma(n) = (n-1)!\quad\forall n\in\mathbb N Γ(n)=(n1)!nN 是通過尤拉積分

Γ ( z ) = ∫ 0 ∞ t z − 1 e − t d t   . \Gamma(z) = \int_0^\infty t^{z-1}e^{-t}dt\,. Γ(z)=0tz1etdt.

你可以找到更多關於的資訊 LaTeX 數學表示式here.

新的甘特圖功能,豐富你的文章

Mon 06 Mon 13 Mon 20 已完成 進行中 計劃一 計劃二 現有任務 Adding GANTT diagram functionality to mermaid
  • 關於 甘特圖 語法,參考 這兒,

UML 圖表

可以使用UML圖表進行渲染。 Mermaid. 例如下面產生的一個序列圖:

張三 李四 王五 你好!李四, 最近怎麼樣? 你最近怎麼樣,王五? 我很好,謝謝! 我很好,謝謝! 李四想了很長時間, 文字太長了 不適合放在一行. 打量著王五... 很好... 王五, 你怎麼樣? 張三 李四 王五

這將產生一個流程圖。:

連結 長方形 圓角長方形 菱形
  • 關於 Mermaid 語法,參考 這兒,

FLowchart流程圖

我們依舊會支援flowchart的流程圖:

Created with Raphaël 2.2.0 開始 我的操作 確認? 結束 yes no
  • 關於 Flowchart流程圖 語法,參考 這兒.

匯出與匯入

匯出

如果你想嘗試使用此編輯器, 你可以在此篇文章任意編輯。當你完成了一篇文章的寫作, 在上方工具欄找到 文章匯出 ,生成一個.md檔案或者.html檔案進行本地儲存。

匯入

如果你想載入一篇你寫過的.md檔案,在上方工具欄可以選擇匯入功能進行對應副檔名的檔案匯入,
繼續你的創作。


  1. mermaid語法說明 ↩︎

  2. 註腳的解釋 ↩︎