也许这是个愚蠢的问题，实际上它很有吸引力，或者 Qt 对我来说太复杂了。事情是这样的：我在编写客户端-服务器应用程序时习惯于使用java，而且非常简单。我想在 C++ 中做同样的事情（我对 C++ 本身非常熟悉），我选择学习 Qt。我尝试在 qt 中编写一些应用程序，但取得了部分成功。
首先困扰我的是信号和插槽。我知道如何在 GUI 编程中使用它们，但它让我对网络感到困惑。并且存在阻塞问题。当我在 java 中调用 BufferedReader 的 readLine() 方法时，它会阻塞，直到它从套接字连接接收到线路。在 Qt 中，我必须确保每次都有可用的线路，并在没有线路时处理它。
当我将 QSocket 的错误信号连接到我的一些自定义插槽时，当服务器发送最后一行并关闭连接时发出信号，并且在客户端的插槽/函数中读取我从未读过最后一行。这是我目前面临的一些问题。
当我不得不实现最简单的协议时，插槽和检查是否有可用数据让我感到困惑。
重要部分：
我试图在互联网上找到很好的例子，但问题是所有的例子都太复杂了。有没有人可以告诉我如何编写简单的客户端-服务器应用程序。服务器只接受一个客户端。客户端发送包含命令的文本行。如果命令是“ADD”或“SUB”，服务器发送“SUP”表示支持该命令。否则它发送“UNS”并关闭连接。如果客户端收到“SUP”，它会发送到更多包含要减去或添加的数字的行。服务器响应结果并关闭连接。
我知道 C++ 需要更多的编码，但在 Java 中这只需要 5 分钟，所以用 C++ 编写它也不应该花很长时间。
我相信这个例子对于任何想在 Qt 中学习网络的人来说都是非常有价值的。
编辑： 这是我尝试制作应用程序（如上所述）：这是服务器部分：
#ifndef TASK_H
#define TASK_H
#include <QObject>
#include <QTcpServer>
class Task : public QObject
{
Q_OBJECT
public:
Task(QObject *parent = 0) : QObject(parent) {}
public slots:
void run();
void on_newConnection();
void on_error(QAbstractSocket::SocketError);
signals:
void finished();
private:
QTcpServer server;
};
#endif // TASK_H
void Task::run()
{
connect(&server,SIGNAL(newConnection()),this,SLOT(on_newConnection()));
connect(&server,SIGNAL(acceptError(QAbstractSocket::SocketError)),this,SLOT(on_error(QAbstractSocket::SocketError)));
if(server.listen(QHostAddress::LocalHost, 9000)){
qDebug() << "listening";
}else{
qDebug() << "cannot listen";
qDebug() << server.errorString();
}
}
void Task::on_newConnection(){
std::cout << "handeling new connection...\n";
QTcpSocket* socket = server.nextPendingConnection();
QTextStream tstream(socket);
while(!socket->canReadLine()){
socket->waitForReadyRead((-1));
}
QString operation = tstream.readLine();
qDebug() << "dbg:" << operation;
if(operation != "ADD" && operation != "SUB"){
tstream << "UNS\n";
tstream.flush();
socket->disconnect();
return;
}
tstream << "SUP\n";
tstream.flush();
double op1,op2;
while(!socket->canReadLine()){
socket->waitForReadyRead((-1));
}
op1 = socket->readLine().trimmed().toDouble();
qDebug() << "op1:" << op1;
while(!socket->canReadLine()){
socket->waitForReadyRead(-1);
}
op2 = socket->readLine().trimmed().toDouble();
qDebug() << "op2:" << op2;
double r;
if(operation == "ADD"){
r = op1 + op2;
}else{
r = op1 - op2;
}
tstream << r << "\n";
tstream.flush();
qDebug() << "result is: " << r;
socket->disconnect();
}
void Task::on_error(QAbstractSocket::SocketError ){
qDebug() << "server error";
server.close();
}
这是客户端（标题类似于服务器，所以我不会发布它）：
void Task::run()
{
QTcpSocket socket;
std::string temp;
socket.connectToHost(QHostAddress::LocalHost,9000);
if(socket.waitForConnected(-1))
qDebug() << "connected";
else {
qDebug() << "cannot connect";
return;
}
QTextStream tstream(&socket);
QString op;
std::cout << "operation: ";
std::cin >> temp;
op = temp.c_str();
tstream << op << "\n";
tstream.flush();
qDebug() << "dbg:" << op << "\n";
while(!socket.canReadLine()){
socket.waitForReadyRead(-1);
}
QString response = tstream.readLine();
qDebug() << "dbg:" << response;
if(response == "SUP"){
std::cout << "operand 1: ";
std::cin >> temp;
op = temp.c_str();
tstream << op + "\n";
std::cout << "operand 2: ";
std::cin >> temp;
op = temp.c_str();
tstream << op + "\n";
tstream.flush();
while(!socket.canReadLine()){
socket.waitForReadyRead(-1);
}
QString result = tstream.readLine();
std::cout << qPrintable("result is: " + result);
}else if(response == "UNS"){
std::cout << "unsupported operatoion.";
}else{
std::cout << "unknown error.";
}
emit finished();
}
- 我能做的更好吗？
- 在类似情况下有哪些好的做法？
- 当使用阻塞（不是信号/槽机制）时，当对方关闭连接时处理事件的最佳方式是什么？
- 有人可以重写它以使其看起来更专业（我只是想看看它应该是什么样子，因为我认为我的解决方案远非完美）？
- 有人可以使用信号和插槽重写它吗？
谢谢。对不起我的英语，可能是愚蠢:)