ZBLOG

Boost.Beast websocket, tcp 服务器共存 使用示例

以下是一个简单的 Boost.Beast WebSocket 和 TCP 服务器共存使用的示例:

  1. #include <iostream>
  2. #include <boost/beast/core.hpp>
  3. #include <boost/beast/websocket.hpp>
  4. #include <boost/asio/ip/tcp.hpp>
  5. #include <boost/asio/signal_set.hpp>
  6. namespace beast = boost::beast;
  7. namespace websocket = beast::websocket;
  8. namespace net = boost::asio;
  9. using tcp = boost::asio::ip::tcp;
  10. void handleWebSocket(websocket::stream<tcp::socket>& ws)
  11. {
  12. try
  13. {
  14. // 进行 WebSocket 握手
  15. ws.handshake();
  16. // 接收和输出从客户端发送的消息
  17. beast::flat_buffer buffer;
  18. ws.read(buffer);
  19. std::cout << "Received message: " << beast::make_printable(buffer.data()) << std::endl;
  20. // 发送响应消息到客户端
  21. ws.write(net::buffer("Hello, WebSocket from server!"));
  22. // 关闭 WebSocket 连接
  23. ws.close(websocket::close_code::normal);
  24. }
  25. catch (const std::exception& e)
  26. {
  27. std:cerr << "WebSocket Error: " << e.what() << std:endl;
  28. }
  29. }
  30. void runServer()
  31. {
  32. try
  33. {
  34. net::io_context io;
  35. // 创建 TCP 监听器对象并绑定到指定端口号
  36. tcp::acceptor acceptor(io, {tcp::v4(), 12345});
  37. while (true)
  38. {
  39. // 等待新的连接请求到达
  40. tcp::socket socket(io);
  41. acceptor.accept(socket);
  42. // 创建 WebSocket 对象来处理连接请求
  43. websocket::stream<tcp::socket> ws(std::move(socket));
  44. // 在新的线程中处理 WebSocket 连接
  45. std::thread([&ws](){
  46. handleWebSocket(ws);
  47. }).detach();
  48. }
  49. }
  50. catch (const std::exception& e)
  51. {
  52. std:cerr << "Server Error: " << e.what() << std:endl;
  53. }
  54. }
  55. int main()
  56. {
  57. try
  58. {
  59. // 创建一个新的线程来运行 TCP 服务器
  60. std::thread serverThread(runServer);
  61. // 等待 CTRL-C 信号,然后退出程序
  62. net::io_context io;
  63. net::signal_set signals(io, SIGINT, SIGTERM);
  64. signals.async_wait([&](const boost::system::error_code&, int){
  65. io.stop();
  66. serverThread.join();
  67. });
  68. io.run();
  69. }
  70. catch (const std::exception& e)
  71. {
  72. std:cerr << "Error: " << e.what() << std:endl;
  73. return -1;
  74. }
  75. return 0;
  76. }

这个示例代码同时创建了一个 TCP 服务器和一个 WebSocket 服务器,监听在不同的端口上。TCP 服务器监听在 12345 端口上,而 WebSocket 服务器默认监听在 8080 端口上。

当有新的连接请求到达时,TCP 服务器会创建一个 WebSocket 对象,并将其委托给单独的线程处理。处理函数 handleWebSocket() 负责进行 WebSocket 握手、接收和发送消息,并最终关闭连接。

主函数中,创建了一个新的线程来运行 TCP 服务器,并使用 Boost.ASIO 的信号集来捕获 CTRL-C 信号,在接收到该信号后停止服务器并退出程序。

请确保已经正确安装了 Boost.Beast 库,并在编译时链接相应的库文件。同样,注意在实际项目中需要处理异常、错误检查和其他边界条件等。这只是一个简单的示例来帮助你理解 Boost.Beast WebSocket 和 TCP 服务器共存的使用。


内容由零声教学AI助手提供,问题来源于学员提问

本站部分文章来源于网络,版权归原作者所有,如有侵权请联系站长删除。
转载请注明出处:https://golang.0voice.com/?id=17631

分享:
扫描分享到社交APP
上一篇
下一篇
发表列表
游客 游客
此处应有掌声~
评论列表

还没有评论,快来说点什么吧~

联系我们

在线咨询: 点击这里给我发消息

微信号:3007537140

上班时间: 10:30-22:30

关注我们
x

注册

已经有帐号?