QT TCP下的socket编程

TripPlanner::TripPlanner(QWidget*parent)
:QDialog(parent)
{
setupUi(this);
QDateTimedateTime=QDateTime::currentDateTime();
dateEdit->setDate(dateTime.date());
timeEdit->setTime(QTime(dateTime.time().hour(),0));
progressBar->hide();
progressBar->setSizePolicy(QSizePolicy::Preferred,
QSizePolicy::Ignored);
tableWidget->verticalHeader()->hide();
tableWidget->setEditTriggers(QAbstractItemView::NoEditTriggers);
connect(searchButton,SIGNAL(clicked()),
this,SLOT(connectToServer()));
connect(stopButton,SIGNAL(clicked()),this,SLOT(stopSearch()));
connect(&tcpSocket,SIGNAL(connected()),this,SLOT(sendRequest()));
connect(&tcpSocket,SIGNAL(disconnected()),
this,SLOT(connectionClosedByServer()));
connect(&tcpSocket,SIGNAL(readyRead()),
this,SLOT(updateTableWidget()));
connect(&tcpSocket,SIGNAL(error(QAbstractSocket::SocketError)),
this,SLOT(error()));
}

voidTripPlanner::connectToServer()
{
tcpSocket.connectToHost("tripserver.zugbahn.de",6178);
tableWidget->setRowCount(0);
searchButton->setEnabled(false);
stopButton->setEnabled(true);
statusLabel->setText(tr("Connectingtoserver..."));
progressBar->show();
nextBlockSize=0;
}
当用户点击searchButton时，connectToServer（）槽将被执行。它使用tcpSocket.connectToHost建立到

服务器的连接。connectToServer（）槽立即返回。连接的动作实际发生在这之后。当连接建立成功，

QTcpSocket触发connected()信号。如果失败，error（）信号被触发。

接着我们设置进度条以及按钮的状态。

把nextBlockSize设置为0.表示我们现在并不知道下一个接收的数据块的大小。

voidTripPlanner::sendRequest()
{
QByteArrayblock;
QDataStreamout(&block,QIODevice::WriteOnly);
out.setVersion(QDataStream::Qt_4_1);
out<<quint16(0)<<quint8('S')<<fromComboBox->currentText()
<<toComboBox->currentText()<<dateEdit->date()
<<timeEdit->time();
if(departureRadioButton->isChecked()){
out<<quint8('D');
}else{
out<<quint8('A');
}
out.device()->seek(0);
out<<quint16(block.size()-sizeof(quint16));
tcpSocket.write(block);
statusLabel->setText(tr("Sendingrequest..."));
}
当connected()信号被触发，sendRequest()
槽被调用。sendRequest()相爱难过服务器发送一个请求（tcpSocket.write(block)）。

我们需要在数据块的第一个字段写入数据块的大小。但是当我们些第一个字段时，我们不知道整个数据块的大小，

所以我们现写入0（out<<quint16(0)）.最后，当数据块填充完毕时，我们计算数据块的大小，将指针重新

移动到QDataStream的开头（out.device()->seek(0)），重新写入数据块的大小out<<quint16(block.size()-sizeof(quint16))。

最后，我们发送数据tcpSocket.write(block)。

voidTripPlanner::updateTableWidget()
{
QDataStreamin(&tcpSocket);
in.setVersion(QDataStream::Qt_4_1);
forever{
introw=tableWidget->rowCount();
if(nextBlockSize==0){
if(tcpSocket.bytesAvailable()<sizeof(quint16))
break;
in>>nextBlockSize;
}
if(nextBlockSize==0xFFFF){
closeConnection();
statusLabel->setText(tr("Found%1trip(s)").arg(row));
break;
}
if(tcpSocket.bytesAvailable()<nextBlockSize)
break;
QDatedate;
QTimedepartureTime;
QTimearrivalTime;
quint16duration;
quint8changes;
QStringtrainType;
in>>date>>departureTime>>duration>>changes>>trainType;
arrivalTime=departureTime.addSecs(duration*60);
tableWidget->setRowCount(row+1);
QStringListfields;
fields<<date.toString(Qt::LocalDate)
<<departureTime.toString(tr("hh:mm"))
<<arrivalTime.toString(tr("hh:mm"))
<<tr("%1hr%2min").arg(duration/60)
.arg(duration%60)
<<QString::number(changes)
<<trainType;
for(inti=0;i<fields.count();++i)
tableWidget->setItem(row,i,
newQTableWidgetItem(fields[i]));
nextBlockSize=0;
}
}

