\ud83d\udc49\ud83c\udffb c++\uc758 Asio(\ub610\ub294 Bootst.asio) \ub77c\uc774\ube0c\ub7ec\ub9ac\ub97c \uc774\ud574\ud558\uae30 \uc704\ud55c \ucf54\ub4dc\uc785\ub2c8\ub2e4. This is code to understand the C++ Asio (or Bootst.asio) library.<\/p>\n\n\n\n
\ud83d\udc49\ud83c\udffb \uc544\ub798\uc758 \ucf54\ub4dc\ub294 \uc774\uc804\uc5d0 \uc5c5\ub85c\ub4dc\ud55c mini_mediaserver_1 \uc758 \uc77c\ubd80\ub85c\uc9c1\uc744 \uc0ac\uc6a9\ud569\ub2c8\ub2e4. The code below uses some of the logic from the previously uploaded mini_mediaserver_1.<\/p>\n\n\n\n
\ud83d\udc49\ud83c\udffb \ud14c\uc2a4\ud2b8 \ud658\uacbd\uc740 MacOS\uc785\ub2c8\ub2e4. The test environment is MacOS.<\/p>\n\n\n\n
— \ud568\uc218 \uc2e4\ud589 \ud750\ub984 \/ Function execution flow<\/p>\n\n\n\n
main() -> Server Class- > do_accept() -> Session Class -> start { do_read {do_write()}}<\/code><\/pre>\n\n\n\n
— \uc18c\ucf13,\uc811\uc18d\uc815\ubcf4 \uacf5\uc720 \/ Socket, connection information sharing<\/p>\n\n\n\n
1.\uc18c\ucf13\uc740 \ubcf5\uc0ac \ud560 \uc218 \uc5c6\uae30 \ub54c\ubb38\uc5d0 \uc18c\uc720\uad8c \uc774\ub3d9\uc744 \ud569\ub2c8\ub2e4.\nSince sockets cannot be copied, ownership is transferred.\n\nstd::make_shared<Session>(std::move(socket))->start();\n\n2.\uc811\uc18d \uc815\ubcf4\ub97c \uacf5\uc720\ud558\uae30 \uc704\ud574 \ub2e4\uc74c \ucf54\ub4dc\ub97c \uc0ac\uc6a9\ud569\ub2c8\ub2e4.\nUse the following code to share connection information.\n\n- make_shared\ub294 \ud558\ub098\ub9cc \uacf5\uc720\ud560 \uc218 \uc788\ub294 \ud3ec\uc778\ud130\ub97c \ub9cc\ub4ed\ub2c8\ub2e4.\nmake_shared creates a pointer that can be shared by only one person.\n\nstd::make_shared<Session>(std::move(socket))->start();\n\n- enable_shared_from_this\ub97c \uc0c1\uc18d\ubc1b\uc73c\uba74 shared_from_this(); \ud568\uc218\ub97c \uc0ac\uc6a9 \ud560 \uc218 \uc788\uc2b5\ub2c8\ub2e4.\nIf you inherit from enable_shared_from_this, you can use the shared_from_this(); function.\n\npublic std::enable_shared_from_this<Session>\n\n- this(Session class) \uc815\ubcf4\uac00 \uc0ac\ub77c\uc9c8 \uc218 \uc788\uc5b4\uc11c \uc548\uc804\ud55c \uc5f0\uacb0\uc744 \uc704\ud574 self\uc5d0 Session Class \uc815\ubcf4\ub97c \ubcf5\ud558\ud569\ub2c8\ub2e4. \nSince the information in this (Session class) can be lost, the Session Class information is copied to self for a secure connection.\n\nauto self = shared_from_this();<\/code><\/pre>\n\n\n\n
— echo<\/p>\n\n\n\n
- \uc544\ub798\uc758 \ub78c\ub2e4 \ucf54\ub4dc\uc5d0\uc11c \uc18c\ucf13\uc5d0\uc11c \ubc1b\uc740 data_\uc758 \ub0b4\uc6a9\uc744 \ucd9c\ub825\ud558\uace0 \ub2e4\uc2dc \uc18c\ucf13\uc5d0 \ub370\uc774\ud130\ub97c \uc791\uc131\ud569\ub2c8\ub2e4.\nIn the lambda code below, the contents of data_ received from the socket are printed, and data is written back to the socket.\n\n[this, self](boost::system::error_code ec, size_t len) {\n if (!ec) {\n std::cout << \"\ubc1b\uc74c\/Receive: \" << std::string(data_, len) << \"\\n\";\n do_write(len); \/\/ \uc5d0\ucf54 \/ echo\n }\n});<\/code><\/pre>\n\n\n\n
\u2714\ufe0f\uc804\uccb4 \ucf54\ub4dc \/ Full Cdoe (tcpecho.cpp)<\/p>\n\n\n\n
#include <iostream>\n#include <memory>\n#include <boost\/asio.hpp>\nusing boost::asio::ip::tcp;\n\n\/\/ --\n\/*\n - std::make_shared<Session>(std::move(socket)) :\n \ud55c \uacf3\ub9cc \ud3ec\uc778\ud130 \uacf5\uc720\uc124\uc815 \/ Pointer sharing settings for only one location\n\n - : public std::enable_shared_from_this<Session> :\n shared_from_this(); \uc0ac\uc6a9\uc744 \uc704\ud574 \uc0c1\uc18d\n Inheritance for using shared_from_this();\n\n - shared_from_this :\n class Session \uac1d\uccb4\ub97c \ubcf5\uc0ac\ud574\uc11c \uc800\uc7a5\n Copy and save the class Session object\n ** this\uac00 \uc18c\uba78\ub420 \uc218 \uc788\uc5b4\uc11c \uc548\uc804\ud55c \uc138\uc158\uc5f0\uacb0 \uc720\uc9c0\ub97c \uc704\ud574 Session\ud074\ub798\uc2a4\ub97c \ud558\ub098 \ub354 \ubcf5\uc0ac\ud568\n Since 'this' can be destroyed,\n an additional copy of the Session class is made to maintain a safe session connection. **\n *\/\nclass Session : public std::enable_shared_from_this<Session> {\n tcp::socket socket_;\n char data_[1024];\n\npublic:\n Session(tcp::socket socket) : socket_(std::move(socket)) {}\n\n void start() {\n do_read();\n }\n\nprivate:\n void do_read() {\n\n \/\/ \ub78c\ub2e4 \uc0b4\uc544\uc788\ub294 \ub3d9\uc548 Session \uc548 \uc8fd\uc74c \/ The Session does not die as long as Lambda is alive\n \/\/ \uc774 \ud074\ub798\uc2a4 \uac1d\uccb4\ub97c \ubcf5\uc0ac\ud574\uc11c \uc800\uc7a5 \/ Copy and save this class object\n auto self = shared_from_this();\n\n \/*\n * async_read_some(buffer(data_), \ub78c\ub2e4\/rambda)\n * 1) \ub370\uc774\ud130 \uc624\uba74 data_\uc5d0 \ucc44\uc6cc\ub193\uace0 \ub78c\ub2e4 \uc2e4\ud589 \uc608\uc57d\ub9cc \ud55c\ub2e4.\n * When data arrives, fill it into data_ and just schedule the Lambda execution.\n *\n * 2) OS\uac00 \uc18c\ucf13\uc5d0 \ub370\uc774\ud130 \ub4e4\uc5b4\uc624\ub294 \uac70 \uac10\uc9c0 \u2192 data_ \ubc30\uc5f4\uc5d0 len\ubc14\uc774\ud2b8\ub9cc\ud07c \ubcf5\uc0ac\ud574 \ub454\ub2e4.\n * The OS detects incoming data in the socket and copies len bytes into the data_ array.\n *\n * 3) \ubcf5\uc0ac\uac00 \ub05d\ub0ac\uc73c\uba74 \ub78c\ub2e4 \uc2e4\ud589\n * Run Lambda once copying is finished\n *\n * 4) \uc774\ubbf8 data_\uc5d0 \ub4e4\uc5b4\uc640 \uc788\ub294 \ubcc0\uc218\ub97c \ub78c\ub2e4\uc5d0\uc11c \uc0ac\uc6a9\n * Using variables already in data_ in Lambda\n *\/\n socket_.async_read_some(boost::asio::buffer(data_),\n [this, self](boost::system::error_code ec, size_t len) {\n if (!ec) {\n std::cout << \"\ubc1b\uc74c\/Receive: \" << std::string(data_, len) << \"\\n\";\n do_write(len); \/\/ \uc5d0\ucf54 \/ echo\n }\n });\n }\n\n void do_write(size_t len) {\n auto self = shared_from_this();\n boost::asio::async_write(socket_, boost::asio::buffer(data_, len),\n [this, self](boost::system::error_code ec, size_t) {\n if (!ec) do_read(); \/\/ \uc77d\uae30 \/ read\n });\n }\n};\n\n\/\/ --\nclass Server {\n \/\/ socket() + bind() + listen()\uc218\ud589 \/ Execute socket() + bind() + listen()\n tcp::acceptor acceptor_; \/\/ private\npublic:\n Server(boost::asio::io_context& io, short port)\n : acceptor_(io, tcp::endpoint(tcp::v4(), port)) {\n do_accept();\n }\n\nprivate:\n void do_accept() {\n acceptor_.async_accept(\n \/\/ \ub78c\ub2e4\ud568\uc218 \/ Lambda function\n [this](boost::system::error_code ec, tcp::socket socket) {\n if (!ec) {\n \/\/ \uc5d0\ub7ec\uac00 \uc5c6\uc73c\uba74 \uc18c\ucf13\uc744 \uc138\uc158\uc5d0 \ub118\uae30\uace0 start \ud638\ucd9c, \uc18c\ucf13\uc740 \ubcf5\uc0ac \uc548\ub428\n \/\/ If there are no errors, pass the socket to the session and call start;\n \/\/ the socket is not copied\n std::make_shared<Session>(std::move(socket))->start();\n }\n \/\/ \ub2e4\uc74c \ud074\ub77c\uc774\uc5b8\ud2b8 \uacc4\uc18d \ubc1b\uc74c\n \/\/ Continue accepting next client\n \/\/\n \/\/ \ubb34\ud55c\ub8e8\ud504 \/ infinite loop\n do_accept();\n });\n }\n};\n\nint main() {\n try {\n boost::asio::io_context io;\n Server s(io, 12345);\n std::cout << \"\uc11c\ubc84 \uc2dc\uc791. \ud3ec\ud2b8 12345 \/ Start server. Port 12345\\n\";\n io.run();\n } catch (std::exception& e) {\n std::cerr << \"\uc5d0\ub7ec\/Error: \" << e.what() << \"\\n\";\n }\n return 0;\n}\n<\/code><\/pre>\n\n\n\n
\u2714\ufe0f \ud130\ubbf8\ub110\uc744 \ub450\uac1c \uc5f4\uc5b4\uc11c \ud558\ub098\ub294 \uc11c\ubc84 \ud558\ub098\ub294 \ud074\ub77c\uc774\uc5b8\ud2b8\ub97c \uc2e4\ud589\ud569\ub2c8\ub2e4. Open two terminals and run the server and the client in one.<\/p>\n\n\n\n
\u2714\ufe0fnc(netcat)\ub294 TCP\/UDP \ud1b5\uc2e0 \ud14c\uc2a4\ud2b8 \ub3c4\uad6c\uc785\ub2c8\ub2e4. nc(netcat) is a TCP\/UDP communication test tool.<\/p>\n\n\n\n
![\"\"](\"https:\/\/www.freelifemakers.org\/wordpress\/wp-content\/uploads\/2026\/05\/terminal-jpg-1-1024x606.jpg\")