【无标题】

🕗 发布于 2024-07-23 16:34 命令模式

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include<QLocalServer>
#include<QLocalSocket>
#include<QMessageBox>
#include<QDataStream>

QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
Q_OBJECT

public:
Widget(QWidget *parent = nullptr);
~Widget();

private slots:
void on_pushButton_clicked();

private:
Ui::Widget *ui;
QLocalServer *localserver;//服务端
QLocalSocket*localsocket=nullptr;//套接字

};
#endif // WIDGET_H

cpp文件：

#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent)
: QWidget(parent)
, ui(new Ui::Widget)
{
ui->setupUi(this);
setWindowTitle("服务器端");
localserver=new QLocalServer(this);
localserver->listen("Good People");//Good People作为连接字符
connect(localserver,&QLocalServer::newConnection,[=]()
{
localsocket=localserver->nextPendingConnection();//获取连接的套接字
connect(localsocket,&QLocalSocket::readyRead,[=]()//如果有可读数据的话
{
QByteArray block;
block=localsocket->readAll();
QString S=block.data();
ui->textEdit->append(QString("客户端：%1").arg(S));
});

});
}

Widget::~Widget()
{
delete ui;
}

void Widget::on_pushButton_clicked()//发送数据
{
if(ui->lineEdit->text().isEmpty())
{
QMessageBox::information(this,"提示信息","请输入内容",QMessageBox::Ok);
return;
}
ui->textEdit->setText(QString("服务器端：%1").arg(ui->lineEdit->text()));//设置内容
if(localsocket->isValid())
{
QString S=ui->lineEdit->text();
localsocket->write(S.toUtf8());//发送消息
}

}

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include<QLocalSocket>
#include<QMessageBox>
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
Q_OBJECT

public:
Widget(QWidget *parent = nullptr);
~Widget();

private slots:
void on_pushButton_clicked();

void on_pushButton_2_clicked();

private:
Ui::Widget *ui;
QLocalSocket * localsocket;//套接字
};
#endif // WIDGET_H
.cpp文件：

#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent)
: QWidget(parent)
, ui(new Ui::Widget)
{
ui->setupUi(this);
localsocket=new QLocalSocket(this);
setWindowTitle("客户端");
connect(localsocket,&QLocalSocket::readyRead,[=]()
{
QByteArray block;
block=localsocket->readAll();//读取信息
ui->textEdit->append(QString("服务器：%1").arg(block.data()));//聊天框添加信息
});

}

Widget::~Widget()
{
delete ui;
}

void Widget::on_pushButton_clicked()//连接
{
localsocket->abort();//先断开
localsocket->connectToServer("Good People");//连接
}

void Widget::on_pushButton_2_clicked()//发送
{
if(ui->lineEdit->text().isEmpty())
{
QMessageBox::information(this,"提示信息","请输入内容。",QMessageBox::Ok);
return;
}
if(localsocket->isValid())
{
localsocket->write(ui->lineEdit->text().toUtf8());
ui->textEdit->append(QString("客户端：%1").arg(ui->lineEdit->text()));
}

}

例子：写入和读取数据

QSharedMemory memory;创建对象
memory.setKey("1000");//设置标识

//写入数据
if(memory.isAttached())//已经连接的话
{
memory.detach();//断开连接
}
QString Str="SharedMemory";

QBuffer buffer;
buffer.open(QBuffer::ReadWrite);
QDataStream S(&buffer);
S<<Str;//将数据写到缓存中
memory.create(buffer.size());//创建共享内存
memory.lock();//上锁
char * M=(char *)memory.data();//获取memory的指针
const char *N=buffer.data().data();//获取缓存的指针
memcpy(M,N,buffer.size());//把数据复制到共享内存中
memory.unlock();//解锁

//读取数据
memory.attach();//连接共享内存
QBuffer buffer1;
QDataStream in(&buffer);
QString Str1;

memory.lock();//上锁
buffer.setData((char*)memory.constData(),memory.size());//存入数据
buffer.open(QBuffer::ReadOnly);//只读模式
in>>Str1;//读取数据
memory.unlock();//解锁

memory.detach();//断开连接
qDebug()<<Str1;

.h文件：

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include<QSharedMemory>
#include<QBuffer>
#include<QMessageBox>
#include<QDataStream>
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
Q_OBJECT

