linuxsocket无法断开

c++

Linux环境中使用socket进行UDP和TCP多线程通信无法关闭socket

（^v^）

原创

关注

0点赞·641人阅读

在Linux下，使用QT编程网络通信，为提高通信效率，使用原始socket进行网络编程，在QT线程中经常出现线程无法退出，原因来源于socket无法关闭。

线程处理如下：

void communicationClass::run()

{

// 开启数据处理线程

#ifdef Q_OS_LINUX

//配置服务器信息

bzero(&m_sServer_addr, sizeof(m_sServer_addr))

m_sServer_addr.sin_family = AF_INET

//设置为IPV4通信

m_sServer_addr.sin_addr.s_addr = htonl(INADDR_ANY)

//设置目的ip

m_sServer_addr.sin_addr.s_addr = inet_addr(m_strSendIP.toStdString().c_str())

//设置目的端口去链接服务器

m_sServer_addr.sin_port = htons(m_ui16Port)

//配置本地信息

bzero(&m_sLocal_addr, sizeof(m_sLocal_addr))

m_sLocal_addr.sin_family = AF_INET

//设置为IPV4通信

//loc_addr.sin_addr.s_addr = htonl(INADDR_ANY)

//设置目的ip

m_sLocal_addr.sin_addr.s_addr = htonl(INADDR_ANY)

//设置本地端口去链接服务器

m_sLocal_addr.sin_port = htons(m_ui16Port)

m_iSockedFd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP) //设置UDP报文传输0表示默认SOCK_DGRAM 默认使用UDP

//其中第三位 0 是调用方式标志位，设置socket通方式，比如非阻塞

if(m_iSockedFd<0)

{

emit signal_networkInfoError(false, "socket create failure")

return

}

//将本地配置使用bind绑定

int ret = bind(m_iSockedFd,(struct sockaddr*)&m_sLocal_addr,sizeof (m_sLocal_addr))

if(ret <0)

{

emit signal_networkInfoError(false, "socket bind failure")

return

}

emit signal_networkInfoError(true, "network success")

// 线程循环等待数据

while (!isInterruptionRequested())

{

char buf[1600]

int count = 0

socklen_t i_server_addr_len = sizeof(m_sServer_addr)

count = recvfrom(m_iSockedFd, buf, sizeof(buf), 0, (struct sockaddr*)&m_sServer_addr,&i_server_addr_len)

if (count >0)

{

// 组装返回数据buffer

QByteArray arrayRecvData

arrayRecvData.resize(count)

memcpy(arrayRecvData.data(), buf, count)

// qDebug() <<"接收到数据:" <<arrayRecvData.size()

emit signal_recvNetworkData(arrayRecvData)

}

msleep(1)

}

#endif

#ifdef Q_OS_WIN32

// 确定版本信息

WSADATA wsaData

WSAStartup(MAKEWORD(2, 2), &wsaData)

if (LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2)

{

emit signal_networkInfoError(false, "Version failure")

return

}

// 创建socket

m_socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)

if (INVALID_SOCKET == m_socket)

{

emit signal_networkInfoError(false, "socket create failure")

return

}

// 初始化本地地址信息

//地址族

m_sLocal_addr.sin_family = AF_INET

//端口

m_sLocal_addr.sin_port = htons(m_ui16Port)

//IP

m_sLocal_addr.sin_addr.s_addr = htonl(INADDR_ANY)

// 初始化服务器地址信息

//地址族

m_sServer_addr.sin_family = AF_INET

//端口

m_sServer_addr.sin_port = htons(m_ui16Port)

//IP

m_sServer_addr.sin_addr.s_addr = inet_addr(m_strSendIP.toStdString().c_str())

int ret = bind(m_socket, (sockaddr*)&m_sLocal_addr, sizeof(m_sLocal_addr))

if (ret <0)

{

emit signal_networkInfoError(false, "socket bind failure")

return

}

emit signal_networkInfoError(true, "network success")

// 线程循环等待数据

while (!isInterruptionRequested())

{

char buf[1600]

// memset(buf,0,1600*sizeof(char))

int count = 0

count = recv(m_socket, buf, sizeof(buf), 0)

if (count >0)

{

// 组装返回数据buffer

QByteArray arrayRecvData

arrayRecvData.resize(count)

memcpy(arrayRecvData.data(), buf, count)

emit signal_recvNetworkData(arrayRecvData)

}

}

