ZBLOG

Boost.Beast websocket, tcp 服务器共存 tcp 9000 端口 websocket 9001 端口使用示例

以下是一个使用 Boost.Beast 实现 WebSocket 和 TCP 服务器共存的示例,分别监听在TCP 9000端口和WebSocket 9001端口:

  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 handleTcp(tcp::socket& socket)
  31. {
  32. try
  33. {
  34. // 接收和输出从客户端发送的消息
  35. char data[1024];
  36. size_t length = socket.read_some(boost::asio::buffer(data));
  37. std:cout << "Received message: " << data << std:endl;
  38. // 发送响应消息到客户端
  39. boost::system::error_code ignored_error;
  40. socket.write_some(boost.asio.buffer("Hello, TCP from server!"), ignored_error);
  41. // 关闭 TCP 连接
  42. socket.shutdown(tcp::socket::shutdown_both);
  43. socket.close();
  44. }
  45. catch (const std::exception& e)
  46. {
  47. std:cerr << "TCP Error: " << e.what() << std:endl;
  48. }
  49. }
  50. void runServer()
  51. {
  52. try
  53. {
  54. net::io_context io;
  55. // 创建 TCP 监听器对象并绑定到指定端口号
  56. tcp::acceptor tcpAcceptor(io, {tcp::v4(), 9000});
  57. // 创建 WebSocket 监听器对象并绑定到指定端口号
  58. tcp::acceptor wsAcceptor(io, {tcp::v4(), 9001});
  59. while (true)
  60. {
  61. // 等待新的 TCP 连接请求到达
  62. tcp::socket tcpSocket(io);
  63. tcpAcceptor.accept(tcpSocket);
  64. // 在新的线程中处理 TCP 连接
  65. std::thread([&tcpSocket]() {
  66. handleTcp(tcpSocket);
  67. }).detach();
  68. // 等待新的 WebSocket 连接请求到达
  69. tcp::socket wsSocket(io);
  70. wsAcceptor.accept(wsSocket);
  71. // 创建 WebSocket 对象来处理连接请求
  72. websocket::stream<tcp::socket> ws(std::move(wsSocket));
  73. // 在新的线程中处理 WebSocket 连接
  74. std::thread([&ws](){
  75. handleWebSocket(ws);
  76. }).detach();
  77. }
  78. }
  79. catch (const std::exception& e)
  80. {
  81. std:cerr << "Server Error: " << e.what() << std:endl;
  82. }
  83. }
  84. int main()
  85. {
  86. try
  87. {
  88. // 创建一个新的线程来运行服务器
  89. std::thread serverThread(runServer);
  90. // 等待 CTRL-C 信号,然后退出程序
  91. net::io_context io;
  92. net::signal_set signals(io, SIGINT, SIGTERM);
  93. signals.async_wait([&](const boost::system::error_code&, int){
  94. io.stop();
  95. serverThread.join();
  96. });
  97. io.run();
  98. }
  99. catch (const std::exception& e)
  100. {
  101. std:cerr << "Error: " << e.what() << std:endl;
  102. return -1;
  103. }
  104. return 0;
  105. }

在该示例中,TCP服务器监听9000端口,WebSocket服务器监听9001端口。当有新的TCP连接请求到达时,将在一个新线程中处理TCP连接;同样地,当有新的WebSocket连接请求到达时,将在另一个新线程中处理WebSocket连接。分别使用handleTcp()函数和handleWebSocket()函数来处理对应的连接。

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


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

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

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

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

联系我们

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

微信号:3007537140

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

关注我们
x

注册

已经有帐号?