当前位置:我的异常网» 网络通信 » UDP组播，完成端口，双网卡收不到数据？帮帮忙

UDP组播，完成端口，双网卡收不到数据？帮帮忙

www.myexceptions.net  网友分享于：2013-04-13  浏览：848次

UDP组播，完成端口，双网卡收不到数据？各位大哥，帮帮忙？

各位大哥：

小弟我写了一个网络通信程序，通过完成端口在指定的网卡上接收网络上传输过来的语音数据，现在情况是：

1：各主机均配置了两张网卡，其中一张网卡由该程序使用，另一张网卡其他程序在用；

2：程序在大部分客户端上运行都正常，唯独在其中一个客户端上GetQueuedCompletionStatus该函数不返回，若该客户端把另一张网卡的网线拔掉，或者禁用掉该网卡，启动软件工作正常。在工作过程中插上另一张网卡的网线也没有问题。但是如果在程序启动前两张网卡都在工作，则GetQueuedCompletionStatus不返回。

主要代码如下：

调用Create函数的代码：

m_Receive.Create(uLocalPort,lpDstStr,0, lpBindAddr)

uLocalPort：组播端口

lpDstStr：组播地址

lpBindAddr：本机上要绑定的网卡地址

bool CUdpSocket::Create(USHORT uLocalPort,LPCTSTR lpDstAddr,USHORT uDstPort,LPCTSTR lpBindAddr/*=NULL*/)

{

if ( htons(uLocalPort) == m_stLclAddr.sin_port

&& m_stDstAddr.sin_addr.s_addr == inet_addr(lpDstAddr)

&& m_stDstAddr.sin_port == htons(uDstPort))

{

return true ;

}

//*/

if (!CreateSocket(uLocalPort,lpBindAddr))

return false ;

/* Assign our destination address */

m_stDstAddr.sin_family = AF_INET;

m_stDstAddr.sin_addr.s_addr = inet_addr(lpDstAddr);

m_stDstAddr.sin_port = htons(uDstPort);

//广播

if(strstr(lpDstAddr,"255"))

{

BOOL bEnable = TRUE ;

int nRes = setsockopt(m_socket,SOL_SOCKET,SO_BROADCAST,(const char*)&bEnable,sizeof(bEnable));

}

//

else

{

// note the 2 says how many concurrent cpu bound threads to allow thru

// this should be tunable based on the requests. CPU bound requests will

// really really honor this.

//

JoinMultiCastGroup(lpDstAddr,uDstPort);

}

//* Disable loopback */

//*/

BOOL fFlag = FALSE;

int nRet = setsockopt(m_socket,

IPPROTO_IP,

IP_MULTICAST_LOOP,

(char *)&fFlag,

sizeof(fFlag));

if (nRet == SOCKET_ERROR) {

printf ("setsockopt() IP_MULTICAST_LOOP failed, Err: %d\n",

WSAGetLastError());

return false ;

}

//*/

//

return CreateCompleteIO();

}

bool CUdpSocket::JoinMultiCastGroup(LPCTSTR lpDstAddr, USHORT uDstPort)

{

/* Assign our destination address */

m_stDstAddr.sin_family = AF_INET;

m_stDstAddr.sin_addr.s_addr = inet_addr(lpDstAddr);

m_stDstAddr.sin_port = htons(uDstPort);

struct ip_mreq stMreq; /* Multicast interface structure */

/* Join the multicast group

*

* NOTE: According to RFC 1112, a sender does not need to join the

* group, however Microsoft requires a socket to join a group in

* order to use setsockopt() IP_MULTICAST_TTL (or fails with error

* WSAEINVAL).

*/

stMreq.imr_multiaddr.s_addr = inet_addr(lpDstAddr);

stMreq.imr_interface.s_addr = INADDR_ANY;

int nRet = setsockopt(m_socket,

IPPROTO_IP,

IP_ADD_MEMBERSHIP,

(char *)&stMreq,

sizeof(stMreq));

if (nRet == SOCKET_ERROR) {

printf (

"setsockopt() IP_ADD_MEMBERSHIP address %s failed, Err: %d\n",

lpDstAddr, WSAGetLastError());

return false ;

}

/* Set IP TTL to traverse up to multiple routers */

//*

u_long lTTL = 2 ;

nRet = setsockopt(m_socket,

IPPROTO_IP,

IP_MULTICAST_TTL,

(char *)&lTTL,

sizeof(lTTL));

if (nRet == SOCKET_ERROR) {

printf ("setsockopt() IP_MULTICAST_TTL failed, Err: %d\n",

WSAGetLastError());

}

//*/

return true ;

}

//

bool CUdpSocket::CreateCompleteIO()

{

m_hCompletionPort = CreateIoCompletionPort (INVALID_HANDLE_VALUE,NULL,0,1);

if (!m_hCompletionPort)

{

printf ("m_hCompletionPort Create Failed\n");

return false;

}

//Associate this socket to this I/O completion port

文章评论