网站怎样免费推广/百度网盘网页-黄石网站建设

网站怎样免费推广,百度网盘网页,学校网站建设的难点,养殖场网站模板TCP简介： Transmission Control Protocol,传输控制协议。用于数据传输的低层网络协议，多个物联网协议都是基于TCP协议的。它是一个面向数据流和连接的可靠传输协议。 TCP头部格式: QTcpSocket类为TCP提供了一个接口，继承自QAbstractSocket…

TCP简介：

Transmission Control Protocol,传输控制协议。用于数据传输的低层网络协议，多个物联网协议都是基于TCP协议的。它是一个面向数据流和连接的可靠传输协议。

TCP头部格式:

QTcpSocket类为TCP提供了一个接口，继承自QAbstractSocket。可实现POP3、SMTP、NNTP等标准的网络协议，也可以实现自定义的网络协议。异步工作，依靠事件循环来检测到来的数据，并且自动刷新输出的数据。而QAbstractSocket继承自QIODevice，故该类具备文件的读写功能，可以使用QTextStream和QDataStream。

QHostAddress QAbstractSocket::peerAddress () const 获取主机的IP地址

quint16 QAbstractSocket::peerPort () const 获取主机的端口号

qint64 QIODevice::write ( const QByteArray & byteArray ) //写入数据，即通过TCP发送数据。

QByteArray QIODevice::read ( qint64 maxSize ) //读取数据，最多读取maxSize。即获取TCP接收的存放在缓冲区的数据

QByteArray QIODevice::readAll () //获取TCP存放在缓冲区可读取的所有数据。

从一个QTcpSocket中读取数据前，必须先调用qint64 QIODevice::bytesAvailable () const 函数来确保已经有足够的数据可用。

涉及到的信号：

void QAbstractSocket::connected () [signal] 当连接建立成功发射连接信号，指示一个已建立的新连接。

void QAbstractSocket::error ( QAbstractSocket::SocketError socketError ) [signal] 连接发生了错误，就会发送error()信号，参数指示发生了什么错误。

void QAbstractSocket::disconnected () [signal] 断开一个已经存在的连接时，发射断开信号。

void QAbstractSocket::stateChanged ( QAbstractSocket::SocketState socketState ) [signal] 状态改变都会发射stateChanged()信号。

void QIODevice::bytesWritten ( qint64 bytes ) [signal] 表示数据写入完成，对应的可以调用bytesToWrite()方法了解写入了多少字节的数据。

void QIODevice::readyRead () [signal] 表示有数据可以读取，对应的可以调用bytesAvailable()方法了解可以读取多少字节的数据。

一个简单的TCP客户端和服务端程序，单连接。

客户端程序：

