0x000007FEFCFA940D 处(位于 QuoteWS.exe 中)引发的异常: Microsoft C++ 异常: websocketpp::exception,位于内存位置 0x000000000230E9C0 处
class broadcast_server{
public:
broadcast_server() {
m_server.clear_access_channels(websocketpp::log::alevel::all);
m_server.set_access_channels(websocketpp::log::alevel::access_core);
m_server.set_access_channels(websocketpp::log::alevel::app);
// Initialize Asio Transport
m_server.init_asio();
// Register handler callbacks
m_server.set_open_handler(bind(&broadcast_server::on_open, this, ::_1));
m_server.set_close_handler(bind(&broadcast_server::on_close, this, ::_1));
//m_server.set_message_handler(bind(&broadcast_server::on_message, this, ::_1, ::_2));
}
~broadcast_server() {
m_server.stop();
}
void run(uint16_t port) {
// listen on specified port
m_server.listen(port);
// Start the server accept loop
m_server.start_accept();
// Start the ASIO io_service run loop
try {
m_server.run();
}
catch (const std::exception & e) {
std::cout << e.what() << std::endl;
}
}
void on_open(connection_hdl hdl) {
{
lock_guard<mutex> guard(m_connection_lock);
m_connections.insert(hdl);
m_server.send(hdl, strmsg, websocketpp::frame::opcode::text);
}
}
void on_close(connection_hdl hdl) {
{
lock_guard<mutex> guard(m_action_lock);
int count = m_connections.size();
m_connections.erase(hdl);
cout << "m_connections size: " << m_connections.size() << endl;
}
}
void send_messages()
{
clock_t ends = 0;
clock_t start = 0;
while (1) {
unique_lock<mutex> lock(noticemutex);
while (!IsUpdata) {
noticedone.wait(lock);
}
lock.unlock();
ends = clock();
if (IsUpdata && (ends - start) > CLOCKS_PER_SEC)
{
//针对大量连接的时候很难保证
unique_lock<mutex> slock(m_action_lock);
con_list::iterator it;
for (it = m_connections.begin(); it != m_connections.end(); it++)
{
try {
************************************************************
m_server.send(*it, "1233", websocketpp::frame::opcode::text);
******************************************
}
catch (websocketpp::exception const & e) {
std::cout <<"error" << e.what() << std::endl;
}
}
IsUpdata = false;
start = ends;
clock_t tmptime = clock();
slock.unlock();
}
else
{
Sleep(10);
}
}
}
void process_messages() {
#if 0
while (1) {
unique_lock<mutex> lock(m_action_lock);
while (m_actions.empty()) {
m_action_cond.wait(lock);
}
action a = m_actions.front();
m_actions.pop();
lock.unlock();
if (a.type == SUBSCRIBE) {
lock_guard<mutex> guard(m_connection_lock);
m_connections.insert(a.hdl);
m_server.send(a.hdl, strmsg, websocketpp::frame::opcode::text);
}
else if (a.type == UNSUBSCRIBE) {
lock_guard<mutex> guard(m_connection_lock);
m_connections.erase(a.hdl);
}
else {
// undefined.
}
}
#endif
}
private:
typedef std::set<connection_hdl, std::owner_less<connection_hdl> > con_list;
server m_server;
con_list m_connections;
std::queue<action> m_actions;
mutex m_action_lock;
mutex m_connection_lock;
mutex m_send_lock;
condition_variable m_action_cond;
};
在send_message函数中的send函数旧奔溃了