0

私は QT/C++ サーバーと Java クライアントを持っています。クライアントはサーバーにファイルを要求し、サーバーはクライアントにストリームを送信します。問題は、TCP 送信 (ローカルホストでも) でいくつかのパケットが失われたことです。時々、クライアントは 288890 の 280705 バイトを受け取ります。

サーバーがあります：

MyTcpServer::MyTcpServer(QObject *parent) :
    QTcpServer(parent)
{
}

void MyTcpServer::startServer(int port)
{
    if(!this->listen(QHostAddress::Any, serverPort))
    {
        qDebug() << "Could not start server";
    }
    else
    {
        qDebug() << "Listening to port " << serverPort << "...";
    }
}

void MyTcpServer::incomingConnection(qintptr socketDescriptor)
{
    SocketThread *thread = new SocketThread(socketDescriptor, this);
    connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));
    thread->start();
}

これは SocketThread です。

SocketThread::SocketThread(qintptr ID, QObject *parent) :
QThread(parent)
{
    this->socketDescriptor = ID;
}

void SocketThread::run()
{
    socket = new QTcpSocket();
    if(!socket->setSocketDescriptor(this->socketDescriptor))
    {
        emit error(socket->error());
        return;
    }
    connect(socket, SIGNAL(readyRead()),    this, SLOT(readyRead()), Qt::DirectConnection);
    connect(socket, SIGNAL(disconnected()), this, SLOT(disconnected()));

    socket->write("Welcome to the Server\r\n"); //SEND AN HELLO MESSAGE
    socket->waitForBytesWritten();
    exec();
}

void SocketThread::readyRead()
{       
    QByteArray socketByteArray = socket->readAll();

    int number = 0;
    QDataStream socketDataStream(socketByteArray);
    socketDataStream >> number; //RECEIVE A NUMBER (I WANT 1)
    if (number == 1)
    {
       QFile file("C:\\temp\\test.txt");
       file.open(QIODevice::ReadWrite);

        socket->write(QString("%1\n").arg(file.size()).toStdString().c_str()); //SEND THE FILESIZE AS STRING
        socket->waitForBytesWritten();
        QByteArray buffer = file.readAll();
        long byteSent = socket->write(buffer); //SEND THE FILE

        socket->flush();
        file.close();
    }
    socket->close();
}

void SocketThread::disconnected()
{
    socket->deleteLater();
    exit(0);
}

そして、これはJAVAクライアントです:

Socket MyClient = null;

boolean connect()
{
  try
  {
    MyClient = new Socket(remoteIP, remotePort);
    MyClient.setSoTimeout(60000);
    if (MyClient != null) {
        inFromServer = new BufferedReader(new InputStreamReader(MyClient.getInputStream()));

        serverWelcomeMessage = inFromServer.readLine(); //RECEIVE THE WELCOME MESSAGE
    }
  }
  catch (IOException e) {
    ...
  }
}

void requestFile()
{
    try {

        FileOutputStream fos = null;

        BufferedOutputStream bos = null;

        DataOutputStream outToServer = new DataOutputStream(MyClient.getOutputStream());

        outToServer.write(encodeIntToByteArray(1)); //SEND THE 1

        outToServer.flush();

        InputStream is = MyClient.getInputStream();

        int remoteFileSize = Integer.parseInt(inFromServer.readLine()); //RECEIVE THE FILESIZE AS STRING

        fos = new FileOutputStream(output);

        bos = new BufferedOutputStream(fos);

        int byteCount = 0;

        int totalByteCount = 0;

        byte[] bytes = new byte[1400];

        while ((byteCount = is.read(bytes)) > 0) {  //RECEIVE THE FILE

            bos.write(bytes, 0, byteCount);

            totalByteCount += byteCount;

        }

        System.out.println("Byte Received "+totalByteCount+" of "+remoteFileSize);

        bos.close();

        fos.close();

        is.close();
    }
catch(...) {

} }

ファイル test.txt は、各行に番号が付いたファイルです。

0
1
2
3
4
...much numbers...
50000

クライアントがファイル全体を受け取る場合もあれば、次のように最初の部分を除いてファイルを受け取る場合もあります。

60
1860
1861
1862
...much numbers...
50000

60 から開始し、1860 にジャンプして 50000 に終了します。

リクエストを 1000 回反復しようとすると、90% の回数でコードが機能し、すべてのデータが転送されます。

誰かが私を理解するのを手伝ってくれますか?

4

1 に答える 1

0

問題は IO ストリームの使用にあります。副作用を正しく理解していないと、別のインスタンスを使用することはできません: inFromServer & is. あなたの正確な問題は java.io.BufferedReader#defaultCharBufferSize です。

接続時にストリームとリーダーを初期化することをお勧めします。そして、クラス全体のどこでもそれらを正確に使用してください。

private Socket socket;
private OutputStream outputStream;
private Writer outputWriter;
private InputStream inputStream;
private Reader inputReader;

public void connect() throws IOException {
    socket = new Socket(..., ...);
    socket.setSoTimeout(60000);
    outputStream = new BufferedOutputStream(socket.getOutputStream()); // Buffered 
    outputWriter = new OutputStreamWriter(outputStream);               // Non-buffered - !important
    inputStream = new BufferedInputStream(socket.getInputStream());    // Buffered
    inputReader = new InputStreamReader(inputStream);                  // Non-buffered - !important
}

また、Java コードには Java 命名規則を使用する方がよいでしょう。

于 2014-11-29T18:11:21.397 に答える