#endif

qDebug() <<"communicationClass quit"

}

复制

退出线程：

#ifdef Q_OS_LINUX

close(m_iSockedFd)

#endif

#ifdef Q_OS_WIN32

closesocket(m_socket)

WSACleanup()

#endif

requestInterruption()

复制

在windows下线程能优雅退出。

但在Linux中会出现close（）关闭socket失败。

解决方法：

#include<sys/socket.h>

int shutdown(int sockfd,int how)

TCP连接是双向的(是可读写的),当我们使用close时,会把读写通道都关闭,有时侯我们希望只关闭一个方向,这个时候我们能够使用shutdown.

how的方式有三种分别是

SHUT_RD（0）：关闭sockfd上的读功能，此选项将不允许sockfd进行读 *** 作。

SHUT_WR（1）：关闭sockfd的写功能，此选项将不允许sockfd进行写 *** 作。

SHUT_RDWR（2）：关闭sockfd的读写功能。

成功则返回0，错误返回-1，错误码errno：EBADF表示sockfd不是一个有效描述符；ENOTCONN表示sockfd未连接；ENOTSOCK表示sockfd是一个文件描述符而不是socket描述符。

Qt的事件是windows的底层消息封装而成的。这个消息和MFC里的消息是同一概念，都是指键盘、鼠标等的按压、松开等消息。例如按下键盘后，windows系统会发出一个 WM_KEYDOWN的消息，Qt捕获这个消息后，将其转换成 Qt::Key_Down 事件。

Qt的事件是较为底层的概念。先有事件，然后才有信号。即：消息 ->事件 ->信号

总结：windows发出消息，Qt捕获消息后转换成事件，再由事件处理后发出信号。

一般来说，如果仅仅是使用Qt的控件，那么只需关心这个控件能发出什么信号，但如果需要深一层的定制控件，则需要关心事件，并重写事件处理函数。

QThread中run()的默认实现调用了exec()，从而创建一个QEventLoop对象，由QEventLoop对象处理线程中事件队列（每一个线程都有一个属于自己的事件队列）中的事件。exec()在其内部不断做着循环遍历事件队列的工作，调用QThread的quit()或exit()方法使退出线程，尽量不要使用terminate()退出线程，terminate()退出线程过于粗暴，造成资源不能释放，甚至互斥锁还处于加锁状态。

线程中的事件循环，使得线程可以使用那些需要事件循环的非GUI 类(如，QTimer,QTcpSocket,QProcess)。

在QApplication前创建的对象，QObject::thread()返回NULL,意味着主线程仅为这些对象处理投递事件，不会为没有所属线程的对象处理另外的事件。可以用QObject::moveToThread()来改变对象及其子对象的线程亲缘关系，假如对象有父亲，不能移动这种关系。在另一个线程(而不是创建它的线程)中delete QObject对象是不安全的。除非可以保证在同一时刻对象不在处理事件。可以用QObject::deleteLater(),它会投递一个DeferredDelete事件，这会被对象线程的事件循环最终选取到。假如没有事件循环运行，事件不会分发给对象。假如在一个线程中创建了一个QTimer对象，但从没有调用过exec(),那么QTimer就不会发射它的timeout()信号，deleteLater()也不会工作。可以手工使用线程安全的函数QCoreApplication::postEvent()，在任何时候，给任何线程中的任何对象投递一个事件，事件会在那个创建了对象的线程中通过事件循环派发。事件过滤器在所有线程中也被支持，不过它限定被监视对象与监视对象生存在同一线程中。QCoreApplication::sendEvent(不是postEvent()),仅用于在调用此函数的线程中向目标对象投递事件。

所有界面组件的创建只能在GUI线程（主线程）中完成。子线程与界面组件的通信有两种方式：

A、信号槽方式

B、发送自定事件方式

https://blog.51cto.com/9291927/1879757

https://blog.51cto.com/9291927/1868744

直观的看，因为在主线程里面运行的app->exec()，所以这样次线程里面的ui无法接受到系统事件。

对Qt而言，一个进程里和窗口系统(譬如Win32的GDI, linux下的X11)UI事件关联的只有主UI线程，而并没有设计成多线程和系统窗口系统同时交互（复杂性，安全性，性能等原因），这应该是根源。

---