語音識別服務(wù)
├─ 服務(wù)端（speech\_server）
│  ├─ RPC服務(wù)實現(xiàn)（SpeechServiceImpl）：處理語音識別請求
│  ├─ 服務(wù)構(gòu)建器（SpeechServerBuilder）：組裝各模塊（ASR、注冊、RPC）
│  ├─ 語音識別封裝（ASRClient）：調(diào)用百度AI SDK
│  ├─ 服務(wù)注冊（Registry）：將服務(wù)節(jié)點注冊到etcd
│  └─ 日志配置：初始化spdlog日志
└─ 客戶端（speech\_client）
   ├─ 服務(wù)發(fā)現(xiàn)（Discovery）：從etcd獲取服務(wù)節(jié)點
   ├─ 信道管理（ServiceManager）：RR輪詢負(fù)載均衡
   └─ 音頻讀?。赫{(diào)用百度AI SDK工具函數(shù)讀取PCM文件

syntax = "proto3";
package zrt;  // 命名空間，避免類名沖突
option cc_generic_services = true;  // 生成C++ RPC服務(wù)代碼
// 語音識別請求
message SpeechRecognitionReq {
    string request_id = 1;          // 請求ID（用于追蹤）
    bytes speech_content = 2;       // 核心：PCM音頻數(shù)據(jù)（二進(jìn)制）
    optional string user_id = 3;    // 可選：用戶ID
    optional string session_id = 4; // 可選：會話ID（鑒權(quán)用）
}
// 語音識別響應(yīng)
message SpeechRecognitionRsp {
    string request_id = 1;              // 對應(yīng)請求的ID
    bool success = 2;                   // 識別是否成功
    optional string errmsg = 3;         // 失敗原因（success=false時必選）
    optional string recognition_result = 4; // 識別結(jié)果（success=true時必選）
}
// RPC服務(wù)定義
service SpeechService {
    rpc SpeechRecognition(SpeechRecognitionReq) returns (SpeechRecognitionRsp);
}

#pragma once
#include "../third/include/aip-cpp-sdk/speech.h"
#include "logger.hpp"
namespace zrt {
class ASRClient {
public:
    using ptr = std::shared_ptr<ASRClient>;
    // 初始化：傳入百度AI的AppID、APIKey、SecretKey
    ASRClient(const std::string &app_id, const std::string &api_key, const std::string &secret_key)
        : _client(app_id, api_key, secret_key) {}
    // 核心接口：輸入PCM音頻數(shù)據(jù)，輸出識別結(jié)果
    std::string recognize(const std::string &speech_data, std::string &err) {
        // 調(diào)用百度SDK：PCM格式（16k采樣率）
        Json::Value result = _client.recognize(speech_data, "pcm", 16000, aip::null);
        // 處理SDK返回：err_no=0表示成功
        if (result["err_no"].asInt() != 0) {
            LOG_ERROR("語音識別失?。簕}", result["err_msg"].asString());
            err = result["err_msg"].asString(); // 傳出錯誤信息
            return "";
        }
        return result["result"][0].asString(); // 返回第一個識別結(jié)果
    }
private:
    aip::Speech _client; // 百度AI SDK的Speech客戶端
};
}

class SpeechServiceImpl : public zrt::SpeechService {
public:
    // 注入ASRClient實例（依賴注入，解耦服務(wù)與ASR實現(xiàn)）
    SpeechServiceImpl(const ASRClient::ptr &asr_client) : _asr_client(asr_client) {}
    void SpeechRecognition(google::protobuf::RpcController* controller,
                           const ::zrt::SpeechRecognitionReq* request,
                           ::zrt::SpeechRecognitionRsp* response,
                           ::google::protobuf::Closure* done) {
        LOG_DEBUG("收到語音轉(zhuǎn)文字請求！request_id: {}", request->request_id());
        brpc::ClosureGuard rpc_guard(done); // 自動釋放Closure，避免內(nèi)存泄漏
        // 1. 調(diào)用ASRClient識別音頻
        std::string err;
        std::string res = _asr_client->recognize(request->speech_content(), err);
        // 2. 組裝響應(yīng)
        response->set_request_id(request->request_id());
        if (res.empty()) {
            // 識別失?。涸O(shè)置錯誤信息
            response->set_success(false);
            response->set_errmsg("語音識別失敗:" + err);
            return;
        }
        // 識別成功：返回結(jié)果
        response->set_success(true);
        response->set_recognition_result(res);
    }
private:
    ASRClient::ptr _asr_client; // 語音識別客戶端
};

class Discovery {
public:
    using ptr = std::shared_ptr<Discovery>;
    // 回調(diào)類型：服務(wù)上下線時通知外部（如更新信道）
    using NotifyCallback = std::function<void(std::string, std::string)>;
    // 初始化：連接etcd、拉取現(xiàn)有服務(wù)、監(jiān)聽變化
    Discovery(const std::string &host, const std::string &basedir,
              const NotifyCallback &put_cb, const NotifyCallback &del_cb)
        : _client(std::make_shared<etcd::Client>(host)), _put_cb(put_cb), _del_cb(del_cb) {
        // 1. 拉取現(xiàn)有服務(wù)節(jié)點（服務(wù)啟動時初始化）
        auto resp = _client->ls(basedir).get();
        if (!resp.is_ok()) {
            LOG_ERROR("獲取服務(wù)列表失敗：{}", resp.error_message());
            return;
        }
        // 遍歷現(xiàn)有節(jié)點，調(diào)用上線回調(diào)
        for (int i = 0; i < resp.keys().size(); ++i) {
            if (_put_cb) _put_cb(resp.key(i), resp.value(i).as_string());
        }
        // 2. 監(jiān)聽etcd目錄變化（實時感知上下線）
        _watcher = std::make_shared<etcd::Watcher>(
            *_client.get(), basedir,
            std::bind(&Discovery::callback, this, std::placeholders::_1),
            true // 遞歸監(jiān)聽子目錄
        );
    }
private:
    // etcd事件回調(diào)：處理PUT（上線）和DELETE（下線）事件
    void callback(const etcd::Response &resp) {
        if (!resp.is_ok()) {
            LOG_ERROR("etcd事件錯誤：{}", resp.error_message());
            return;
        }
        for (auto &ev : resp.events()) {
            if (ev.event_type() == etcd::Event::PUT) {
                LOG_DEBUG("服務(wù)上線：{}-{}", ev.kv().key(), ev.kv().as_string());
                if (_put_cb) _put_cb(ev.kv().key(), ev.kv().as_string());
            } else if (ev.event_type() == etcd::Event::DELETE_) {
                LOG_DEBUG("服務(wù)下線：{}-{}", ev.prev_kv().key(), ev.prev_kv().as_string());
                if (_del_cb) _del_cb(ev.prev_kv().key(), ev.prev_kv().as_string());
            }
        }
    }
private:
    NotifyCallback _put_cb;       // 服務(wù)上線回調(diào)
    NotifyCallback _del_cb;       // 服務(wù)下線回調(diào)
    std::shared_ptr<etcd::Client> _client; // etcd客戶端
    std::shared_ptr<etcd::Watcher> _watcher; // etcd監(jiān)聽器
};

class ServiceManager {
public:
    using ptr = std::shared_ptr<ServiceManager>;
    // 聲明需要關(guān)注的服務(wù)（只處理聲明過的服務(wù)）
    void declared(const std::string &service_name) {
        std::unique_lock<std::mutex> lock(_mutex);
        _follow_services.insert(service_name);
    }
    // 服務(wù)上線回調(diào)：添加信道
    void onServiceOnline(const std::string &service_instance, const std::string &host) {
        std::string service_name = getServiceName(service_instance);
        // 只處理關(guān)注的服務(wù)
        if (_follow_services.count(service_name) == 0) {
            LOG_DEBUG("{}服務(wù)上線，無需關(guān)注", service_name);
            return;
        }
        // 獲取或創(chuàng)建服務(wù)的信道管理對象
        auto service = getOrCreateServiceChannel(service_name);
        service->append(host); // 添加新節(jié)點的信道
    }
    // 選擇一個信道（RR輪詢）
    ServiceChannel::ChannelPtr choose(const std::string &service_name) {
        std::unique_lock<std::mutex> lock(_mutex);
        auto it = _services.find(service_name);
        if (it == _services.end()) {
            LOG_ERROR("無{}服務(wù)的可用節(jié)點", service_name);
            return nullptr;
        }
        return it->second->choose(); // 調(diào)用ServiceChannel的RR邏輯
    }
private:
    // 從實例名中提取服務(wù)名（如/service/speech_service/instance → /service/speech_service）
    std::string getServiceName(const std::string &service_instance) {
        auto pos = service_instance.find_last_of('/');
        return pos == std::string::npos ? service_instance : service_instance.substr(0, pos);
    }
private:
    std::mutex _mutex; // 線程安全鎖
    std::unordered_set<std::string> _follow_services; // 關(guān)注的服務(wù)列表
    // 服務(wù)名 → 信道管理對象的映射
    std::unordered_map<std::string, ServiceChannel::ptr> _services;
};

error: no matching function for call to ‘transform(..., <unresolved overloaded function type>)'
note: couldn't deduce template parameter ‘_UnaryOperation'

// 修改前（SDK原代碼，錯誤）
std::transform(src.begin(), src.end(), src.begin(), toupper);
// 修改后（正確）
std::transform(src.begin(), src.end(), src.begin(),
    [](unsigned char c) { // 轉(zhuǎn)unsigned char，避免char負(fù)數(shù)（如中文亂碼）
        return static_cast<char>(std::toupper(c)); // 顯式調(diào)用<cctype>版本
    }
);

warning: no return statement in function returning non-void [-Wreturn-type]

std::string aip::to_upper(std::string src) {
    std::transform(...); // 處理邏輯
    return src; // 補(bǔ)全返回語句
}

0
語音識別失敗:invalid audio length

// 修改前
aip::get_file_content("16k.pcm", &file_content);
// 修改后（替換為實際路徑）
aip::get_file_content("/home/zrt/workspace/16k.pcm", &file_content);

# 查看權(quán)限，確保有r（讀）權(quán)限
ls -l 16k.pcm
# 無權(quán)限則添加
chmod +r 16k.pcm

# 將任意音頻轉(zhuǎn)為16k、16位、單聲道PCM
ffmpeg -i test.wav -ar 16000 -ac 1 -sample_fmt s16le 16k.pcm

~Discovery() {
   _watcher->Cancel(); // 主動停止監(jiān)聽器
}

# 運(yùn)行客戶端（發(fā)現(xiàn)服務(wù)并發(fā)起請求）
./speech_client --etcd_host=http://127.0.0.1:2379 --speech_service=/service/speech_service

# 運(yùn)行客戶端（發(fā)現(xiàn)服務(wù)并發(fā)起請求）
./speech_client --etcd_host=http://127.0.0.1:2379 --speech_service=/service/speech_service

12345  # file_content.size()，非0表示讀取成功
收到響應(yīng): 111111
收到響應(yīng): 你好，世界