QT 使用QTcpServer QTcpSocket 建立TCP服务器端和客户端

1。如图客户端连接server后，server发送“hello tcp“ 给客户端

2. 实例代码

----------------------------------- server端 -----------------------------------------

修改工程文件.pro， QT += network，添加net模块

widget.h

#ifndef WIDGET_H

#define WIDGET_H

#include <QWidget>

#include <QtNetwork>

namespace Ui {

class Widget;

}

class Widget : public QWidget

{

    Q_OBJECT

public:

    explicit Widget(QWidget *parent = 0);

    ~Widget();

private:

    Ui::Widget *ui;

    QTcpServer *tcpServer;

public slots:

    void sendMessages();

};

#endif // WIDGET_H

widget.cpp

#include "widget.h"

#include "ui_widget.h"

#include <QtGui>

Widget::Widget(QWidget *parent) :

    QWidget(parent),

    ui(new Ui::Widget)

{

    ui->setupUi(this);

    tcpServer = new QTcpServer(this);

    if( !tcpServer->listen(QHostAddress::LocalHost, 13888) )

    {   //监听本地主机的13888端口，如果出错就输出错误信息，并关闭

        qDebug() << tcpServer->errorString();

        close();

    }

    //连接信号和相应槽函数

    connect(tcpServer, SIGNAL(newConnection()), this, SLOT(sendMessages()));

}

Widget::~Widget()

{

    delete ui;

}

void Widget::sendMessages()

{

    QByteArray block;   //用于暂存我们要发送的数据

    QDataStream out(&block, QIODevice::WriteOnly);  //使用数据流写入数据

    out.setVersion(QDataStream::Qt_4_7);

    out << (quint16) 0;

    out << tr("hello tcp");

    out.device()->seek(0);

    out << (quint16) (block.size() - sizeof(quint16));

    //获取已经建立的连接的子套接字

    QTcpSocket *clientConnection = tcpServer->nextPendingConnection();

    connect(clientConnection, SIGNAL(disconnected()), clientConnection, SLOT(deleteLater()));

    /*clientConnection->disconnectFromHost();它表示当发送完成时就会断开连接，

     *这时就会发出disconnected()信号，

     *而最后调用deleteLater()函数保证在关闭连接后删除该套接字clientConnection。

    */

    clientConnection->write(block);

    clientConnection->disconnectFromHost();

    ui->statusLabel->setText("Send message successfil");

}

---------------------------------------- Client 端 ----------------------------------

clientwidget.h

#ifndef CLIENTWIDGET_H

#define CLIENTWIDGET_H

#include <QWidget>

#include <QtNetwork>

#include <QtGui>

namespace Ui {

class clientWidget;

}

class clientWidget : public QWidget

{

    Q_OBJECT

public:

    explicit clientWidget(QWidget *parent = 0);

    ~clientWidget();   

private slots:

    void newConnect();   //连接服务器

    void readMessage();  //接收数据

    void displayError(QAbstractSocket::SocketError); //显示错误

private:

    Ui::clientWidget *ui;

    QTcpSocket *tcpSocket;

    QString message; //存放从服务器接收到的字符串

    quint16 blockSize; //存放文件的大小信息

};

#endif // CLIENTWIDGET_H

clientwidget.cpp

#include "clientwidget.h"

#include "ui_clientwidget.h"

#include <QtDebug>

clientWidget::clientWidget(QWidget *parent) :

    QWidget(parent),

    ui(new Ui::clientWidget)

{

    ui->setupUi(this);

    tcpSocket = new QTcpSocket(this);

    connect(tcpSocket, SIGNAL(readyRead()), this, SLOT(readMessage()));

    connect(tcpSocket, SIGNAL(error(QAbstractSocket::SocketError)),

            this, SLOT(displayError(QAbstractSocket::SocketError)));

    /*这里关联了tcpSocket的两个信号，

     *当有数据到来时发出readyRead()信号，我们执行读取数据的readMessage()函数。

     *当出现错误时发出error()信号，我们执行displayError()槽函数。

    */

    connect(ui->linkButton, SIGNAL(clicked()), this, SLOT(newConnect()));

}

clientWidget::~clientWidget()

{

    delete ui;

}

void clientWidget::newConnect()

{

    blockSize = 0;

    tcpSocket->abort(); //取消已有的连接

    tcpSocket->connectToHost(ui->hostLineEdit->text(),

                             ui->portLineEdit->text().toInt());

     //连接到主机，这里从界面获取主机地址和端口号

}

void clientWidget::readMessage()

{

    QDataStream in(tcpSocket);

    in.setVersion(QDataStream::Qt_4_7);

    if( blockSize == 0 )

    {

        //判断接收的数据是否有两字节，也就是文件的大小信息

        //如果有则保存到blockSize变量中，没有则返回，继续接收数据

        if( tcpSocket->bytesAvailable() < (int)sizeof(quint16) )

            return;

        in >> blockSize;

    }

    //如果没有得到全部的数据，则返回，继续接收数据

    if( tcpSocket->bytesAvailable() < blockSize )

        return;

    in >> message;  //将接收到的数据存放到变量中

    ui->messageLabel->setText(message);

}

void clientWidget::displayError(QAbstractSocket::SocketError)

{

    qDebug() << tcpSocket->errorString();

}

巴特西

QT 使用QTcpServer QTcpSocket 建立TCP服务器端和客户端

最新文章

热门文章

巴特西

QT 使用QTcpServer QTcpSocket 建立TCP服务器端 和 客户端

最新文章

热门文章

QT 使用QTcpServer QTcpSocket 建立TCP服务器端和客户端