#include <boost/asio.hpp>
#include <iostream>
using namespace boost::asio;
int main()
{try{io_service io;ip::tcp::endpoint ep(ip::tcp::v4(), 6688);ip::tcp::acceptor acceptor(io, ep);while (1){ip::tcp::socket sock(io);acceptor.accept(sock);std::cout << "client:" << sock.remote_endpoint().address() << std::endl;sock.write_some(buffer("hello asio"));}}catch (std::exception& e){std::cout << e.what() << std::endl;}return 0;
}

#include <boost/asio.hpp>
#include <iostream>
#include <vector>
#include <string>
using namespace boost::asio;
int main()
{try{io_service io;ip::tcp::endpoint ep(ip::address::from_string("127.0.0.1"), 6688);ip::tcp::socket sock(io);sock.connect(ep);char str[1024];sock.read_some(buffer(str));std::cout << "receive from" << sock.remote_endpoint().address() << std::endl;;std::cout << str << std::endl;}catch (std::exception& e){std::cout << e.what() << std::endl;}getchar();return 0;
}

// BoostTcpServer.cpp : 定义控制台应用程序的入口点。
// 

#include "stdafx.h"
#include "boost/asio.hpp"
#include "boost/thread.hpp" using namespace std;
using namespace boost::asio; #ifdef _MSC_VER
#define _WIN32_WINNT  0X0501 //避免VC下编译警告
#endif #define PORT 1000
#define IPV6
//#define IPV4 

int _tmain(int argc, _TCHAR* argv[])
{ // 所有asio类都需要io_service对象
  io_service iosev; //创建用于接收客户端连接的acceptor对象
#ifdef IPV4 ip::tcp::acceptor acceptor(iosev,ip::tcp::endpoint(ip::tcp::v4(), PORT));
#endif #ifdef IPV6 ip::tcp::acceptor acceptor(iosev,ip::tcp::endpoint(ip::tcp::v6(), PORT));
#endif while (true) { // socket对象
    ip::tcp::socket socket(iosev); // 等待直到客户端连接进来
    acceptor.accept(socket); // 显示连接进来的客户端 std::cout <<"remote ip:"<<socket.remote_endpoint().address()<<endl; std::cout <<"remote port:"<<socket.remote_endpoint().port() << std::endl; char buf[2048]; boost::system::error_code ec; while(1) { socket.read_some(buffer(buf),ec); if (ec) { std::cout <<boost::system::system_error(ec).what() << std::endl; break ; } std::cout<<"recv msg:"<<buf<<endl; if(strcmp(buf,"bye")==0)//收到结束消息结束客户端连接
      { break; } socket.write_some(buffer("I heared you!\n"),ec); if (ec) { std::cout <<boost::system::system_error(ec).what() << std::endl; break ; } } socket.close(); // 与当前客户交互完成后循环继续等待下一客户连接
  } return 0;
} 

#include "stdafx.h"
#include "boost/asio.hpp" using namespace boost::asio; #ifdef _MSC_VER
#define _WIN32_WINNT  0X0501 //避免VC下编译警告
#endif #define PORT 1000
#define IPV6
//#define IPV4 

int _tmain(int argc, _TCHAR* argv[])
{ // 所有asio类都需要io_service对象
  io_service iosev; // socket对象
  ip::tcp::socket socket(iosev); // 连接端点，这里使用了本机连接，可以修改IP地址测试远程连接
#ifdef IPV4 ip::address_v4 address=ip::address_v4::from_string("127.0.0.1");
#endif #ifdef IPV6 //"0:0:0:0:0:0:0:1"为IPV6的本机回环地址，类似于"127.0.0.1" ip::address_v6 address=ip::address_v6::from_string("0:0:0:0:0:0:0:1");
#endif ip::tcp::endpoint ep(address, PORT); // 连接服务器
  boost::system::error_code ec; socket.connect(ep,ec); // 如果出错，打印出错信息 if (ec) { std::cout << boost::system::system_error(ec).what() << std::endl; return -1; } //循环发送和接收数据 for(int i=0;i<5;++i) { //发送数据 socket.write_some(buffer("hello"), ec); // 接收数据 char buf[100]; size_t len=socket.read_some(buffer(buf), ec); std::cout.write(buf, len); Sleep(500); } //发送与服务端约定好的结束语,由服务端断链 socket.write_some(buffer("bye"), ec); getchar(); return 0;
}