发帖 回复
返回列表
  • 6284阅读
  • 1回复

Qt socket Client & Server 問題2 [复制链接]

 上一主题 下一主题
离线nkc731210
新手上路
 
只看楼主 倒序阅读 楼主  发表于: 2010-03-19
— 本帖被 XChinux 从 General Qt Programming 移动到本区(2011-01-02) —
Dear All:

以下是socket Server 端，但是有一個問題：只能接收一次，收完後就要重新啟動Listen

有甚麼方法可以收完一個檔案後繼續Listen 下次要傳送的檔案，不需要再重新啟動
ServerDialog.cpp
复制代码
  1. #include <QApplication>
  2. #include <QProgressBar>
  3. #include <QVBoxLayout>
  4. #include <QHostAddress>
  5. #include <QLabel>
  6. #include <QAbstractSocket>
  7. #include <QTcpSocket>
  8. #include <QMessageBox>
  9. #include <QFile>
  11. #include <iostream>
  12. using namespace std;
  14. #include "ServerDialog.h"
  16. ServerDialog::ServerDialog(QWidget *parent) : QDialog(parent) {
  17.     label = new QLabel("Received:");
  18.     QVBoxLayout *layout = new QVBoxLayout;
  19.     layout->addWidget(label);
  20.     this->setLayout(layout);
  21.     
  22.     connect(&server, SIGNAL(newConnection()),
  23.             this, SLOT(acceptConnection()));
  24. }
  26. void ServerDialog::setReceivedFileName(QString fileName) {
  27.     file = new QFile(fileName);
  28. }
  30. void ServerDialog::listen(quint16 port) {
  31.     server.listen(QHostAddress::Any, port);
  32. }
  34. void ServerDialog::acceptConnection() {
  35.     if (!file->open(QIODevice::WriteOnly)) {
  36.         cerr << "Unable to write the file" << endl;
  37.         delete file;
  38.         file = 0;
  39.         return;
  40.     }    
  41.     
  42.     clientConnection = server.nextPendingConnection();
  43.     
  44.     connect(clientConnection, SIGNAL(readyRead()),
  45.             this, SLOT(updateProgress()));
  46.     connect(clientConnection, SIGNAL(error(QAbstractSocket::SocketError)),
  47.             this, SLOT(displayError(QAbstractSocket::SocketError)));
  48.     
  49.     server.close();
  50.     
  51.     QApplication::setOverrideCursor(Qt::WaitCursor);
  52. }
  54. void ServerDialog::updateProgress() {
  55.     bytesReceived += (int) clientConnection->bytesAvailable();
  56.     file->write(clientConnection->readAll());
  57.     
  58.     QString txt = "Received %1MB";
  59.     
  60.     label->setText(txt.arg(bytesReceived / (1024 * 1024)));
  61. }
  63. void ServerDialog::displayError(QAbstractSocket::SocketError socketError) {
  64.     file->close();
  65.     
  66.     if (socketError == QTcpSocket::RemoteHostClosedError) {
  67.         QMessageBox::information(this,
  68.                "OK!", "Save file as " + file->fileName());
  69.     }
  70.     else {
  71.         QMessageBox::information(this, "Network error",
  72.            "The following error occurred: " + clientConnection->errorString());
  73.     }
  74.     
  75.     delete file;
  76.     file = 0;
  77.     
  78.     QApplication::restoreOverrideCursor();
  79. }



ServerDialog.h
复制代码
  1. #ifndef SERVERDIALOG_H
  2. #define SERVERDIALOG_H
  4. #include <QDialog>
  5. #include <QTcpServer>
  7. class QLabel;
  8. class QFile;
  9. class QTcpSocket;
  11. class ServerDialog : public QDialog {
  12.    Q_OBJECT
  13.   
  14. public:
  15.     ServerDialog(QWidget *parent = 0);
  16.     void setReceivedFileName(QString fileName);
  17.     void listen(quint16 port);
  18.     
  19. public slots:
  20.     void acceptConnection();
  21.     void updateProgress();
  22.     void displayError(QAbstractSocket::SocketError socketError);
  24. private:
  25.     QLabel *label;
  26.     QTcpServer server;
  27.     QTcpSocket *clientConnection;
  28.     int bytesReceived;
  29.     QFile *file;
  30. };
  32. #endif


main.cpp
复制代码
  1. ServerDialog *server = new ServerDialog;
  2. server->setReceivedFileName("f://received.dat");
  3. server->listen(9393);
  4. server->setWindowTitle("QTcpServer");
  5. server->resize(200, 10);
  6. server->show();
回复
举报
分享到 淘江湖 新浪 QQ微博 QQ空间 开心 人人 豆瓣 网易微博 百度 鲜果 白社会 飞信
离线wangqy
新手上路
只看该作者 1楼 发表于: 2010-03-22
void ServerDialog::acceptConnection() {
    if (!file->open(QIODevice::WriteOnly)) {
        cerr << "Unable to write the file" << endl;
        delete file;
        file = 0;
        return;
    }    
    
    clientConnection = server.nextPendingConnection();
    
    connect(clientConnection, SIGNAL(readyRead()),
            this, SLOT(updateProgress()));
    connect(clientConnection, SIGNAL(error(QAbstractSocket::SocketError)),
            this, SLOT(displayError(QAbstractSocket::SocketError)));
    
   server.close();  //我觉得不应该有这一句。
    
    QApplication::setOverrideCursor(Qt::WaitCursor);
}
回复
举报
发帖 回复
返回列表
快速回复
限100 字节
 
上一个 下一个