VPF::[boost] asio чтение в клинете - Форум программистов

ecspertiza

Дата 21.4.2011, 09:58 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 763
Регистрация: 3.11.2008
Где: г.Смоленск

Репутация: 1
Всего: 5

С бустом начал общаться довольно не давно, и опыта еще маловато, так что если что не судите строго

пытаюсь набрасать клиента для чтения и передачи данных вот что получилось

Код


#include <boost/asio.hpp>
#include <iostream>
#include <boost/bind.hpp>
#include <boost/asio.hpp>
#include <boost/thread.hpp>

using boost::asio::ip::tcp;

class session{

    public:
        session(boost::asio::io_service &ios, std::string ip, std::string port)
            :io_service(ios),resolver(io_service),query(tcp::v4(), ip.c_str(), port.c_str()),sock(ios)
        {            
            iterator = resolver.resolve(query);
            sock.connect(*iterator);

            sock.async_read_some(boost::asio::buffer(data_, max_length),
                boost::bind(&session::handle_read, this,boost::asio::placeholders::error,
                boost::asio::placeholders::bytes_transferred));
        }    

        void handle_read(const boost::system::error_code& error,
                size_t bytes_transferred)
        {
                std::cout << "handle read " << data_ << std::endl;
        }

        void handle_write(std::string s)
        {
            std::cout << "handle write " << s << std::endl;
                boost::asio::async_write(sock,
                    boost::asio::buffer(s, s.length()),
                    boost::bind(&session::handle_read, this, boost::asio::placeholders::error,
                boost::asio::placeholders::bytes_transferred));

        }

    private:
        boost::asio::io_service &io_service;
        tcp::resolver resolver;
        tcp::resolver::query query;
        tcp::resolver::iterator iterator;

        tcp::socket sock;
        enum { max_length = 1024 };
        char data_[max_length];
};

class client{
    public:
        client()
        {
            last_session = 0;
        }

        void connect(std::string ip, std::string port)
        {
            last_session = new session(io_service,ip,port);
        }

        void send_data(std::string s)
        {
            last_session->handle_write(s);
        }

    private:
        boost::asio::io_service io_service;
        session *last_session;
};

void Interface(client *c)
{
    while(true)
    {
        std::string s;
        std::cin >> s;
        c->send_data(s);
    }
}

int main(int argc, char* argv[])
{
    client c;
    c.connect("127.0.0.1","5514");

    boost::thread t(&Interface,&c);
    t.join();

    return 0;
}

данные передает ,но не принимает, то есть процедура handle_read не выполняется. Не подскажете где я накосячил?

--------------------

С уважением,
мастер конфетного цеха!

онлайн компилер
залип

boostcoder

Дата 21.4.2011, 11:51 (ссылка)

(нет голосов)

Загрузка ...

pattern`щик

Профиль
Группа: Завсегдатай
Сообщений: 5458
Регистрация: 1.4.2010

Репутация: 49
Всего: 110

bytes_transferred в handle_read ровняется переданному размеру?

Это сообщение отредактировал(а) boostcoder - 21.4.2011, 12:04

--------------------

компилятор онлайн с поддержкой C++11
сборки компиляторов MinGW

ecspertiza

Дата 21.4.2011, 11:54 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 763
Регистрация: 3.11.2008
Где: г.Смоленск

Репутация: 1
Всего: 5

беда в том что процедура handle_read или не вызывается или блокируется вывод, ибо вывод вот этой строки

Код


std::cout << "handle read " << data_ << std::endl

я так не разу и не увидел

--------------------

С уважением,
мастер конфетного цеха!

онлайн компилер
залип

boostcoder

Дата 21.4.2011, 12:10 (ссылка)

(нет голосов)

Загрузка ...

pattern`щик

Профиль
Группа: Завсегдатай
Сообщений: 5458
Регистрация: 1.4.2010

Репутация: 49
Всего: 110

что-то я не обнаружил io_service::run() ;)

--------------------

компилятор онлайн с поддержкой C++11
сборки компиляторов MinGW

ecspertiza

Дата 21.4.2011, 12:22 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 763
Регистрация: 3.11.2008
Где: г.Смоленск

Репутация: 1
Всего: 5

io_service.run() тоже пробовал запускать, вот так

Код


#include <boost/asio.hpp>
#include <iostream>
#include <boost/bind.hpp>
#include <boost/asio.hpp>
#include <boost/thread.hpp>
using boost::asio::ip::tcp;
class session{
    public:
        session(boost::asio::io_service &ios, std::string ip, std::string port)
            :io_service(ios),resolver(io_service),query(tcp::v4(), ip.c_str(), port.c_str()),sock(ios)
        {            
            iterator = resolver.resolve(query);
            sock.connect(*iterator);
            sock.async_read_some(boost::asio::buffer(data_, max_length),
                boost::bind(&session::handle_read, this,boost::asio::placeholders::error,
                boost::asio::placeholders::bytes_transferred));
        }    
        void handle_read(const boost::system::error_code& error,
                size_t bytes_transferred)
        {
                std::cout << "handle read " << data_ << std::endl;
        }
        void handle_write(std::string s)
        {
            std::cout << "handle write " << s << std::endl;
                boost::asio::async_write(sock,
                    boost::asio::buffer(s, s.length()),
                    boost::bind(&session::handle_read, this, boost::asio::placeholders::error,
                boost::asio::placeholders::bytes_transferred));
        }
    private:
        boost::asio::io_service &io_service;
        tcp::resolver resolver;
        tcp::resolver::query query;
        tcp::resolver::iterator iterator;
        tcp::socket sock;
        enum { max_length = 1024 };
        char data_[max_length];
};
class client{
    public:
        client()
        {
            last_session = 0;
            io_service.run();
        }
        void connect(std::string ip, std::string port)
        {
            last_session = new session(io_service,ip,port);
        }
        void send_data(std::string s)
        {
            //io_service.post(boost::bind(&session::handle_write, last_session, s));
            last_session->handle_write(s);
        }
    private:
        boost::asio::io_service io_service;
        session *last_session;
};
void Interface(client *c)
{
    while(true)
    {
        std::string s;
        std::cin >> s;
        c->send_data(s);
    }
}
int main(int argc, char* argv[])
{
    client c;
    c.connect("127.0.0.1","5514");
    
    Sleep(1000);

    c.send_data("siski");

    Sleep(5000);

    return 0;
}

собственно тема та же, в процедуре send_data пробовал еще и вот так данные отправлять

Код


io_service.post(boost::bind(&session::handle_write, last_session, s));

но так они и не отправляются, вообщем беда со всех сторон smile

--------------------

С уважением,
мастер конфетного цеха!

онлайн компилер
залип

boostcoder

Дата 21.4.2011, 12:30 (ссылка)

(голосов:3)

Загрузка ...

pattern`щик

Профиль
Группа: Завсегдатай
Сообщений: 5458
Регистрация: 1.4.2010

Репутация: 49
Всего: 110

Цитата(ecspertiza @ 21.4.2011, 12:22

)

client()
        {
            last_session = 0;
            io_service.run();

срочно читать доку! smile

--------------------

компилятор онлайн с поддержкой C++11
сборки компиляторов MinGW

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| C/C++: Общие вопросы \| Следующая тема »