public:
Widget(QWidget *parent = nullptr);
~Widget();

private slots:
void on_pushButton_clicked();

void on_pushButton_2_clicked();

void on_pushButton_3_clicked();

private:
Ui::Widget *ui;
QSharedMemory sharedmemory;//共享内存
};
#endif // WIDGET_H

main函数：

#include "widget.h"

#include <QApplication>

int main(int argc, char *argv[])
{
QApplication a(argc, argv);
Widget w1;
w1.setWindowTitle("widget1");
w1.show();//进程1
Widget w2;
w2.setWindowTitle("widget2");
w2.show();//进程2
return a.exec();
}
这里解释一下为什么要有断开连接的按钮：

经过多次测试发现：

A端发完数据，B端接收数据后，A端需要主动断开连接后B端才能正常发送数据。

（懂的大佬请在评论区解释一下）

.h文件：

#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include<QProcess>
#include<QMessageBox>
#include<QDebug>
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
Q_OBJECT

public:
Widget(QWidget *parent = nullptr);
~Widget();

private slots:
void on_pushButton_clicked();

void on_pushButton_2_clicked();
private:
Ui::Widget *ui;
QProcess *process;
};
#endif // WIDGET_H

.cpp文件：

#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent)
: QWidget(parent)
, ui(new Ui::Widget)
{
ui->setupUi(this);
setWindowTitle("主进程");
process=new QProcess;
connect(process,&QProcess::readyReadStandardOutput,[=]()//读取信息
{
QString S=process->readAllStandardOutput().data();
ui->textEdit->append(QString("子线程：%1").arg(S));
});

}

Widget::~Widget()
{
delete ui;
}

void Widget::on_pushButton_clicked()//打开子进程
{
//子线程的开启
process->start("D:/Qt_data/build-QProcess_text1-Desktop_Qt_5_9_9_MinGW_32bit-Debug/debug/QProcess_text1.exe");

}

void Widget::on_pushButton_2_clicked()//发送数据
{

if(ui->lineEdit->text().isEmpty())
{
QMessageBox::information(this,"提示信息","输入框不能为空。",QMessageBox::Ok);
return;
}
if(process->Running)
{
QString S=ui->lineEdit->text();//获取lineEdit中的内容
process->write(S.toStdString().c_str());//写入数据
ui->textEdit->append("父线程："+S);//在聊天框显示内容
}
return;

}

.h文件：
#ifndef WIDGET_H
#define WIDGET_H

#include <QWidget>
#include<QFile>
#include<QSocketNotifier>
#include<QBuffer>
#include<QMessageBox>
#include<QFuture>
#include<QtConcurrent>
#include<QIODevice>
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACE

class Widget : public QWidget
{
Q_OBJECT

public:
Widget(QWidget *parent = nullptr);
~Widget();

private slots:
void on_pushButton_clicked();
void readStdin();//读取数据

private:
Ui::Widget *ui;
QFile file;
signals:
void sig_log(QString S);//显示数据
void sig_receivedCommand(QString S);//显示数据
};
#endif // WIDGET_H

.cpp文件：
#include "widget.h"
#include "ui_widget.h"
#include<iostream>
#include<windows.h>
#include<io.h>
#include<fcntl.h>
#include<QSocketNotifier>
Widget::Widget(QWidget *parent)
: QWidget(parent)
, ui(new Ui::Widget)
{
ui->setupUi(this);
setWindowTitle("子进程");

QFuture<void> fu=QtConcurrent::run(this,&Widget::readStdin);//开启一个线程
connect(this,&Widget::sig_receivedCommand,this,[&](QString s)
{
ui->textEdit->append("父线程："+s);
});
connect(this,&Widget::sig_log,this,[=](QString s)
{
ui->textEdit->append("父线程："+s);
});

}

Widget::~Widget()
{
delete ui;
}

