C++远程监控系统接收端- RevPlayMDIChildWnd.cpp

void CRevPlayWnd::InitMultiSock()
{
    int RevBuf;
    int status;
    BOOL  bFlag;
    CString ErrMsg;
    SOCKADDR_IN stLocalAddr;
    SOCKADDR_IN stDestAddr;
    SOCKET hNewSock;
    int RevLen=sizeof(RevBuf);
    //创建一个IP组播套接字
    MultiSock = WSASocket(AF_INET, SOCK_DGRAM, IPPROTO_UDP,
          (LPWSAPROTOCOL_INFO)NULL, 0,
          WSA_FLAG_MULTIPOINT_C_LEAF | WSA_FLAG_MULTIPOINT_D_LEAF);
    if (MultiSock == INVALID_SOCKET)
    {
        MessageBox("WSASocket() failed");
        return;
    }
    
    //允许对同一地址bind多次
    bFlag = TRUE;
    status = setsockopt(
        MultiSock,                    /* socket */
        SOL_SOCKET,                /* socket level */
        SO_REUSEADDR,            /* socket option */
        (char *)&bFlag,            /* option value */
         sizeof (bFlag));    /* size of value */

    if (status == SOCKET_ERROR)
    {
      ErrMsg.Format ("set SO_REUSEADDR failed, Err: %d",WSAGetLastError());
      MessageBox(ErrMsg);
      return;
    }
    // 将套接字绑定到用户指定端口
    stLocalAddr.sin_family = AF_INET;
  //  stLocalAddr.sin_port = htons (DestPort);
    stLocalAddr.sin_port = htons (201);
    stLocalAddr.sin_addr.s_addr = INADDR_ANY;
    status = bind (
        MultiSock,
        (struct sockaddr FAR *)&stLocalAddr,
        sizeof(struct sockaddr));

    if (status == SOCKET_ERROR)
    {
        ErrMsg.Format ("Bind(socket: %d, port: %d) failed, Err: %d",
            MultiSock, DestPort, WSAGetLastError());
        MessageBox(ErrMsg);
            
    }
    //设定接收缓冲区为64k
     RevBuf=65536;
    status = setsockopt(
        MultiSock,                    /* socket */
        SOL_SOCKET,                /* socket level */
        SO_RCVBUF,            /* socket option */
        (char *)&RevBuf,            /* option value */
        sizeof(RevBuf));    /* size of value */
    if (status == SOCKET_ERROR)
    {
        MessageBox("set SO_REVBUF error");
        return;
    }
    
    //加入组播组
    stDestAddr.sin_family = PF_INET;
    stDestAddr.sin_port = htons (201);
    stDestAddr.sin_addr.s_addr = inet_addr("234.5.6.7");
    hNewSock = WSAJoinLeaf (MultiSock, /* socket */
        (PSOCKADDR)&stDestAddr, /* multicast address */
        sizeof (stDestAddr),    /* length of addr struct */    
        NULL,                   /* caller data buffer */
        NULL,                   /* callee data buffer */
        NULL,                   /* socket QOS setting */
        NULL,                   /* socket group QOS */
        JL_RECEIVER_ONLY);               /* do both: send *and* receive */

    if (hNewSock == INVALID_SOCKET)
    {
      ErrMsg.Format ("WSAJoinLeaf() failed, Err: %d",WSAGetLastError());
      MessageBox(ErrMsg);
    }     
}