Как использовать экземпляр QTcpSocket несколько раз с интервалом в пару секунд?

Мне приходится повторять один и тот же запрос с QTcpSocket несколько раз с интервалом в пару секунд. Простая задача, но я не могу заставить ее работать только с одним экземпляром объекта. Как снова подключиться к серверу, используя тот же экземпляр QTcpSocket? Я пробовал reset(), резюме(), сброс(), open() во многих различных комбинациях, и это ничего не дало. Я не могу подключиться к ConnectToHost() во второй раз...


c++ tcp qt qtcpsocket
person user1598527    schedule 29.03.2014    source источник
comment
Почему бы вам не оставить сокет подключенным между попытками?   -  person deGoot    schedule 29.03.2014
comment
Сервер, с которым я должен общаться, построен так, что он может обрабатывать только одно открытое соединение за раз. И мне нужно будет отправить другой запрос, когда этот запрос неактивен.   -  person user1598527    schedule 29.03.2014

Ответы (1)


arrow_upward
2
arrow_downward

Все, что вам нужно сделать, это connectToHost(), использовать соединение, а затем disconnectFromHost(). Вот и все. Ни больше ни меньше.

В приведенном ниже примере показано повторное использование экземпляров клиентского и серверного сокетов. Экземпляры сервера хранятся в пуле, который увеличивается только при необходимости. Он написан для Qt 5 и использует C++11.

// https://github.com/KubaO/stackoverflown/tree/master/questions/multisocket-22726075
#include <QtNetwork>

class EchoServer : public QTcpServer
{
   QStack<QTcpSocket*> m_pool;
   void incomingConnection(qintptr descr) Q_DECL_OVERRIDE {
      if (m_pool.isEmpty()) {
         auto s = new QTcpSocket(this);
         QObject::connect(s, &QTcpSocket::readyRead, s, [s]{
            s->write(s->readAll());
         });
         QObject::connect(s, &QTcpSocket::disconnected, this, [this, s]{
            m_pool.push(s);
         });
         m_pool.push(s);
      }
      m_pool.pop()->setSocketDescriptor(descr, QTcpSocket::ConnectedState);
   }
public:
   ~EchoServer() { qDebug() << "pool size:" << m_pool.size(); }
};

void setupEchoClient(QTcpSocket & sock)
{
   static const char kByteCount[] = "byteCount";
   QObject::connect(&sock, &QTcpSocket::connected, [&sock]{
      auto byteCount = 64 + qrand() % 65536;
      sock.setProperty(kByteCount, byteCount);
      sock.write(QByteArray(byteCount, '\x2A'));
   });
   QObject::connect(&sock, &QTcpSocket::readyRead, [&sock]{
      auto byteCount = sock.property(kByteCount).toInt();
      if (byteCount) {
         auto read = sock.read(sock.bytesAvailable()).size();
         byteCount -= read;
      }
      if (byteCount <= 0) sock.disconnectFromHost();
      sock.setProperty(kByteCount, byteCount);
   });
}

int main(int argc, char *argv[])
{
   QCoreApplication a(argc, argv);
   QHostAddress addr("127.0.0.1");
   quint16 port = 5050;

   EchoServer server;
   if (! server.listen(addr, port)) qFatal("can't listen");

   QTcpSocket clientSocket;
   setupEchoClient(clientSocket);

   auto connectsLeft = 20;
   auto connector = [&clientSocket, &addr, port, &connectsLeft]{
      if (connectsLeft--) {
         qDebug() << "connecting" << connectsLeft;
         clientSocket.connectToHost(addr, port);
      } else
         qApp->quit();
   };
   // reconnect upon disconnection
   QObject::connect(&clientSocket, &QTcpSocket::disconnected, connector);
   // initiate first connection
   connector();

   return a.exec();
}
person Kuba hasn't forgotten Monica    schedule 29.03.2014
comment
Спасибо, я допустил ошибку в другой части кода, которая выглядела так, как будто это проблема connectToHost(). - person user1598527; 29.03.2014