基于QT编写一个网络调试助手

class myserver : public qobject {
q_object
public:
myserver() {
qtcpserver *server = new qtcpserver(this);
connect(server, &qtcpserver::newconnection, this,
&myserver::onnewconnection);
server->listen(qhostaddress::any, 1234);
}
private slots:
void onnewconnection() {
qtcpsocket *clientsocket = server->nextpendingconnection();
connect(clientsocket, &qtcpsocket::readyread, this,
&myserver::onreadyread);
// ...
}
void onreadyread() {
qtcpsocket *clientsocket = qobject_cast<qtcpsocket *>(sender());
// 读取数据
qbytearray data = clientsocket->readall();
// 处理数据
// ...
}
};

class myclient : public qobject {
q_object
public:
myclient() {
qtcpsocket *socket = new qtcpsocket(this);
connect(socket, &qtcpsocket::readyread, this, &myclient::onreadyread);
socket->connecttohost("server_address", 1234);
}
private slots:
void onreadyread() {
qtcpsocket *socket = qobject_cast<qtcpsocket *>(sender());
qbytearray data = socket->readall();
// 处理接收到的数据
// ...
}
};

#include <qtcpserver>
#include <qtcpsocket>
#include <qcoreapplication>
#include <qdebug>
int main(int argc, char *argv[]) {
qcoreapplication a(argc, argv);
qtcpserver server;
// 监听端口
if (!server.listen(qhostaddress::any, 12345)) {
qdebug() << "server could not start";
return -1;
}
qdebug() << "server started!";
// 当有新连接时，执行相应的操作
qobject::connect(&server, &qtcpserver::newconnection, [&]() {
qtcpsocket *client = server.nextpendingconnection();
qobject::connect(client, &qtcpsocket::readyread, [client]() {
qbytearray data = client->readall();
qdebug() << "received data:" << data;
client->write("hello, client!");
});
qobject::connect(client, &qtcpsocket::disconnected, client,
&qtcpsocket::deletelater);
});
return a.exec();
}

#include <qtcpsocket>
#include <qcoreapplication>
#include <qdebug>
class tcpclient : public qobject {
q_object
public:
tcpclient(const qstring &host, quint16 port) {
connect(&socket, &qtcpsocket::connected, this, &tcpclient::onconnected);
connect(&socket, &qtcpsocket::readyread, this, &tcpclient::onreadyread);
socket.connecttohost(host, port);
}
private slots:
void onconnected() {
qdebug() << "connected to server!";
socket.write("hello, server!");
}
void onreadyread() {
qbytearray data = socket.readall();
qdebug() << "server said:" << data;
socket.disconnectfromhost();
}
private:
qtcpsocket socket;
};
int main(int argc, char *argv[]) {
qcoreapplication a(argc, argv);
tcpclient client("localhost", 12345);
return a.exec();
}
#include "main.moc"

// 包含主窗口和用户界面定义
#include "mainwindow.h"
#include "ui_mainwindow.h"
// 主窗口构造函数
mainwindow::mainwindow(qwidget *parent)
: qmainwindow(parent)
, ui(new ui::mainwindow)
{
// 初始化用户界面
ui->setupui(this);
// 设置主窗口中心部件的布局
ui->centralwidget->setlayout(ui->verticallayout_2);
// 设置主窗口标题
this->setwindowtitle("网络调试助手服务端-上官qt案例");
cursor = ui->textbrowserrev->textcursor(); // 获取文本浏览器的文本光标
// 初始时禁用“停止监听”按钮
ui->pushbuttonlistenstop->setenabled(false);
// 创建新的 tcp 服务器实例
tcpserver = new qtcpserver(this);
// 将新连接信号连接到处理新连接的槽函数
connect(tcpserver, signal(newconnection()), this,
slot(mnewconnectionhandler()));
// 获取系统上所有网络接口，并将 ipv4 地址添加到下拉列表中
qlist<qnetworkinterface> interfaces = qnetworkinterface::allinterfaces();
for (const qnetworkinterface &interface : interfaces) {
for (const qnetworkaddressentry &entry : interface.addressentries()) {
if (entry.ip().protocol() == qabstractsocket::ipv4protocol) {
ui->comboboxipaddr->additem(entry.ip().tostring());
}
}
}
}
// 主窗口析构函数
mainwindow::~mainwindow()
{
// 释放用户界面资源
delete ui;
}
// “开始监听”按钮的点击事件处理函数
void mainwindow::on_pushbuttonlisten_clicked()
{
// 侦听指定 ip 地址和端口
tcpserver->listen(qhostaddress(ui->comboboxipaddr->currenttext()),
ui->lineeditport->text().toint());
// 更新按钮状态
ui->pushbuttonlisten->setenabled(false);
ui->pushbuttonlistenstop->setenabled(true);
}
// 新 tcp 连接的处理函数
void mainwindow::mnewconnectionhandler()
{
// 获取下一个待处理的连接
qtcpsocket *tmpsocket = tcpserver->nextpendingconnection();
// 向文本浏览器中添加客户端信息
ui->textbrowserrev->append("服务器: 客户端ip地址是："+ tmpsocket-
>peeraddress().tostring()
+" 客户端端口号是： "+qstring::number(tmpsocket-
>peerport())+"\n");
// 连接套接字的状态变化和数据接收信号到相应槽函数
connect(tmpsocket, signal(statechanged(qabstractsocket::socketstate)),
this, slot(mstatechanged(qabstractsocket::socketstate)));
connect(tmpsocket, signal(readyread()), this, slot(mreaddata()));
}
// 套接字状态改变时的槽函数
void mainwindow::mstatechanged(qabstractsocket::socketstate state)
{
// 获取发送信号的套接字对象
qtcpsocket *tmp = (qtcpsocket *)sender();
// 根据套接字的不同状态进行不同处理
switch(state){
case qabstractsocket::unconnectedstate:
// 客户端断开连接
ui->textbrowserrev->append("服务器：有客户端断开连接！");
tmp->deletelater();
break;
case qabstractsocket::connectedstate:
// 客户端连接
ui->textbrowserrev->append("服务器：有新客户端接入！");
break;
default:
break;
}
}
// “停止监听”按钮的点击事件处理函数
void mainwindow::on_pushbuttonlistenstop_clicked()
{
// 更新按钮状态
ui->pushbuttonlisten->setenabled(true);
ui->pushbuttonlistenstop->setenabled(true);
// 停止监听端口
tcpserver->close();
}
// 接收到数据时的槽函数
void mainwindow::mreaddata()
{
// 获取发送信号的套接字对象
qtcpsocket *tmp = (qtcpsocket *)sender();
settextcolor(0,0,0); // 设置文本颜色为红色
cursor.inserttext("客户端："+ tmp->readall()+"\n");
}
// “发送”按钮的点击事件处理函数
void mainwindow::on_pushbuttonsend_clicked()
{
// 查找所有的子 qtcpsocket 对象
qlist<qtcpsocket*> socketlist = tcpserver->findchildren<qtcpsocket*>();
// 向每个连接的客户端发送数据
foreach(qtcpsocket *tmp, socketlist){
tmp->write(ui->texteditsnd->toplaintext().toutf8());
settextcolor(255,0,0); // 设置文本颜色为红色
cursor.inserttext("服务端："+ui->texteditsnd-
>toplaintext().toutf8()+"\n");
};
}
// 设置文本颜色的函数
void mainwindow::settextcolor(int r, int g, int b)
{
qtextcharformat textformat;
textformat.setforeground(qbrush(qcolor(r, g, b))); // 根据提供的 rgb 值设置颜色
// 应用格式到光标
cursor.setcharformat(textformat);
}