您好,登錄后才能下訂單哦!
這篇“boost.asio框架系列之socket編程怎么實現(xiàn)”文章的知識點大部分人都不太理解,所以小編給大家總結(jié)了以下內(nèi)容,內(nèi)容詳細,步驟清晰,具有一定的借鑒價值,希望大家閱讀完這篇文章能有所收獲,下面我們一起來看看這篇“boost.asio框架系列之socket編程怎么實現(xiàn)”文章吧。
客戶端的代碼如下:
#include <iostream> #include <boost/array.hpp> #include <boost/asio.hpp> using boost::asio::ip::tcp; int main(int argc, char* argv[]) { try { boost::asio::io_service io_service; tcp::endpoint end_point(boost::asio::ip::address::from_string("127.0.0.1"), 3200); tcp::socketsocket(io_service); socket.connect(end_point); for (;;) { boost::array<char, 128> buf; boost::system::error_code error; size_t len = socket.read_some(boost::asio::buffer(buf), error); if (error == boost::asio::error::eof) break; // Connection closed cleanly by peer. else if (error) throw boost::system::system_error(error); // Some other error. std::cout.write(buf.data(), len); } } catch (std::exception& e) { std::cerr << e.what() << std::endl; } return 0; }
主要流程如下:
通過tcp::socket類定義一個tcp client對象socket
通過connect函數(shù)連接服務(wù)器,打開socket連接。
通過read_some函數(shù)來讀數(shù)據(jù)
另外,還可以通過write_some來寫數(shù)據(jù),通過close來關(guān)閉socket連接(這里是通過釋放socket對象隱式釋放連接)。
服務(wù)器代碼如下:
#include <ctime> #include <iostream> #include <string> #include <boost/asio.hpp> using namespace boost; using boost::asio::ip::tcp; int main() { try { asio::io_service io_service; tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 3200)); for (;;) { tcp::socket socket(io_service); acceptor.accept(socket); time_t now = time(0); std::string message = ctime(&now); system::error_code ignored_error; socket.write_some(asio::buffer(message), ignored_error); } } catch (std::exception& e) { std::cerr << e.what() << std::endl; } return 0; }
主要流程如下:
通過tcp::acceptor類創(chuàng)建一個tcp server對象,并綁定端口(也可以不在構(gòu)造器中自動綁定,而通過bind函數(shù)手動綁定)
通過accept函數(shù)獲取遠端連接
通過遠端連接的write_some函數(shù)將數(shù)據(jù)發(fā)往客戶端
前面的服務(wù)器是同步版本,在大并發(fā)的場景下一般需要用到異步socket。服務(wù)器的異步版本如下:
#include <ctime> #include <iostream> #include <string> #include <memory> #include <functional> #include <boost/asio.hpp> using boost::asio::ip::tcp; using namespace std; void process_client(shared_ptr<tcp::socket> client) { time_t now = time(0); shared_ptr<string> message(new string(ctime(&now))); auto callback = [=](const boost::system::error_code& err ,size_t size) { if ((int)size == message->length()) cout << "write completed" << endl; }; client->async_send(boost::asio::buffer(*message), callback); } typedef function<void (const boost::system::error_code&)> accept_callback; void start_accept(tcp::acceptor& server) { shared_ptr<tcp::socket> client(new tcp::socket(server.get_io_service())); accept_callback callback = [&server, client](const boost::system::error_code& error) { if (!error) process_client(client); start_accept(server); }; server.async_accept(*client, callback); } int main() { try { boost::asio::io_service io_service; tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 3200)); start_accept(acceptor); io_service.run(); } catch (std::exception& e) { std::cerr << e.what() << std::endl; } return 0; }
這個異步版本的邏輯倒不是很復(fù)雜,基本上和.net中傳統(tǒng)的異步socket相似,不過需要注意的是,由于c++中內(nèi)存需要自己管理,而asio框架也沒有提供任何管理機制,因此需要注意async_accept、async_send等函數(shù)的參數(shù)生命周期,切記不能在里面?zhèn)魅霔W兞康囊谩H绻嵌炎兞?,需要確保釋放,本例中我是通過share_ptr來實現(xiàn)的自動釋放。
以上就是關(guān)于“boost.asio框架系列之socket編程怎么實現(xiàn)”這篇文章的內(nèi)容,相信大家都有了一定的了解,希望小編分享的內(nèi)容對大家有幫助,若想了解更多相關(guān)的知識內(nèi)容,請關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。