asio+bind

#ifndef SERVER_H
#define SERVER_H
 
#include <iostream>
#include <QtGlobal>
#include <QFile>
#include <QTextStream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/shared_array.hpp>
#include <boost/thread.hpp>
 
typedef boost::shared_ptr<boost::asio::ip::tcp::socket> socket_ptr;
 
class Server
{
public:
    Server(const qint16 port);
    bool WorkResult();
    void system_handler(boost::shared_array<char> data, socket_ptr sockets);
    void file_handler(boost::shared_array<char> data, socket_ptr sockets);
    void text_handler(boost::shared_array<char> data, socket_ptr sockets);
private:
    static const size_t data_length = 520;
    bool end_flag = false;
    boost::asio::ip::tcp::endpoint endpoint_;
    QString file_name = "";
    void start_accept(boost::asio::ip::tcp::acceptor * acceptor);
    void on_accept_handler(boost::asio::ip::tcp::acceptor* acceptor,
                               socket_ptr sockets,
                               const boost::system::error_code& error);
    void data_handler(socket_ptr sockets,
                          boost::shared_array<char> data,
                          boost::system::error_code& error);
};
 
#endif // SERVER_H

#include "server.h"
 
Server::Server(qint16 port):endpoint_(boost::asio::ip::tcp::v4(),port){
    boost::asio::io_service io_service;
    boost::shared_ptr<boost::asio::io_service::work> work(new boost::asio::io_service::work(io_service));
    size_t cpu_count = boost::thread::hardware_concurrency();
    boost::thread_group work_threads;
    for(size_t i = 0; i < cpu_count; i++){
        work_threads.create_thread(boost::bind(&boost::asio::io_service::run, &io_service));
    }
    boost::asio::ip::tcp::acceptor (io_service,endpoint_);
    work.reset();
    work_threads.join_all();
    end_flag = true;
}
 
bool Server::WorkResult(){
    return end_flag;
}
 
void Server::system_handler(boost::shared_array<char> data, socket_ptr sockets){
    QFile file(file_name);
    file.open(QIODevice::ReadWrite);
}
 
void Server::file_handler(boost::shared_array<char> data, socket_ptr sockets){
     //
}
 
void Server::text_handler(boost::shared_array<char> data, socket_ptr sockets){
    //
}
 
    //начало асинхронного подключения
void Server::start_accept(boost::asio::ip::tcp::acceptor * acceptor){
    socket_ptr sockets(new socket_ptr::element_type(acceptor->get_io_service()));
    acceptor->async_accept(*sockets,
                           boost::bind(&Server::on_accept_handler,
                           acceptor,
                           sockets,
                           boost::asio::placeholders::error()));
}
    //получение данных
void Server::on_accept_handler(boost::asio::ip::tcp::acceptor* acceptor,
                               socket_ptr sockets,
                               const boost::system::error_code& error){
    if(!error){
        boost::shared_array<char> data(new char[data_length]);
        boost::asio::async_read(*sockets,
                                boost::asio::buffer(data.get(),data_length),
                                boost::asio::transfer_at_least(2),
                                boost::bind(&Server::data_handler,
                                            sockets,
                                            data,
                                            boost::asio::placeholders::error()));
    }else{
           /* boost::bind(&error_send_handler,
                        sockets,
                        boost::asio::placeholders::error());*/
    }
    start_accept(acceptor);
}
    //обработчик ошибки
    //void error_send_handler(socket_ptr sockets, const boost::system::error_code& error)
    //обработчик полученных данных
void Server::data_handler(socket_ptr sockets,
                          boost::shared_array<char> data,
                          boost::system::error_code& error){
    if(! error){
        switch(data[0]){
        case 's': system_handler(data,sockets); //обработчик системной информации
            break;
        case 'f': file_handler(data,sockets); //обработчик файлов
            break;
        case 't': text_handler(data,sockets); //обработчик текстовой информации
            break;
        }
    }
}

boost::asio::async_read(*sockets,
                                boost::asio::buffer(data.get(),data_length),
                                boost::asio::transfer_at_least(2),
                                boost::bind(&Server::data_handler,
                                            this,
                                            sockets,
                                            data,
                                            boost::asio::placeholders::error()));