void Widget::readStdin()//读取数据
{
bool ok=true;
char chbuf[1024];//缓存
DWORD dwRead;//32位无符号整数
HANDLE hStdinDup;//HANDLE 句柄类型

const HANDLE hStdin=GetStdHandle(STD_INPUT_HANDLE);//GetStdHandle获取标准输入的句柄
if(hStdin==INVALID_HANDLE_VALUE)//为无效句柄的话
return;
DuplicateHandle(GetCurrentProcess(),hStdin,
GetCurrentProcess(),&hStdinDup,0,false,DUPLICATE_SAME_ACCESS);//创建一个新句柄
CloseHandle(hStdin);//关闭旧句柄
while(ok)
{
ok=ReadFile(hStdinDup,chbuf,sizeof(chbuf),&dwRead,NULL);//读取hstdinDup句柄文件中的数据
emit sig_log(QLatin1String("ok is:")+QString::number(ok));
if(ok &&dwRead!=0)
{
emit sig_receivedCommand(QString::fromUtf8(chbuf,dwRead));//读取数据
}
}

}

void Widget::on_pushButton_clicked()//发送数据
{
if(ui->lineEdit->text().isEmpty())
{
QMessageBox::information(this,"提示信息","输入框不能为空。",QMessageBox::Ok);
return;
}
QFile fileout;
if(fileout.open(stdout,QIODevice::WriteOnly))
{
QString S=ui->lineEdit->text();
fileout.write(S.toStdString().c_str());
ui->textEdit->append("子线程："+S);
fileout.close();//关闭文件
}

}

原文地址：https://blog.csdn.net/g200407331/article/details/140541334

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：[git] 拉取远程新分支
下一篇：基于微信小程序+SpringBoot+Vue的青少年科普教学系统平台(带1w+文档)

[CUDA] cuda kernel开发记录
包括kernel的一些使用注意事项， launch_bound, __device__, debug排查技巧
阅读更多2024-11-16
【python】掌握 Flask：轻量级 Web 开发框架解析
路由是 Web 开发的基础，负责管理 URL 到视图函数的映射。在 Flask 中，路由定义非常简单，只需使用装饰器即可。这个代码段定义了一个路由，访问该路径时会返回 “Hello, Flask!通过
阅读更多2024-11-16
AI图片分析接口LiteAIServer摄像机实时接入分析平台未戴安全帽检测算法
随着人工智能技术的飞速发展，摄像机实时接入分析平台LiteAIServer工地未佩戴安全帽检测算法应运而生，为工地安全管理带来了革命性的变革。
阅读更多2024-11-16
2024新版pycharm如何切换anaconda虚拟环境
回归正题，导入项目后点击文件=>设置，找到解释器。不得不说这界面改的真不错，看着很舒服。另外在终端用指令切换也是可以的。添加解释器=>添加本地解释器。
阅读更多2024-11-16
计算机提示mfc140u.dll丢失的五种解决方法，了解mfc140u.dll错误的几种修复方法
当你尝试打开某些程序时，突然出现错误提示，告知你系统缺少 mfc140u.dll 文件，这可能让你感到困惑和无助。mfc140u.dll 是 Microsoft Foundation Class (M
阅读更多2024-11-16
k8s 中传递参数给docker容器
在 Kubernetes 中，可以通过多种方式将参数传递给 Dockerfile 或其运行的容器，常见的方式包括使用环境变量、命令行参数、配置文件等。
阅读更多2024-11-16
设计模式之工厂模式，但是宝可梦
作为一个细分了三个种类的设计模式，到底该如何取舍？比起直接new一个对象，使用对应模式的好处到底在哪？简单工厂模式：根据传入的参数决定产出的对象，可以隐藏一些创建的细节适用于需要根据条件创建不同对象的
阅读更多2024-11-16
【深度学习】wsl-ubuntu深度学习基本配置
这里注意一点，你换了源之后就最好不要开代理了，要不然搞不好下载失败，pip和conda都是。
阅读更多2024-11-16
nodejs和npm在gitbash中提示Not Found情况的解决办法
很多小伙伴学习了node以后，在cmd命令行中可以正常的获取node版本和npm版本，但是我们经常使用gitbash来管理git，这时候下载完gitbash后，在gitbash中输入node -v和n
阅读更多2024-11-16
判断子序列
给定一个长度为 n的整数序列 a1,a2,…,an以及一个长度为 m的整数序列 b1,b2,…,bm。请你判断 a序列是否为 b序列的子序列。子序列指序列的一部分项按原有次序排列而得的序列，例如序列
阅读更多2024-11-16

【无标题】

相关文章