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編輯器功能,在這裡插入程式碼片我們增加了如下幾點新功能,幫助你用它寫部落格:
- 全新的介面設計 ,將會帶來全新的寫作體驗;
- 在創作中心設定你喜愛的程式碼高亮樣式,Markdown 將程式碼片顯示選擇的高亮樣式 進行展示;
- 增加了 圖片拖拽 功能,你可以將本地的圖片直接拖拽到編輯區域直接展示;
- 全新的 KaTeX數學公式 語法;
- 增加了支援甘特圖的mermaid語法1 功能;
- 增加了 多螢幕編輯 Markdown文章功能;
- 增加了 焦點寫作模式、預覽模式、簡潔寫作模式、左右區域同步滾輪設定 等功能,功能按鈕位於編輯區域與預覽區域中間;
- 增加了 檢查列表 功能。
功能快捷鍵
撤銷: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.
圖片:
帶尺寸的圖片:
居中的圖片:
居中並且帶尺寸的圖片:
當然,我們為了讓使用者更加便捷,我們增加了圖片拖拽功能。
如何插入一段漂亮的程式碼片
去部落格設定頁面,選擇一款你喜歡的程式碼片高亮樣式,下面展示同樣高亮的 程式碼片
.
// An highlighted block
var foo = 'bar';
生成一個適合你的列表
- 專案
- 專案
- 專案
- 專案
- 專案1
- 專案2
- 專案3
- 計劃任務
- 完成任務
建立一個表格
一個簡單的表格是這麼建立的:
專案 | Value |
---|---|
電腦 | $1600 |
手機 | $12 |
導管 | $1 |
設定內容居中、居左、居右
使用:---------:
居中
使用:----------
居左
使用----------:
居右
第一列 | 第二列 | 第三列 |
---|---|---|
第一列文字居中 | 第二列文字居右 | 第三列文字居左 |
SmartyPants
SmartyPants將ASCII標點字元轉換為“智慧”印刷標點HTML實體。例如:
TYPE | ASCII | HTML |
---|---|---|
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)=(n−1)!∀n∈N 是通過尤拉積分
Γ ( z ) = ∫ 0 ∞ t z − 1 e − t d t . \Gamma(z) = \int_0^\infty t^{z-1}e^{-t}dt\,. Γ(z)=∫0∞tz−1e−tdt.
你可以找到更多關於的資訊 LaTeX 數學表示式here.
新的甘特圖功能,豐富你的文章
- 關於 甘特圖 語法,參考 這兒,
UML 圖表
可以使用UML圖表進行渲染。 Mermaid. 例如下面產生的一個序列圖:
這將產生一個流程圖。:
- 關於 Mermaid 語法,參考 這兒,
FLowchart流程圖
我們依舊會支援flowchart的流程圖:
- 關於 Flowchart流程圖 語法,參考 這兒.
匯出與匯入
匯出
如果你想嘗試使用此編輯器, 你可以在此篇文章任意編輯。當你完成了一篇文章的寫作, 在上方工具欄找到 文章匯出 ,生成一個.md檔案或者.html檔案進行本地儲存。
匯入
如果你想載入一篇你寫過的.md檔案,在上方工具欄可以選擇匯入功能進行對應副檔名的檔案匯入,
繼續你的創作。
註腳的解釋 ↩︎