当QTcpSocket接收到数据时，readyRead（）信号被触发。updateTableWidget()槽就被调用了。

这里我们用了一个forever循环，这是必须的！因为我们无法保证一次就接到了所有的数据块。可能，我们只接收到数据块的一个部分，也可能是全部。

forever循环是如何工作的呢？如果nextBlockSize是0，表示我们没有独到数据块的大小，我们必须重新读取它。数据块的大小字段必须至少读取sizeof(quint16))字节才能获得，如果读取的数据少于sizeof(quint16))，必须重新读取。

如果数据块大小字段为0xFFFF，表示服务器端数据发送完毕，我们停止接收。

最后我们设置nextBlockSize为0，表示下一个数据块的大小还不知道，我们必须接收。

voidTripPlanner::closeConnection()
{
tcpSocket.close();
searchButton->setEnabled(true);
stopButton->setEnabled(false);
progressBar->hide();
}
当接收到的数据块大小字段的值为0xFFFF，我们关闭连接。

voidTripPlanner::connectionClosedByServer()
{
if(nextBlockSize!=0xFFFF)
statusLabel->setText(tr("Error:Connectionclosedbyserver"));
closeConnection();
}
当服务器断开连接时，如果我们没有读到表示数据传送完毕的0xFFFF，我们发出一个错误。

voidTripPlanner::error()
{
statusLabel->setText(tcpSocket.errorString());
closeConnection();
}
显示错误。

主函数：

intmain(intargc,char*argv[])
{
QApplicationapp(argc,argv);
TripPlannertripPlanner;
tripPlanner.show();
returnapp.exec();
}

接下来，我们看看服务器端的实现。

classTripServer:publicQTcpServer
{
Q_OBJECT
public:
TripServer(QObject*parent=0);
private:
voidincomingConnection(intsocketId);
};
服务器端重新实现incomingConnection方法。当客户端尝试连接到服务器的监听端口时，incomingConnection方法被触发。

voidTripServer::incomingConnection(intsocketId)
{
ClientSocket*socket=newClientSocket(this);
socket->setSocketDescriptor(socketId);
}

classClientSocket:publicQTcpSocket
{
Q_OBJECT
public:
ClientSocket(QObject*parent=0);
privateslots:
voidreadClient();
private:
voidgenerateRandomTrip(constQString&from,constQString&to,
constQDate&date,constQTime&time);
quint16nextBlockSize;
};

voidClientSocket::readClient()
{
QDataStreamin(this);
in.setVersion(QDataStream::Qt_4_1);
if(nextBlockSize==0){
if(bytesAvailable()<sizeof(quint16))
return;
in>>nextBlockSize;
}
if(bytesAvailable()<nextBlockSize)
return;
quint8requestType;
QStringfrom;
QStringto;
QDatedate;
QTimetime;
quint8flag;
in>>requestType;
if(requestType=='S'){
in>>from>>to>>date>>time>>flag;
srand(from.length()*3600+to.length()*60+time.hour());
intnumTrips=rand()%8;
for(inti=0;i<numTrips;++i)
generateRandomTrip(from,to,date,time);
QDataStreamout(this);
out<<quint16(0xFFFF);
}
close();
}

voidClientSocket::generateRandomTrip(constQString&/*from*/,
constQString&/*to*/,constQDate&date,constQTime&time)
{
QByteArrayblock;
QDataStreamout(&block,QIODevice::WriteOnly);
out.setVersion(QDataStream::Qt_4_1);
quint16duration=rand()%200;
out<<quint16(0)<<date<<time<<duration<<quint8(1)
<<QString("InterCity");
out.device()->seek(0);
out<<quint16(block.size()-sizeof(quint16));
write(block);
}

intmain(intargc,char*argv[])
{
QApplicationapp(argc,argv);
TripServerserver;
if(!server.listen(QHostAddress::Any,6178)){
cerr<<"Failedtobindtoport"<<endl;
return1;
}
QPushButtonquitButton(QObject::tr("&Quit"));
quitButton.setWindowTitle(QObject::tr("TripServer"));
QObject::connect(&quitButton,SIGNAL(clicked()),
&app,SLOT(quit()));
quitButton.show();
returnapp.exec();
}