使用 WebSocket++ 实现多个客户端连接并进行消息的收发,并在接入时将其保存在 Map 中,离开时断开连接可以按照以下步骤进行:
- 创建一个 WebSocket 服务器对象:
websocketpp::server<websocketpp::config::asio> server;
- 定义一个 Map 来保存客户端连接信息:
std::map<websocketpp::connection_hdl, std::string> connections;
- 设置回调函数来处理新连接和断开事件:
// 新连接回调函数
void on_open(websocketpp::connection_hdl hdl) {
// 将新连接保存到 Map 中,可以使用 connection_hdl 作为 key
connections[hdl] = "";
}
// 断开连接回调函数
void on_close(websocketpp::connection_hdl hdl) {
// 在断开连接时从 Map 中移除对应的记录
connections.erase(hdl);
}
- 设置消息接收处理函数:
void on_message(websocketpp::connection_hdl hdl, websocketpp::server<websocketpp::config::asio>::message_ptr msg) {
std::string message = msg->get_payload();
// 处理接收到的消息
// 发送回复消息给客户端
server.send(hdl, "Reply message", websocketpp::frame::opcode::text);
}
- 启动服务器并设置相关配置:
int main() {
// 设置服务器端口号和其他配置项...
// 设置回调函数
server.set_open_handler(&on_open);
server.set_close_handler(&on_close);
server.set_message_handler(&on_message);
// 启动服务器
server.init_asio();
server.listen(port);
server.start_accept();
// 进入事件循环
server.run();
return 0;
}
上述代码只是简单示例,具体的实现可能需要根据实际需求进行调整。请注意确保正确引入 WebSocket++ 的头文件和链接相关库,并适当处理异常情况。
内容由零声教学AI助手提供,问题来源于学员提问