main.cpp

#include "communicate_TCP.hpp"
#include <boost/thread/thread.hpp>


void TestServer()
{
    io_service ios;
    Server server(ios,9900);

    server.Accept();
    ios.run();
}


int main()
{
    io_service ios_server;
    boost::asio::io_service::work work_server(ios_server);
    boost::thread thread_server([&ios_server]{ios_server.run();});
    Server server(ios_server,9900);
    server.Accept();



    io_service ios;
    boost::asio::io_service::work work(ios);
    boost::thread thd([&ios]{ios.run();});

    Connector conn(ios,"127.0.0.1",9900);
    conn.Start();

    string str;
    if(!conn.IsConnected())
    {
        cin>>str;
        return -1;
    }
    const int len = 512;
    char line[len] = "";


    while(cin>>str)
    {
        char header[HEAD_LEN] = {};
        int totalLen = str.length()+1+HEAD_LEN;
        std::sprintf(header,"%d",totalLen);
        memcpy(line,header,HEAD_LEN);
        memcpy(line+HEAD_LEN,str.c_str(),str.length()+1);

        conn.Send(line,totalLen);
    }

    thread_server.join();



    return 0;
}