Search code examples
c++qtqtcpsocketqtnetworkqtcpserver

Console Chat Using QTcpSocket and QTcpServer


I want to write a console chat program in qt framework.I have a problem with sending messages.

Client sends messages to server but server doesn't take the messages until client program is closed.When client is closed, server displays all messages.I don't want that.I want server to get my messages when i send to it.

I wrote the codes below.You will see what i want to do if you look at main function of client.

    /*

    Created BY : 
    Creation DATE : 26/10/2012

    Client interface

    */

    #ifndef CLIENT_H
    #define CLIENT_H

    #include <QtNetwork>
    #include <QObject>
    #include <QtNetwork/QTcpSocket>

    namespace NetworkArdic
    {

    class Client : public QObject
    {
        Q_OBJECT
        public:

            Client(QObject * obj = 0,QString add="localhost", quint16 port = 4000);


            void SendData(QString data);

            virtual ~Client();

        private slots:


            void ReadData();

            void connected();

        private:

            QTcpSocket *socket;
    };

    }

    #endif


 /*

    Created BY : 
    Creation DATE : 26/10/2012

    Client source file

    */

    #include "Client.h"
    #include <QHostAddress>
    #include <iostream>
    using namespace std;

    namespace NetworkArdic{

    Client::Client(QObject * obj, QString add, quint16 port) : QObject(obj)
    {

        socket = new QTcpSocket(this);


        connect(socket, SIGNAL(readyRead()), this, SLOT(ReadData()));
        connect(socket, SIGNAL(connected()), this, SLOT(connected()));

        socket->connectToHost(QHostAddress(add), port);
    }

    Client::~Client(){
        socket->close();
        delete socket;
    }



    void Client::SendData(QString data)
    {
        if(!data.isEmpty())
        {
            socket->write(QString(data + "\n").toUtf8());
        }
    }

    void Client::ReadData()
    {
        while(socket->canReadLine())
        {

            QString line = QString::fromUtf8(socket->readLine()).trimmed();
            qDebug() << line;
        }
    }

    void Client::connected()
    {
        socket->write(QString("Client : Server connection has been made (: \n").toUtf8());
    }

    }

    int main(int argc, char *argv[])
    {
        QCoreApplication a(argc, argv);

        Client cli(0,"127.0.0.1",4000);

        string line;
        while(line!="exit"){
            cout << "Message : ";
            cin >> line;
            cli.SendData(QString(line.c_str()));
        }

        return a.exec();
    }

     /*

    Created BY : 
    Creation DATE : 26/10/2012

    Server interface


    */

    #ifndef SERVER_H
    #define SERVER_H

    #include <QtNetwork>
    #include <QObject>
    #include <QtNetwork/QTcpServer>
    #include <QtNetwork/QTcpSocket>

    namespace NetworkArdic
    {

        class Server: public QTcpServer
        {

            Q_OBJECT
            public:

              Server(QObject * parent = 0 , quint16 port = 4000);
              virtual  ~Server();

            private slots:

              void acceptConnection();
              void startRead();
              void disconnected();

            private:

              QTcpSocket * client;

        };

    }

    #endif // SERVER_H



   /*

    Created BY : 
    Creation DATE : 26/10/2012

    Server source file

    */


    #include "Server.h"
    #include <iostream>
    using namespace std;

    namespace NetworkArdic{

    Server::Server(QObject* parent , quint16 port): QTcpServer(parent)
    {
      connect(this, SIGNAL(newConnection()),this, SLOT(acceptConnection()));

      listen(QHostAddress::Any, port );
    }

    Server::~Server()
    {
      delete client;
      close();
    }

    void Server::acceptConnection()
    {
      client = nextPendingConnection();

      connect(client, SIGNAL(readyRead()), this, SLOT(startRead()));
      connect(client, SIGNAL(disconnected()), this, SLOT(disconnected()));

      qDebug() << "New client from:" << client->peerAddress().toString();
    }

    void Server::startRead()
    { 
        while(client->canReadLine())
        {
            QString line = QString::fromUtf8(client->readLine()).trimmed();
            qDebug() << "Client :" << line;

            client->write(QString("Server : I've taken your message (:\n").toUtf8());
        }

    }

    void Server::disconnected()
    {

        qDebug() << "Client disconnected:" << client->peerAddress().toString();

        client->write(QString("Server : I wish you didn't leave ):\n").toUtf8());

    }

    }

Solution

  • Try using socket->flush() after you write the data.

    http://doc.qt.digia.com/qt/qabstractsocket.html#flush