1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
#include <stdio.h>
#include <string.h>
#include <websocketpp/config/asio_client.hpp>
#include <websocketpp/client.hpp>
#include <iostream>
#include "common.h"
typedef websocketpp::client<websocketpp::config::asio_tls_client> client_tls;
typedef websocketpp::client<websocketpp::config::asio_client> client_no_tls;
typedef websocketpp::lib::shared_ptr<websocketpp::lib::asio::ssl::context> context_ptr;
using websocketpp::lib::placeholders::_1;
using websocketpp::lib::placeholders::_2;
using websocketpp::lib::bind;
typedef websocketpp::config::asio_client::message_type::ptr message_ptr;

context_ptr on_tls_init(const char * hostname, websocketpp::connection_hdl) {
    context_ptr ctx = websocketpp::lib::make_shared<boost::asio::ssl::context>(boost::asio::ssl::context::sslv23);
    return ctx;
}


void on_message(websocketpp::connection_hdl hdl, message_ptr msg) {

    std::cout << "on_message" << hdl.lock().get()<< " and message: " << msg->get_payload()<< std::endl;
}

void on_open(void* c, websocketpp::connection_hdl hdl, bool tls) {

    std::cout << "on_open" << std::endl;
    std::string first_data = "{ "assess_ref":{"core_type":"cn.multirec.score","grade_tight" : 0,"rank" : 100,"scale" : 1.0,"support_repeat" : false,"text" : "小小"},"control_param" : {"suffix_penal_quick":1,"vad_max_sec" : 30,"vad_pause_sec" : 5,"vad_st_sil_sec" : 5},"mime_type" : "wav","need_url" : false,"user_info" : "user_info" }";
    //发送数据
    if (tls)
    {
        ((client_tls*)c)->send(hdl, first_data, websocketpp::frame::opcode::text);
    }
    else {
        ((client_no_tls*)c)->send(hdl, first_data, websocketpp::frame::opcode::text);
    }

}
int main(int argc, char* argv[]) {

    // Create a client endpoint
    client_tls _client_tls;
    client_no_tls  _client_no_tls;
    std::string hostname = "openai.100tal.com";

    std::string uri = "wss://openai.100tal.com/****************";
    char ch= uri.c_str()[2];
    bool tls = (ch == 's');
    try {

        if (tls)//wss
        {
            _client_tls.clear_access_channels(websocketpp::log::alevel::all);
            _client_tls.clear_error_channels(websocketpp::log::elevel::all);

            _client_tls.init_asio();
            _client_tls.set_reuse_addr(true);
            _client_tls.set_message_handler(bind(&on_message,  ::_1, ::_2));
            _client_tls.set_open_handler(bind(&on_open, &_client_tls, ::_1,true));
            _client_tls.set_tls_init_handler(bind(&on_tls_init, hostname.c_str(), ::_1));
            websocketpp::lib::error_code ec;
            client_tls::connection_ptr con = _client_tls.get_connection(uri, ec);

            if (ec) {
                std::cout << "could not create connection because: " << ec.message() << std::endl;
                return 0;
            }
            _client_tls.connect(con);
            std::this_thread::sleep_for(std::chrono::milliseconds(200));
            _client_tls.run();

        }
        else {//ws
            _client_no_tls.clear_access_channels(websocketpp::log::alevel::all);
            _client_no_tls.clear_error_channels(websocketpp::log::elevel::all);

            _client_no_tls.init_asio();
            _client_no_tls.set_reuse_addr(true);
            _client_no_tls.set_message_handler(bind(&on_message, ::_1, ::_2));
            _client_no_tls.set_open_handler(bind(&on_open, &_client_no_tls, ::_1, false));
            websocketpp::lib::error_code ec;
            client_no_tls::connection_ptr con = _client_no_tls.get_connection(uri, ec);

            if (ec) {
                std::cout << "could not create connection because: " << ec.message() << std::endl;
                return 0;
            }
            std::cout << "to connect... " << std::endl;
            _client_no_tls.connect(con);
           
            std::this_thread::sleep_for(std::chrono::milliseconds(200));
            _client_no_tls.run();
        }
       
    }

    catch (websocketpp::exception const & e) {
        std::cout << e.what() << std::endl;
    }

}