9

这个问题类似于https://stackoverflow.com/questions/11650328/using-reliable-multicast-pragmatic-general-multicast-not-returning-from-accept，但我的代码与其略有不同，因此可能会导致在不同的答案中。

我正在尝试获得可靠的多播服务器/客户端概念证明设置。

解决方案本身是一个服务器/客户端连接。客户端通过 TCP/IP 连接到服务器。然后服务器打开一个可靠的多播套接字供客户端监听。客户端通过 TCP 发送消息，服务器通过IPPROTO_RM. 最终目标是让许多客户端连接到服务器，都接收每个回显的消息。

示例代码基于此页面。

我已经类似地设置了我的 RM 插座（见下面的清单）。TCP 套接字工作正常。问题出在 RM 插座上。服务器打开多播套接字，然后binds正确connects地打开多播地址。但是，客户端listens正确，但调用会accept永远阻塞。

客户端和服务器进程都在同一台主机上运行。

我已经检查过，并且主机（Server 2008）上安装了多播支持。

更新：我注意到，如果我先从发送方的套接字向套接字发送一些数据，有时接受会返回。这并不理想，也不可靠。

更新：标志指向开关。似乎一个小枢纽不会削减它。我们发生了一起搞笑的事件，导致整栋楼的通讯丢失。

清单

服务器创建并连接多播发送者

short
   Port = 0;
const char
   *Address = "234.5.6.7";

SOCKET
   RMSocket;

SOCKADDR_IN 
   LocalAddr, 
   SessionAddr;

RMSocket = socket(AF_INET, SOCK_RDM, IPPROTO_RM);


if (RMSocket == INVALID_SOCKET)
   {
   return Failed;
   }

LocalAddr.sin_family = AF_INET;
LocalAddr.sin_port = htons(0);
LocalAddr.sin_addr.s_addr = htonl(INADDR_ANY);

if ( bind( RMSocket, (SOCKADDR*)&LocalAddr, sizeof(LocalAddr)) == SOCKET_ERROR )
   {
   return Failed;
   }

SessionAddr.sin_family = AF_INET;
SessionAddr.sin_port = htons( Port );
SessionAddr.sin_addr.s_addr = inet_addr( Address );

if ( connect( RMSocket, (SOCKADDR*)&SessionAddr, sizeof(SessionAddr)) == SOCKET_ERROR )
   {
   return Failed;
   }

return Success;

客户端创建并接受多播阅读器

short
   Port = 0;
const char
   *Address = "234.5.6.7";

SOCKADDR_IN 
   LocalAddr;
SOCKET
   RMListener,
   RMSocket;


RMListener = socket( AF_INET, SOCK_RDM, IPPROTO_RM );

if ( RMListener == INVALID_SOCKET ) 
   {
   return Failed;
   }


LocalAddr.sin_family = AF_INET;
LocalAddr.sin_port = htons( Port );
LocalAddr.sin_addr.s_addr = inet_addr( Address );


if ( bind( RMListener, (SOCKADDR*)&LocalAddr, sizeof(LocalAddr) ) )
   {
   return Failed;
   }


if ( listen( RMListener, SOMAXCONN ) )
   {
   return Failed;
   }

// BLOCKS HERE
RMSocket = accept( RMListener, NULL, NULL);



if ( RMSocket == INVALID_SOCKET )
   {
   return Failed;
   }

return Success;
4

1 回答 1

1

您是否安装了 MSMQ（微软消息队列）？IPPROTO_RM 需要在基于 Ms 的计算机上工作。此外，它仅适用于 Windows 版本 >= Xp||2003

编辑：我看到你已经检查过了。

于 2013-03-20T09:14:35.467 回答