当前位置： 首页 > wzjs >正文

上海网站建设报价书故事式软文范例100字

wzjs 2025/7/21 7:36:31
上海网站建设报价书,故事式软文范例100字,网站 错位,美国人做的汉字网站长文本切割实现流式调用文本合成语音 下面是一个文本合成音频的接口文档 快速 TTS 音频构造接口文档 请求地址： http://52.83.113.111:13679/Say/api/ra请求方式： post xml raw请求参数： 字段名称字段作用数据格式（示例&…

长文本切割实现流式调用文本合成语音

  • 下面是一个文本合成音频的接口文档

快速 TTS 音频构造接口文档

  • 请求地址：
http://52.83.113.111:13679/Say/api/ra
请求方式：
 post xml raw
请求参数：
字段名称字段作用数据格式（示例）
*****xml结构体string(32)<speak xmlns="http://www.w3.org/2001/10/synthesis" xmlns:mstts="http://www.w3.org/2001/mstts" xmlns:emo="http://www.w3.org/2009/10/emotionml" version="1.0" xml:lang="en-US"> <voice name="zh-CN-YunJianNeural"> <prosody rate="0%" pitch="0%"> 如果喜欢这个项目的话请点个 Star 吧。 </prosody > </voice > </speak >
format请求头标识stringaudio-24khz-48kbitrate-mono-mp3
DeviceNo请求头参数string319ee32b4715017e60b1ab5b6c0ea69f
参数备注：

可选vioce name：

{'中国大陆播音男口音1': 'zh-CN-YunjianNeural','中国大陆播音男口音3': 'zh-CN-YunyangNeural','中国大陆少女口音1': 'zh-CN-XiaoxiaoNeural','中国大陆少女口音2': 'zh-CN-XiaoyiNeural','中国大陆少女口音3': 'zh-CN-YunxiaNeural',}
返回参数：

二进制音频流

长文本切割，多协程合成音频，websocket流式输出音频流代码

