提交

kongdeqiang

2026-03-13 28ccfbfc51068a663a80764e14074df5edf2b5ba

 runtime/websocket/bin/funasr-wss-client.cpp

@@ -98,11 +98,12 @@
        switch (msg->get_opcode()) {
            case websocketpp::frame::opcode::text:
            total_recv=total_recv+1;
                LOG(INFO)<< "Thread: " << this_thread::get_id() <<", on_message = " << payload;
                LOG(INFO)<< "Thread: " << this_thread::get_id() << ", total_recv=" << total_recv << " total_send=" <<total_send;
            if(total_recv==total_send)
                LOG(INFO)<< "Thread: " << this_thread::get_id() << ", total_recv=" << total_recv <<", on_message = " << payload;
                std::unique_lock<std::mutex> lock(msg_lock);
                cv.notify_one();
            if(close_client)
            {
                    LOG(INFO)<< "Thread: " << this_thread::get_id() << ", close client";
                    LOG(INFO)<< "Thread: " << this_thread::get_id() << ", close client thread";
               websocketpp::lib::error_code ec;
               m_client.close(m_hdl, websocketpp::close::status::going_away, "", ec);
               if (ec){
@@ -114,7 +115,7 @@

    // This method will block until the connection is complete  
    void run(const std::string& uri, const std::vector<string>& wav_list, const std::vector<string>& wav_ids, 
             int audio_fs, const std::unordered_map<std::string, int>& hws_map, int use_itn=1) {
             int audio_fs, const std::unordered_map<std::string, int>& hws_map, int use_itn=1, int svs_itn=1) {
        // Create a new connection to the given URI
        websocketpp::lib::error_code ec;
        typename websocketpp::client<T>::connection_ptr con =
@@ -141,14 +142,17 @@
            if (i >= wav_list.size()) {
                break;
            }
            if (total_send !=0){
                std::unique_lock<std::mutex> lock(msg_lock);
                cv.wait(lock);
            }
            total_send += 1;
            send_wav_data(wav_list[i], wav_ids[i], audio_fs, hws_map, send_hotword, use_itn);
            send_wav_data(wav_list[i], wav_ids[i], audio_fs, hws_map, send_hotword, use_itn, svs_itn);
            if(send_hotword){
                send_hotword = false;
            }
        }
        WaitABit(); 

        close_client = true;
        asio_thread.join();

    }
@@ -182,17 +186,14 @@
    // send wav to server
    void send_wav_data(string wav_path, string wav_id, int audio_fs,
        const std::unordered_map<std::string, int>& hws_map, 
        bool send_hotword, bool use_itn) {
        bool send_hotword, bool use_itn, bool svs_itn) {
        uint64_t count = 0;
        std::stringstream val;

      funasr::Audio audio(1);
        int32_t sampling_rate = audio_fs;
        std::string wav_format = "pcm";
      if(funasr::IsTargetFile(wav_path.c_str(), "wav")){
         if(!audio.LoadWav(wav_path.c_str(), &sampling_rate, false))
            return ;
      }else if(funasr::IsTargetFile(wav_path.c_str(), "pcm")){
        if(funasr::IsTargetFile(wav_path.c_str(), "pcm")){
         if (!audio.LoadPcmwav(wav_path.c_str(), &sampling_rate, false))
            return ;
      }else{
@@ -238,8 +239,12 @@
        jsonbegin["wav_format"] = wav_format;
        jsonbegin["audio_fs"] = sampling_rate;
        jsonbegin["itn"] = true;
        jsonbegin["svs_itn"] = true;
        if(use_itn == 0){
            jsonbegin["itn"] = false;
        }
        if(svs_itn == 0){
            jsonbegin["svs_itn"] = false;
        }
        jsonbegin["is_speaking"] = true;
        if(send_hotword){
@@ -334,14 +339,18 @@
  private:
    websocketpp::connection_hdl m_hdl;
    websocketpp::lib::mutex m_lock;
    websocketpp::lib::mutex msg_lock;
    websocketpp::lib::condition_variable cv;
    bool m_open;
    bool m_done;
    bool close_client=false;
   int total_send=0;
    int total_recv=0;
};

int main(int argc, char* argv[]) {
#ifdef _WIN32
    #include <windows.h>
    SetConsoleOutputCP(65001);
#endif
    google::InitGoogleLogging(argv[0]);
@@ -363,6 +372,9 @@
    TCLAP::ValueArg<int> use_itn_(
        "", "use-itn",
        "use-itn is 1 means use itn, 0 means not use itn", false, 1, "int");
    TCLAP::ValueArg<int> svs_itn_(
        "", "svs-itn",
        "svs-itn is 1 means use itn and punc, 0 means not use", false, 1, "int");
    TCLAP::ValueArg<std::string> hotword_("", HOTWORD,
        "the hotword file, one hotword perline, Format: Hotword Weight (could be: 阿里巴巴 20)", false, "", "string");

@@ -373,6 +385,7 @@
    cmd.add(thread_num_);
    cmd.add(is_ssl_);
    cmd.add(use_itn_);
    cmd.add(svs_itn_);
    cmd.add(hotword_);
    cmd.parse(argc, argv);

@@ -382,6 +395,7 @@
    int threads_num = thread_num_.getValue();
    int is_ssl = is_ssl_.getValue();
    int use_itn = use_itn_.getValue();
    int svs_itn = svs_itn_.getValue();

    std::vector<websocketpp::lib::thread> client_threads;
    std::string uri = "";
@@ -426,17 +440,17 @@
    
    int audio_fs = audio_fs_.getValue();
    for (size_t i = 0; i < threads_num; i++) {
        client_threads.emplace_back([uri, wav_list, wav_ids, audio_fs, is_ssl, hws_map, use_itn]() {
        client_threads.emplace_back([uri, wav_list, wav_ids, audio_fs, is_ssl, hws_map, use_itn, svs_itn]() {
          if (is_ssl == 1) {
            WebsocketClient<websocketpp::config::asio_tls_client> c(is_ssl);

            c.m_client.set_tls_init_handler(bind(&OnTlsInit, ::_1));

            c.run(uri, wav_list, wav_ids, audio_fs, hws_map, use_itn);
            c.run(uri, wav_list, wav_ids, audio_fs, hws_map, use_itn, svs_itn);
          } else {
            WebsocketClient<websocketpp::config::asio_client> c(is_ssl);

            c.run(uri, wav_list, wav_ids, audio_fs, hws_map, use_itn);
            c.run(uri, wav_list, wav_ids, audio_fs, hws_map, use_itn, svs_itn);
          }
        });
    }