Simonelinuxsocket无法断开
的有关信息介绍如下：
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;
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;
// 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
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描述符。
