vc++实现组播传输（2）

港控/mmm° 2022-02-13 04:13 273阅读 0赞

本文将客户端和服务端分开写成两个部分。

#### 1. 客户端 ####

#include <stdio.h> 
    #include <winsock2.h> 
    #include <ws2tcpip.h> 
    #pragma comment(lib, "ws2_32.lib")
    
    int test3()
    { 
    	int iRet = 0;
    	WSADATA wsaData;
    	WSAStartup(MAKEWORD(2, 2), &wsaData);
    
    	SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0);
    
    	int iFlag = 0;	// 0-Í¬Ò»Ì¨Ö÷»ú 1-¿äÖ÷»ú
    	iRet = setsockopt(sock, IPPROTO_IP, IP_MULTICAST_TTL, (char*)&iFlag, sizeof(iFlag));
    	if (iRet != 0) { 
    		printf("setsockopt fail:%d", WSAGetLastError());
    		return -1;
    	}
    
    	sockaddr_in addr;
    	addr.sin_addr.S_un.S_addr = inet_addr("234.2.2.2");
    	addr.sin_family = AF_INET;
    	addr.sin_port = htons(9411);
    
    	char strSend[1024] = {  0 };
    	static int iIdx = 0;
    	while (1)
    	{ 
    		sprintf_s(strSend, "udp send group data:%d", iIdx++);
    		iRet = sendto(sock, strSend, strlen(strSend) + 1, 0, (sockaddr*)&addr, sizeof(sockaddr));
    		if (iRet <= 0) { 
    			printf("send fail:%d", WSAGetLastError());
    		}
    		else { 
    			printf("send data:%s\n", strSend);
    		}
    		Sleep(500);
    	}
    
    	closesocket(sock);
    	WSACleanup();
    
    	return 0;
    }

#### 2. 服务端 ####

#include <stdio.h> 
    #include <winsock2.h> 
    #include <ws2tcpip.h> 
    #pragma comment(lib, "ws2_32.lib")
    
    int test3()
    { 
    	int iRet = 0;
    	WSADATA wsaData;
    	WSAStartup(MAKEWORD(2, 2), &wsaData);
    
    	SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0);
    
    	sockaddr_in addr;
    	addr.sin_family = AF_INET;
    	//addr.sin_addr.S_un.S_addr = INADDR_ANY;
    	addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
    	addr.sin_port = htons(9411);
    
    	bool bOptval = true;
    	iRet = setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char*)&bOptval, sizeof(bOptval));
    	if (iRet != 0) { 
    		printf("setsockopt fail:%d", WSAGetLastError());
    		return -1;
    	}
    
    	iRet = bind(sock, (sockaddr*)&addr, sizeof(addr));
    	if (iRet != 0) { 
    		printf("bind fail:%d", WSAGetLastError());
    		return -1;
    	}
    	printf("socket:%d bind success\n", sock);
    
    	// ¼ÓÈë×é²¥ 
    	ip_mreq multiCast;
    	//multiCast.imr_interface.S_un.S_addr = INADDR_ANY;
    	multiCast.imr_interface.S_un.S_addr = inet_addr("127.0.0.1");
    	multiCast.imr_multiaddr.S_un.S_addr = inet_addr("234.2.2.2");
    	iRet = setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char*)&multiCast, sizeof(multiCast));
    	if (iRet != 0) { 
    		printf("setsockopt fail:%d", WSAGetLastError());
    		return -1;
    	}
    
    	printf("udp group start\n");
    
    	int len = sizeof(sockaddr);
    	char strRecv[1024] = {  0 };
    	while (true)
    	{ 
    		memset(strRecv, 0, sizeof(strRecv));
    		iRet = recvfrom(sock, strRecv, sizeof(strRecv) - 1, 0, (sockaddr*)&addr, &len);
    		if (iRet <= 0) { 
    			printf("recvfrom fail:%d", WSAGetLastError());
    			return -1;
    		}
    		printf("recv data:%s\n", strRecv);
    	}
    
    	closesocket(sock);
    	WSACleanup();
    
    	return 0;
    }

--------------------

欢迎关注本人公众号，公众号会更新一些不一样的内容，相信一定会有所收获。  
![在这里插入图片描述][20201219120057415.jpg_pic_center]

[20201219120057415.jpg_pic_center]: /images/20220213/dcab070c7369471e92975f2aeec04740.png