Visual Studio 实现TCp socket 异步通信，客户端和服务器端

#include <boost/asio.hpp> #include <iostream> #include <fstream> #include <map> #include <string> #define LENGTH 1000 using namespace boost::asio; class Server { typedef ip::tcp::socket socket_type; typedef std::shared_ptr<socket_type> sock_ptr; public: Server() :m_acceptor(m_io, ip::tcp::endpoint(ip::tcp::v4(), 6688)) { readFile(); accept(); } void run() { m_io.run(); } private: void accept() { sock_ptr sock(new socket_type(m_io)); m_acceptor.async_accept(*sock, std::bind(&Server::accept_handler, this, std::placeholders::_1, sock)); } void accept_handler(const boost::system::error_code& ec, sock_ptr sock) { if (ec) { return; } std::cout << "client:"; std::cout << sock->remote_endpoint().address() << std::endl; char str1[LENGTH + 16] = { 0 }; for (int i = 0; i < spliceNum + 1; i++) { strcpy_s(str1, mapFile.at(i).c_str()); sock->async_write_some(buffer(str1), std::bind(&Server::write_handler, this, std::placeholders::_1)); } accept(); } void write_handler(const boost::system::error_code&) { std::cout << "send msg complete." << std::endl; } void readFile() { std::fstream file("D:\\work\\testdata_case012.sp", std::ios::in | std::ios::out | std::ios::binary); if (!file.is_open()) { std::cout << "Open file failure!" << std::endl; } while (!file.eof()) { char buffer_splice[LENGTH] = { 0 }; file.read(buffer_splice, LENGTH); std::string strbuffer_splice(buffer_splice); mapFile.insert(std::pair<int, std::string>(spliceNum, buffer_splice)); spliceNum++; } file.close(); } private: io_service m_io; ip::tcp::acceptor m_acceptor; int spliceNum; std::map<int, std::string> mapFile; }; int main() { try { std::cout << "server" << std::endl; Server svr; svr.run(); } catch (std::exception& e) { std::cout << e.what() << std::endl; } return 0; }