Qt下使用fork创建进程并使用socket通信

把最近工作总结下。

之前在嵌入python解释器的过程中，我们没有处理这样一种情况：当Python解释器正在执行一个阻塞操作(比如socket server 在监听一个客户端连入)，这时我们需要终止解释器的运行，该如何操作呢？

在Qt线程中不容易实现该功能，如果在socket 监听时终止python解释器，那么再次运行时端口就会显示被占用，因为资源没有清理。为了解决这种情况，我们让解释器运行在一个进程中。这样在需要停止时，我们可以发送kill信号终止进程。

老规矩，接下来上码：

#include "mainwindow.h"

#include "ui_mainwindow.h"

#include <QThread>

#include <QDebug>

#include <signal.h>

#include <sys/types.h>

#include <unistd.h> //close head file

#include <sys/wait.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <arpa/inet.h>

int childProcessId = -1;

int client_sockfd;

void sigint(int);

void sigint(int signal)

{

if(SIGINT == signal)

{

qDebug() << "My DADDY has Killed me!!!";

exit(0);

}

}

MainWindow::MainWindow(QWidget *parent) :

QMainWindow(parent),

ui(new Ui::MainWindow)

{

ui->setupUi(this);

//tcp server

processServer = new QTcpServer();

connect(processServer, SIGNAL(newConnection()),

this, SLOT(slot_recvClientConnect()));

if(!processServer->listen(QHostAddress::Any, 8866))

{

//监听本地主机的8866端口，如果出错就输出错误信息，并关闭

qDebug() <<"error message"<<processServer->errorString();

processServer->close();

}

///////////////client

struct sockaddr_in remote_addr; //服务器端网络地址结构体

memset(&remote_addr,0,sizeof(remote_addr)); //数据初始化--清零

remote_addr.sin_family=AF_INET; //设置为IP通信

remote_addr.sin_addr.s_addr=inet_addr("127.0.0.1");//服务器IP地址

remote_addr.sin_port=htons(8866); //服务器端口号

/*创建客户端套接字--IPv4协议，面向连接通信，TCP协议*/

if((client_sockfd=socket(PF_INET,SOCK_STREAM,0))<0)

{

perror("socket");

return;

}

/*将套接字绑定到服务器的网络地址上*/

if(::connect(client_sockfd,(struct sockaddr *)&remote_addr,sizeof(struct sockaddr))<0)

{

perror("connect");

return;

}

}

MainWindow::~MainWindow()

{

processServer->close();

delete ui;

delete processServer;

}

void MainWindow::slot_recvClientConnect()

{

qDebug() << "accept connect";

clientConnect = processServer->nextPendingConnection();

connect(clientConnect, SIGNAL(readyRead()),

this, SLOT(slot_readClientData()));

}

void MainWindow::slot_readClientData()

{

QString str;

str = clientConnect->readAll();

clientConnect->write("hello");

qDebug() << "client data>>:" << str ;

}

void MainWindow::on_pbn_start_clicked()

{

pid_t pid;

pid = fork();

if(pid < 0)

{

qDebug() << "creat process faild!";

}

else if((pid_t)0 == pid) //child process,pid is child pid

{

signal(SIGINT, sigint);

qDebug() << "this is client proccess!";

char buf1[] = "socket client";

while(1)

{

send(client_sockfd,buf1,strlen(buf1),0);

QThread::sleep(3);

}

}

else // parent process

{

childProcessId = pid;

qDebug() << "child process pid is " << childProcessId;

}

}

void MainWindow::on_pbn_stop_clicked()

{

if(-1 != childProcessId)

{

pid_t pidClear;

kill(childProcessId, SIGINT);

QThread::usleep(500);

do{

pidClear = waitpid(childProcessId,NULL,WNOHANG);

if(-1 == pidClear)

{

qDebug() << "clear error!!!";

}

if(childProcessId == pidClear)

{

qDebug() << "clear success!!!";

}

QThread::usleep(500);

}while(0 == pidClear);

childProcessId = -1;

}

}

程序环境是ubuntu + Qt。

简单介绍下程序的主体构成：构造函数中使用c创建客户端，使用Qt的类创建服务器。

界面点击start按钮时，使用fork创建子进程，在进程中客户端向服务器发送数据。点击stop按钮时，父进程向子进程发出kill信号，由于子进程注册了中断信号，所以会执行信号函数中的操作。之后父进程使用 waitpid(childProcessId,NULL,WNOHANG)等待清理子进程，之后进程资源被释放。如果python解释器运行在进程中，那么python解释器也会被中断，资源被清理故而不会被占用。Python重定向信息输出也可通过socket发送出来。

程序运行效果：

在子进程被中断前，先进入信号函数。之后由父进程清理子进程资源。