1Boost之TCP，Client and Server

客户端代码

#include <boost/asio.hpp>

#include <iostream>

#include <stdlib.h>

using namespace std;

using namespace boost::asio;

void main()

{

    io_service iosev;

    ip::tcp::socket mysorket(iosev);

    ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 1100);

    boost::system::error_code ec;

    mysorket.connect(ep, ec);//链接

    while (1)

    {

        char str[1024] = { 0 };

        cout << "请输入";

        cin >> str;

        cout << endl;

        mysorket.write_some(buffer(str), ec);

        memset(str, 0, 1024);//清空字符串

        mysorket.read_some(buffer(str), ec);

        cout << "收到" << str << endl;

    }

    cin.get();

}

客户端代码：

服务器端代码：

#include <boost/asio.hpp>

#include <iostream>

#include <stdlib.h>

using namespace std;

using namespace boost::asio;

void main()

{

    io_service iosev;

    //这里使用ip v4协议，端口号是1100

    ip::tcp::acceptor myacceptor(iosev, ip::tcp::endpoint(ip::tcp::v4(), 1100));

    while (1)

    {

        //构建TCP

        ip::tcp::socket mysocket(iosev);

        //接受套接字

        myacceptor.accept(mysocket);

        cout << "客户端" << mysocket.remote_endpoint().address() << ":"

            << mysocket.remote_endpoint().port() << "链接上" << endl;

        char recestr[1024] = { 0 };

        boost::system::error_code ec;

        //处理网络异常

        int length = mysocket.read_some(buffer(recestr), ec);

        cout << "收到" << recestr << "长度" << length << endl;

        system(recestr);

        length = mysocket.write_some(buffer(recestr, length), ec);

        cout << "发送报文长度" << length << endl;

    }

    cin.get();

}

运行结果：