package serviceimport ("bytes""fmt""github.com/gin-gonic/gin""github.com/gorilla/websocket""io""log""net/http""strings""sync""time"
)// 定义常用标点符号
var punctuationMarks = []string{".", "，", "。", "！", "？", "；", ":", "、", "·"}// 定义音频格式和TTS相关信息
//var voicer = "zh-CN-YunjianNeural"//var deviceNo = "319ee32b4715017e60b1ab5b6c0ea69f"
var format = "audio-24khz-48kbitrate-mono-mp3"//var audioServers = []string{
//	"http://server1.com/audio1.mp3",
//	"http://server2.com/audio2.mp3",
//	"http://server3.com/audio3.mp3",
//}var upgrader = websocket.Upgrader{CheckOrigin: func(r *http.Request) bool {return true},
}const bufferSize = 1024 * 32 // 32KB// 创建一个带互斥锁的缓冲区结构体，用于存储音频数据
type AudioBuffer struct {buffer bytes.Buffermutex  sync.Mutex
}func (ab *AudioBuffer) Write(p []byte) (n int, err error) {ab.mutex.Lock()defer ab.mutex.Unlock()return ab.buffer.Write(p)
}func (ab *AudioBuffer) Read(p []byte) (n int, err error) {ab.mutex.Lock()defer ab.mutex.Unlock()return ab.buffer.Read(p)
}// 定义标点符号集合（可以根据实际需求扩展）
var PunctuationMarks = []string{",", "，", "。", "!", "！", "？", "?", "\n"}// computeLen 根据 UTF-8 编码，按照标点符号进行切割，确保每段不超过 15 个汉字
func computeLen(content string) (string, string) {Sr := ""      // 用于存储最终返回的已处理文本cp := content // 临时存储输入的文本内容// 获取文本中的汉字数量，按UTF-8编码切割for {// 如果剩余的文本为空或只剩最后一个字符，停止匹配切割if len(cp) == 0 {break}// 查找第一个符合的标点符号sAim := findFirstMatch(cp)// 如果剩余的文本长度较短或者已满足条件，直接添加到 Sr// 判断：如果当前已经处理的文本长度加上剩余文本长度 <= 15（即不超过15个汉字）if len(Sr)+len(cp) <= 15 {Sr += cp // 将剩余的文本直接添加到 Srcp = ""  // 剩余文本清空break    // 处理完成，退出循环}// 查找切割点，确保切割后的文本不超过 15 个汉字// 如果当前已经处理的文本长度小于15，并且找到一个符合条件的标点符号if len(Sr) < 15 && sAim != "" {fmt.Println("sAim => ", sAim)fmt.Println("len(Sr) => ", len(Sr))worldCount := 0 // 汉字计数器index := 0      // 字符串切割的索引位置// 遍历字符串，统计汉字数量（按字符数统计，处理UTF-8编码）for index = range cp {// 如果已处理的汉字数量大于等于15，则停止if worldCount >= 15 {fmt.Println("汉字数量大于等于15 cp => ", len(cp))break}// 增加汉字计数worldCount++}// 将符合条件的文本（从开始到切割点）添加到 SrSr += cp[:index]// 剩余的文本部分，更新 cpcp = cp[index:]// 处理完成，退出循环break}}// 返回切割后的结果：已处理的文本和剩余的文本return Sr, cp
}// computeLen 根据 UTF-8 编码，按照标点符号进行切割，确保每段不超过 30 个汉字
func computeLen22(content string) (string, string) {Sr := ""      // 用于存储最终返回的已处理文本cp := content // 临时存储输入的文本内容// 获取文本中的汉字数量，按UTF-8编码切割for {// 如果剩余的文本为空或只剩最后一个字符，停止匹配切割if len(cp) == 0 {break}// 查找第一个符合的标点符号sAim := findFirstMatch(cp)// 如果剩余的文本长度较短或者已满足条件，直接添加到 Sr// 判断：如果当前已经处理的文本长度加上剩余文本长度 <= 30（即不超过30个汉字）if len(Sr)+len(cp) <= 20 {Sr += cp // 将剩余的文本直接添加到 Srcp = ""  // 剩余文本清空break    // 处理完成，退出循环}// 查找切割点，确保切割后的文本不超过 30 个汉字// 如果当前已经处理的文本长度小于30，并且找到一个符合条件的标点符号if len(Sr) < 20 && sAim != "" {runeCount := 0 // 汉字计数器index := 0     // 字符串切割的索引位置// 遍历字符串，统计汉字数量（按字符数统计，处理UTF-8编码）for index = range cp {// 如果已处理的汉字数量大于等于30，则停止if runeCount >= 20 {break}// 增加汉字计数runeCount++}// 将符合条件的文本（从开始到切割点）添加到 SrSr += cp[:index]// 剩余的文本部分，更新 cpcp = cp[index:]// 处理完成，退出循环break}}// 返回切割后的结果：已处理的文本和剩余的文本return Sr, cp
}// 这个函数的作用是找到字符串中第一个符合标点符号的字符
func findFirstMatch(str string) string {// 遍历标点符号集合，检查当前文本中是否包含标点符号for _, match := range PunctuationMarks {// 如果找到符合的标点符号，则返回该符号if strings.Contains(str, match) {return match}}// 如果没有找到任何符合的标点符号，返回空字符串return ""
}// splitPlayText 函数用于将输入文本分割成当前播放文本和剩余文本
// 参数：input - 输入的字符串
// 返回值：(string, string) - 第一个返回值是本次播放的文本，第二个返回值是剩余文本
func splitPlayText(input string) (string, string) {// 将输入字符串转换为 rune 切片，以正确处理中文字符// 如果输入长度小于等于15个字符，直接返回整个字符串作为播放文本，无剩余文本if len([]rune(input)) <= 15 {return input, ""}// 定义可用的分隔符数组// 包含中文标点（。，！？）和英文标点（.,!?）以及换行符separators := []rune{'。', '.', '，', ',', '!', '！', '?', '？', '\n'}// 将输入字符串转换为 rune 切片，便于按字符处理runes := []rune(input)// 记录最后一个找到的分隔符位置// 初始化为-1表示还未找到分隔符lastSepPos := -1// 遍历字符串中的每个字符for i, r := range runes {// 标记当前字符是否为分隔符isSeparator := false// 检查当前字符是否是分隔符for _, sep := range separators {if r == sep {isSeparator = true// 更新最后一个分隔符的位置lastSepPos = ibreak}}// 处理超过25个字符的情况// 如果当前位置超过25且之前找到过分隔符，从最后一个分隔符处切割if i >= 25 && lastSepPos != -1 {// 返回分隔符之前的文本（包含分隔符）作为播放文本// 分隔符之后的文本作为剩余文本return string(runes[:lastSepPos+1]), string(runes[lastSepPos+1:])}// 处理超过15个字符的情况// 如果当前位置超过15且当前字符是分隔符，在当前位置切割if i >= 15 && isSeparator {// 返回当前分隔符之前的文本（包含分隔符）作为播放文本// 分隔符之后的文本作为剩余文本return string(runes[:i+1]), string(runes[i+1:])}}// 如果遍历完整个字符串都没有找到合适的切割点// 返回整个字符串作为播放文本，无剩余文本return string(runes), ""
}// 创建SSML内容
//func createSSML(text, voicer string) string {
//	return fmt.Sprintf("<speak><voice name=\"%s\">%s</voice></speak>", voicer, text)
//}// 向TTS API请求音频数据
func fetchAudioToTTS(text string, voicer string, format string) ([]byte, error) {url := "http://52.83.116.11:13679/Say/api/ra"payload := "<speak xmlns=\"http://www.w3.org/2001/10/synthesis\" " +"xmlns:mstts=\"http://www.w3.org/2001/mstts\" " +"xmlns:emo=\"http://www.w3.org/2009/10/emotionml\" " +"version=\"1.0\" " +"xml:lang=\"en-US\">" +"<voice name=\"" + voicer + "\">" +"<prosody rate=\"0%\" pitch=\"0%\">" +text +"</prosody>" +"</voice>" +"</speak>"fmt.Println(" ========================================== ")fmt.Println(" payload : =>", payload)// 设置请求头req, err := http.NewRequest("POST", url, strings.NewReader(payload))if err != nil {return nil, err}req.Header.Set("Content-Type", "application/xml")req.Header.Set("format", format)// 发送请求并获取响应client := &http.Client{}resp, err := client.Do(req)if err != nil {fmt.Println("fetchAudioToTTS err => ", err.Error())return nil, err}defer resp.Body.Close()// 读取音频流audioData, err := io.ReadAll(resp.Body)if err != nil {fmt.Println("读取音频流 err => ", err.Error())return nil, err}return audioData, nil
}// 处理文本分段，逐段请求TTS并通过channel返回音频数据
func processTextInChunks(content string, voicer string, ch chan<- []byte) {for len(content) > 0 {// 切割文本segment, remaining := splitPlayText(content)content = remaining// 如果 segment 为空，直接跳过if len(strings.TrimSpace(segment)) == 0 && len(strings.ReplaceAll(segment, "\n", "")) == 0 {//continuebreak}// 创建SSML//ssml := createSSML(segment, voicer)fmt.Println("segment : => ", segment, "content : ==>", content)// 请求TTS接口获取音频audioData, err := fetchAudioToTTS(segment, voicer, format)if err != nil {fmt.Println("Error generating audio:", err)continue}//fmt.Println("audioData : =>", audioData)// 将音频数据发送到channelch <- audioDataif len(content) == 0 {// 音频数据传输结束break}// 模拟逐段播放，每段等待一段时间time.Sleep(3 * time.Second)}// 关闭channelclose(ch)
}// WebSocket连接处理函数，流式传输音频数据
func HandleAudioStream(ws *websocket.Conn, msgContent string, voicer string) {//ws, err := upgrader.Upgrade(c.Writer, c.Request, nil)//if err != nil {//	log.Printf("WebSocket upgrade error: %v", err)voicer//	return//}//defer ws.Close()// 创建一个带互斥锁的bufferaudioBuffer := &AudioBuffer{}// 创建用于通知新数据到达的channelnewDataChan := make(chan struct{}, 1)// 创建用于通知所有音频获取完成的channeldoneChan := make(chan struct{})// 创建一个channel，用于接收音频数据audioCh := make(chan []byte)// 测试文本//content := "这是一个测试文本，包含多个标点符号，看看如何处理。流式计算引擎Flink，是大数据领域非常常用的一个计算框架和分布式处理引擎，用于在无边界和有边界数据流上进行有状态的计算。"// 启动处理文本切割和请求TTS的goroutinego processTextInChunks(msgContent, voicer, audioCh)// 启动获取音频的goroutinego FetchAudioSequentially(audioCh, audioBuffer, newDataChan, doneChan)// 启动发送音频的goroutinego SendStreamAudio(ws, audioBuffer, newDataChan, doneChan)// 等待WebSocket连接关闭for {if _, _, err := ws.ReadMessage(); err != nil {log.Printf("WebSocket read error: %v", err)return}}
}// fetchAudioSequentially 负责按顺序获取音频数据
func FetchAudioSequentially(audioCh <-chan []byte, audioBuffer *AudioBuffer, newDataChan chan struct{}, doneChan chan struct{}) {defer close(doneChan)// 从audioCh获取音频数据for audioData := range audioCh {// 将获取到的音频数据写入音频缓冲区audioBuffer.Write(audioData)//fmt.Println("audioData : => ", audioData)// 通知有新数据可用select {case newDataChan <- struct{}{}:default:}// 模拟处理延时（实际场景可删除）time.Sleep(time.Second * 2)}
}// SendStreamAudio 负责将获取到的数据流式发送到客户端
func SendStreamAudio(ws *websocket.Conn, audioBuffer *AudioBuffer, newDataChan chan struct{}, doneChan chan struct{}) {buffer := make([]byte, bufferSize)//var offset int64 = 0for {select {case <-newDataChan:// 有新数据可用，尝试读取并发送for {n, err := audioBuffer.Read(buffer)if err == io.EOF {// 当前buffer读完，等待新数据//fmt.Println("err => ", err.Error())break}if err != nil {log.Printf("Error reading buffer: %v", err)return}// 发送数据//fmt.Println(" ws.WriteMessage 发送数据: ==> ", buffer[:n])err = ws.WriteMessage(websocket.BinaryMessage, buffer[:n])if err != nil {log.Printf("Error writing to websocket: %v", err)return}//offset += int64(n)}case <-doneChan:// 所有音频获取完成，确保发送完最后的数据for {n, err := audioBuffer.Read(buffer)if err == io.EOF {return}if err != nil {log.Printf("Error reading final buffer: %v", err)return}err = ws.WriteMessage(websocket.BinaryMessage, buffer[:n])if err != nil {log.Printf("Error writing final data to websocket: %v", err)return}}}}
}

HTTP_TTS流式输出音频流代码示例

package serviceimport ("PsycheEpic/src/models""fmt""github.com/gin-gonic/gin""log""net/http""strings""time"
)// 处理文本分段，逐段请求TTS并通过channel返回音频数据
func http_processTextInChunks(content string, voicer string, ch chan<- []byte) {for len(content) > 0 {// 切割文本segment, remaining := splitPlayText(content)content = remaining// 如果 segment 为空，直接跳过if len(strings.TrimSpace(segment)) == 0 && len(strings.ReplaceAll(segment, "\n", "")) == 0 {//continuebreak}// 创建SSML//ssml := createSSML(segment, voicer)fmt.Println("segment : => ", segment, "content : ==>", content)// 请求TTS接口获取音频audioData, err := fetchAudioToTTS(segment, voicer, format)if err != nil {fmt.Println("Error generating audio:", err)continue}//fmt.Println("audioData : =>", audioData)// 将音频数据发送到channelch <- audioDataif len(content) == 0 {// 音频数据传输结束ch <- nil // 使用nil来表示音频数据已经完成break}// 模拟逐段播放，每段等待一段时间time.Sleep(3 * time.Second)}// 关闭channelclose(ch)
}func HandleHTTPAudioStream(c *gin.Context) {// 设置响应头c.Writer.Header().Set("Content-Type", "audio/mp3")c.Writer.Header().Set("Transfer-Encoding", "chunked")// 获取 form-data 参数text := c.PostForm("text")voicer := c.PostForm("voicer")log.Printf("接收到TTS请求 - 文本: %s, 语音类型: %s", text, voicer)// 参数校验if text == "" || voicer == "" {c.JSON(http.StatusBadRequest, gin.H{"code": 0, "message": "参数 text 和 voicer 不能为空"})return}deviceNo := c.PostForm("deviceNo")if deviceNo == "" {c.JSON(http.StatusOK, gin.H{"code": 0, "message": "deviceNo参数不能为空"})return}DollInfo, err := models.GetDollUserRelationBySerialNumber(deviceNo)if err != nil {c.JSON(http.StatusOK, gin.H{"code": 0, "message": "查询玩具设备信息出错"})return}if DollInfo == nil {c.JSON(http.StatusOK, gin.H{"code": 0, "message": "未查询到设备绑定的用户信息"})return}// 检查设备是否当前已经连接if _, exists := DollChatCache[deviceNo]; !exists {c.JSON(http.StatusOK, gin.H{"code": 0, "message": "设备未连接或已断开"})return}// 创建一个无缓冲的通道来协调goroutinedone := make(chan bool)// 初始化缓存区，开辟空间//buffer := make([]byte, bufferSize)// 使用CloseNotify来检测客户端连接是否关闭clientGone := c.Writer.CloseNotify()// 创建带互斥锁的音频缓冲区//audioBuffer := &AudioBuffer{}// 创建用于接收音频数据的 channelaudioCh := make(chan []byte)// **启动 Goroutine 处理文本分割和请求 TTS**// 启动后台处理go func() {log.Println("开始处理文本并获取音频数据")http_processTextInChunks(text, voicer, audioCh)}()// 发送数据go func() {for {select {// 检查客户端是否已断开连接case <-clientGone:fmt.Println("客户端已断开连接")done <- truereturndefault:// 继续处理// 从audioCh管道获取数据case audioData := <-audioCh://fmt.Println("有数据... ", string(audioData))// 从audioCh管道获取数据if audioData == nil {// 如果接收到 nil，表示音频数据已发送完毕fmt.Println("数据已发送完毕")done <- truereturn}// 直接写入音频数据到 HTTP 响应_, err := c.Writer.Write(audioData)if err != nil {log.Printf("写入 HTTP 音频流出错: %v", err)return}// 确保数据实时发送if flusher, ok := c.Writer.(http.Flusher); ok {flusher.Flush()}}}done <- true}()// 等待所有数据处理完成或客户端断开连接<-done}
http://www.dtcms.com/wzjs/34238.html

相关文章：

  • 海南工程建设资料备案网站快速排名网站
  • 外贸网站 测速北京今日重大新闻
  • 旧域名怎么做新网站营销方式和手段有哪些
  • 网站服务搭建sem对seo的影响有哪些
  • 网络营销外包专家正规seo多少钱
  • 网站建设价格标准信息百度信息流代理
  • 宠物网站建设方案书seo快速上排名
  • 自己建网站百度到吗宁波搜索引擎优化seo
  • 广州 营销型网站深圳网站开发
  • app网站建设需要什么在线生成个人网站app
  • 商务网站建站国家培训网官网
  • 开了个网站用年份做名字好吗云浮seo
  • wordpress鱼南宁seo网络推广
  • 怎么给企业制作网站google关键词搜索技巧
  • 评网网站建设广州网站营销seo费用
  • 网站绑定两个域名怎么做跳转如何推广好一个产品
  • 西安做网站要多少钱批量优化网站软件
  • 新开的公司怎么做网站百度seo怎么操作
  • 做网站的人找不到了网络营销方案总结
  • 网站服务器有哪些类型优化大师是什么意思
  • wordpress 首页banner怎么快速优化关键词排名
  • 宁夏网站建设品牌公司个人网站怎么建立
  • 网站布局怎么做免费拓客软件排行榜
  • 网页设计教程网站seo推广软件代理
  • 南京企业网站建设河北百度seo关键词
  • 网站中怎么做图片的变换seo标题生成器
  • 哪里有网站建设加工百度广告联盟怎么加入
  • 食品饮料网站源码江苏疫情最新消息
  • 知名网站设计服务商app渠道推广
  • 网站建设的目标是网络推广项目计划书