#ifndef QTTCPCLIENT_H
#define QTTCPCLIENT_H#include <QObject>
#include <QAbstractSocket>class QTcpSocket; //前置声明//客户端程序  单连接，即一个客户端一个服务端
class QtTcpClient : public QObject
{Q_OBJECT
public:explicit QtTcpClient(QObject *parent = 0);~QtTcpClient();void sendMessage(); //发送信息private slots:void readMessage();  //获取返回的信息void displayError(QAbstractSocket::SocketError);  //获取连接发生的错误private:QTcpSocket *tcpSocket;  //tcp连接quint16 blockSize;  //发送数据的大小
};#endif // QTTCPCLIENT_H#include "qttcpclient.h"
#include <QtNetwork>
#include <QDataStream>
#include <QString>
#include <QByteArray>
#include <QIODevice>
#include <QObject>
#include <QDebug>QtTcpClient::QtTcpClient(QObject *parent) :QObject(parent)
{tcpSocket=new QTcpSocket(this);//建立信号连接，readyRead表示有数据过来，需要读取connect(tcpSocket,SIGNAL(readyRead()),this,SLOT(readMessage()));//建立信号连接，error(QAbstractSocket::SocketError)连接发生错误或关闭时会发射此信号connect(tcpSocket,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(displayError(QAbstractSocket::SocketError)));blockSize=0;tcpSocket->abort();//终止已有的连接tcpSocket->connectToHost(QHostAddress(QString("127.0.0.1")),6666);//建立新的连接qDebug()<<"client run......"<<endl;
}QtTcpClient::~QtTcpClient()
{delete tcpSocket;tcpSocket=NULL;
}void QtTcpClient::sendMessage()
{QByteArray block;QDataStream out(&block,QIODevice::WriteOnly);out.setVersion(QDataStream::Qt_4_0);out<<(quint16)0;out<<QString("hi server this is my first connect!!!");out.device()->seek(0);//定位到数据的开头out<<(quint16)(block.size()-sizeof(quint16)); //添加数据大小信息到数据开头tcpSocket->write(block); //发送数据}void QtTcpClient::readMessage()
{QString message;QDataStream in(tcpSocket);in.setVersion(QDataStream::Qt_4_0);if(blockSize==0){//判断接收的数据是否大于两字节，也就是文件的大小信息所占的空间//如果是则保存到blockSize中，否则直接返回，继续接收数据。if(tcpSocket->bytesAvailable()<(int)sizeof(quint16)){return;}in>>blockSize;}//如果没有接收完全部数据，则返回继续接收if(tcpSocket->bytesAvailable()<blockSize){return;}//将接收的数据存放到变量中in>>message;qDebug()<<message;this->sendMessage();//断开连接tcpSocket->disconnectFromHost();
}void QtTcpClient::displayError(QAbstractSocket::SocketError)
{switch(tcpSocket->error()){case QAbstractSocket::RemoteHostClosedError:  //远程服务端关闭连接错误tcpSocket->disconnectFromHost();qDebug()<<"client close now";break;default:qDebug()<<"error id: "<<tcpSocket->error()<<endl;qDebug()<<"error message: "<<tcpSocket->errorString()<<endl;break;}
}#include <QCoreApplication>
#include "qttcpclient.h"int main(int argc, char *argv[])
{QCoreApplication a(argc, argv);QtTcpClient tcpclient_t;return a.exec();
}

服务端程序：

#ifndef QTTCPSERVER_H
#define QTTCPSERVER_H#include <QObject>
#include <QAbstractSocket>class QTcpServer; //前置声明
class QTcpSocket;//服务端程序  单连接，即一个客户端一个服务端
class QtTcpServer : public QObject
{Q_OBJECT
public:explicit QtTcpServer(QObject *parent = 0);~QtTcpServer();private slots:void sendMessage();//发送信息void readMessage();//获取返回的信息void displayError(QAbstractSocket::SocketError);//获取连接发生的错误private:QTcpServer *tcpServer; //tcp服务端QTcpSocket *clientConnect;//来自客户端的连接quint16 blockSize;  //接收数据的大小
};#endif // QTTCPSERVER_H#include "qttcpserver.h"
#include <QtNetwork>
#include <QDataStream>
#include <QString>
#include <QByteArray>
#include <QIODevice>
#include <QObject>
#include <QDebug>QtTcpServer::QtTcpServer(QObject *parent) :QObject(parent)
{blockSize=0;tcpServer=new QTcpServer(this);//开始监听if(!tcpServer->listen(QHostAddress(QString("127.0.0.1")),6666)){qDebug()<<tcpServer->serverError()<<endl;qDebug()<<tcpServer->errorString()<<endl;qApp->exit();}//建立信号连接，每来一个新的连接，就发送服务端信息connect(tcpServer,SIGNAL(newConnection()),this,SLOT(sendMessage()));qDebug()<<"server run....."<<endl;
}QtTcpServer::~QtTcpServer()
{delete tcpServer;tcpServer=NULL;delete clientConnect;clientConnect=NULL;
}void QtTcpServer::sendMessage()
{QByteArray block;QDataStream out(&block,QIODevice::WriteOnly);out.setVersion(QDataStream::Qt_4_0);out<<(quint16)0;out<<QString("hello client the connect build!!!");out.device()->seek(0);out<<(quint16)(block.size()-sizeof(quint16));clientConnect=tcpServer->nextPendingConnection();//获取客户端的连接tcpServer->close();//关联套接字的disconnected()和deleteLater(),表明当连接断开时删除该套接字connect(clientConnect,SIGNAL(disconnected()),clientConnect,SLOT(deleteLater()));clientConnect->write(block);connect(clientConnect,SIGNAL(readyRead()),this,SLOT(readMessage()));connect(clientConnect,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(displayError(QAbstractSocket::SocketError)));}void QtTcpServer::readMessage()
{QString message;QDataStream in(clientConnect);in.setVersion(QDataStream::Qt_4_0);if(blockSize==0){if(clientConnect->bytesAvailable()<(int)sizeof(quint16)){return;}in>>blockSize;}if(clientConnect->bytesAvailable()<blockSize){return;}in>>message;qDebug()<<message;}void QtTcpServer::displayError(QAbstractSocket::SocketError)
{switch(clientConnect->error()){case QAbstractSocket::RemoteHostClosedError:clientConnect->disconnectFromHost(); //disconnectFromHost函数会一直等待套接字将所有数据发送完毕，然后关闭该套接字，并发射disconnected信号qDebug()<<"server connect close"<<endl;break;default:qDebug()<<"error id: "<<clientConnect->error()<<endl;qDebug()<<"error message: "<<clientConnect->errorString()<<endl;clientConnect->disconnectFromHost();qDebug()<<"server connect close"<<endl;break;}
}#include <QCoreApplication>
#include "qttcpserver.h"int main(int argc, char *argv[])
{QCoreApplication a(argc, argv);QtTcpServer tcpserver_t;return a.exec();
}

运行结果：

基于TCP的文件传输程序：