// boost_asio_client.cpp : 定義控制臺應(yīng)用程序的入口點。 //#include "stdafx.h" #include <boost/asio.hpp> #include <boost/enable_shared_from_this.hpp> #include <boost/weak_ptr.hpp> #include <boost/shared_ptr.hpp> #include <boost/bind.hpp> #include <boost/thread.hpp> #include <boost/pool/singleton_pool.hpp>#include <winsock2.h> #include <mswsock.h> #include <MSTcpIP.h> #include <errno.h> #include <ws2ipdef.h> #include <process.h>#pragma comment(lib, "ws2_32.lib") #pragma comment(lib, "mswsock.lib") using namespace boost::asio; void connect_handler(const boost::system::error_code &ec) {printf("connect success\n"); } void tcp_async_client() {boost::asio::io_service service;boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address::from_string("0.0.0.0"), 6000);boost::asio::ip::tcp::socket sock(service);sock.async_connect(ep,connect_handler);//boost::thread(boost::bind());service.run(); } int _tmain(int argc, _TCHAR* argv[]) {tcp_async_client();return 0; }
// boost_asio_server.cpp : 定義控制臺應(yīng)用程序的入口點。 //#include "stdafx.h"#include <boost/asio.hpp> #include <boost/enable_shared_from_this.hpp> #include <boost/weak_ptr.hpp> #include <boost/shared_ptr.hpp> #include <boost/bind.hpp> #include <boost/thread.hpp> #include <boost/pool/singleton_pool.hpp>#include <winsock2.h> #include <mswsock.h> #include <MSTcpIP.h> #include <errno.h> #include <ws2ipdef.h> #include <process.h>#pragma comment(lib, "ws2_32.lib") #pragma comment(lib, "mswsock.lib")using namespace boost::asio;#include <map> using namespace std;typedef boost::shared_ptr<boost::asio::ip::tcp::socket> sock_ptr; typedef boost::shared_ptr<boost::asio::ip::tcp::acceptor> acceptor_ptr; typedef boost::shared_ptr<boost::asio::io_service> io_service_ptr;map<int,sock_ptr> link_mgr_map;void tcp_async_post_read(sock_ptr sock); void tcp_async_post_write(sock_ptr sock, const void *buf, size_t len); void tcp_async_receive_handler(sock_ptr sock, void *buf, const boost::system::error_code& ec, std::size_t bytes_transferred) {printf("buff:%s len:%d\n",buf,bytes_transferred);tcp_async_post_write(sock,buf,bytes_transferred);tcp_async_post_read(sock); }char buf[512]; int len = 512; void tcp_async_post_read(sock_ptr sock) {sock->async_read_some(boost::asio::buffer(buf, len), boost::bind(tcp_async_receive_handler, sock, buf, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)); } void tcp_async_send_handler(sock_ptr sock,const boost::system::error_code& ec, std::size_t bytes_transferred) {printf("send %d bytes success\n",bytes_transferred); } void tcp_async_post_write(sock_ptr sock, const void *buf, size_t len) {try{sock->async_write_some(boost::asio::buffer(buf, len), boost::bind(tcp_async_send_handler, sock, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred));}catch (const boost::system::system_error& e){e.code().value();} }typedef boost::shared_ptr<ip::tcp::socket> socket_ptr; typedef boost::shared_ptr<ip::tcp::acceptor> acceptor_ptr;void handle_accept(io_service *service,acceptor_ptr acc,socket_ptr sock, const boost::system::error_code &err); void start_accept(io_service *service,acceptor_ptr acc) {socket_ptr sock(new ip::tcp::socket(*service));acc->async_accept(*sock, boost::bind( handle_accept, service,acc,sock, _1) ); } void handle_accept(io_service *service,acceptor_ptr acc,socket_ptr sock, const boost::system::error_code &err) {if ( err) return;// 從這里開始, 你可以從socket讀取或者寫入static int index = 0;link_mgr_map.insert(make_pair(index++,sock));tcp_async_post_read(sock);start_accept(service,acc); }#define CLIENT_THREAD_NUM 4 #include <boost/threadpool/pool.hpp>void work_thread_func(io_service *service) {service->run(); }int _tmain(int argc, _TCHAR* argv[]) {io_service service;ip::tcp::endpoint ep( ip::tcp::v4(), 4567); // 監(jiān)聽端口2001acceptor_ptr acc(new boost::asio::ip::tcp::acceptor(service,ep));start_accept(&service,acc);//service.run();boost::threadpool::pool tp(4);tp.schedule( boost::bind(work_thread_func, &service));while (getchar()){boost::this_thread::sleep(boost::posix_time::seconds(1));}return 0; }

總結(jié)

以上是生活随笔為你收集整理的boost之asio异步io使用实例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。