linux socket 求助，总是提示 Connection refused

有时候，写UDP socket程序的时候，在调用sendto或者recvfrom的时候，会发现有Connection refused错误返回，错误码是ECONNREFUSED。对于懂得socket接口但是不很很懂网络的人，可能这根本就不是个问题，他会根据错误码知道远端没有这个服务端口，正如socket api的man手册中描述的那样： ECONNREFUSED A remote host refused to allow the network connection (typically because it is not running the requested service). 有时候无知真的是一种幸福！但是如果你十分精通TCP/IP栈，那么就想不通了，UDP既然无连接，怎么知道远端的情况呢？UDP不正如协议标准描述的那样，发出去就不管了吗？对于接收，没有数据就一直等，如果设置了NOWAIT，则直接返回EAGAIN，表示稍后再试。不管怎么说，也不会有ECONNREFUSED这么详细的信息返回才对啊。 既然UDP不会从对端返回任何错误信息，那么一定有别的什么返回了，总不能凭空猜测啊。这就涉及到了网络协议设计中的数据平面和控制平面了，对于控制平面的消息，可以是带内传输，也可以是带外传输。对于TCP而言，无疑是带内传输的，因为它本身就是有连接的协议，协议本身会处理任何的错误和异常，然而对于UDP而言，因为其设计目的就是保持简单性，故不再附带有任何带内的控制消息逻辑，互联网上为了弥补这一类协议的控制逻辑的缺失，ICMP协议才显得尤为重要！实际上，ICMP，根据名称就可以看出它是一种专门的控制协议，控制和指示IP层发生的事件。 ECONNREFUSED正是ICMP返回的！

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描述符。

---