Qt + boost::asio - простейший симбиоз

[V1KT0P]

Сразу скажу что я глядел на qt_echo_server, но там слишком много кода для того чтоб я смог сразу разобраться. Да и asio я только начал изучать.
Так вот несколько вопросов:
1. Как проще всего установить связь между Qt и asio?
2. Могу ли я добавлять задания для asio из разных потоков, потокобезопасно ли это?
3. Как из asio вызвать сигналы Qt так, чтобы сигнал объекта выполнялся в том потоке к которому принадлежит объект?
4. Забить на симбиоз и делать GUI и сервер отдельными приложениями? С одной стороны вроде хорошо, с другой стороны добавлять прослойку межпроцессорного взаимодействия не хочется.

[BRE]

4. Забить на симбиоз и делать GUI и сервер отдельными приложениями?

Вот только так. Не нужны серверы с гуями, не должно быть на аппаратных серверах гуев.

А asio хорош, да. Правильный выбор. Еще я бы предложил посмотреть на erlang.

[V1KT0P]

А asio хорош, да. Правильный выбор. Еще я бы предложил посмотреть на erlang.

Все твердят что типа серверы на erlang получаются идеальные. Но мне его вообще не хочется изучать.
Я хочу еще изучить Java, Ruby, Python и мелочь вроде JavaScript и Lua.

[V1KT0P]

А asio хорош, да. Правильный выбор.

Я так понял ты знаешь asio, как установить timeout на асинхронный сокет?

[BRE]

Я так понял ты знаешь asio, как установить timeout на асинхронный сокет?

Я использую таймер (asio::deadline_timer).

[V1KT0P]

Я так понял ты знаешь asio, как установить timeout на асинхронный сокет?

Я использую таймер (asio::deadline_timer).

Смотри, я использую стандартные вызовы:

Код

C++ (Qt)
socket_.async_read_some(boost::asio::buffer(buffer_),
    strand_.wrap(
      boost::bind(&connection::handle_read, shared_from_this(),
        boost::asio::placeholders::error,
        boost::asio::placeholders::bytes_transferred)));
boost::asio::async_write(socket_, reply_.to_buffers(),
    strand_.wrap(
      boost::bind(&connection::handle_write, shared_from_this(),
        boost::asio::placeholders::error)));

Как мне по событию таймера отменить эти задания?

[BRE]

Как мне по событию таймера отменить эти задания?

Сказать сокету shutdown. Это приведет к срабатыванию всех активных обработчиков с кодом ошибки.

[V1KT0P]

Как мне по событию таймера отменить эти задания?

Сказать сокету shutdown. Это приведет к срабатыванию всех активных обработчиков с кодом ошибки.

Спасибо, действительно работает.

[Barmaglodd]

А asio хорош, да. Правильный выбор. Еще я бы предложил посмотреть на erlang.

asio-ужас на шаблонах, месяц пытался его освоить, но не смог до конца, хотя с остальными частями буста несколько лет работаю.
А Erlang да, хорош! После asio переделал всё за несколько дней на него.

[V1KT0P]

А asio хорош, да. Правильный выбор. Еще я бы предложил посмотреть на erlang.

asio-ужас на шаблонах, месяц пытался его освоить, но не смог до конца, хотя с остальными частями буста несколько лет работаю.
А Erlang да, хорош! После asio переделал всё за несколько дней на него.

А по производительности как? Выросла или упала?

[Barmaglodd]

Хз, у меня больше 200 клиентов никогда не было, ощутимой нагрузки они не создают. Да и сравнивать сложно, Erlang вариант далеко ущёл от прототипа на asio.

[V1KT0P]

Хз, у меня больше 200 клиентов никогда не было, ощутимой нагрузки они не создают. Да и сравнивать сложно, Erlang вариант далеко ущёл от прототипа на asio.

Тю у меня сервер на Qt4 тянет 500 клиентов. Переписываю на asio только из-за того что необходимо тянуть 2500 клиентов.

[V1KT0P]

Как мне по событию таймера отменить эти задания?

Сказать сокету shutdown. Это приведет к срабатыванию всех активных обработчиков с кодом ошибки.

Еще вопрос, какой аналог QDataStream есть в asio или boost? Необходимо иметь возможность указать порядок байт.

[BRE]

Еще вопрос, какой аналог QDataStream есть в asio или boost? Необходимо иметь возможность указать порядок байт.

Не знаю такого.

[V1KT0P]

Еще вопрос, какой аналог QDataStream есть в asio или boost? Необходимо иметь возможность указать порядок байт.

Не знаю такого.

А как тогда ты из буфера вытягиваешь данные с нужным порядком байт?
Может я что-то не так делаю:
1) Буфер у меня массив char(m_buffer), в asio передаю вот так:

Код

C++ (Qt)
m_socket.async_read_some(boost::asio::buffer(m_buffer+m_buffer_count, sizeof(m_buffer)-m_buffer_count),
                             m_strand.wrap(
                                 boost::bind(&Connection::handleRead, shared_from_this(),
                                             boost::asio::placeholders::error,
                                             boost::asio::placeholders::bytes_transferred)));

Вытягиваю данные через memcpy, ибо не понял как по другому сделать.