udp组播接收和发送程序（udp组播发送需要绑定ip吗）

科技前沿 • 2025-05-16 18:01 • 阅读 47

大家好，我是讯享网，很高兴认识大家。

#include <iostream>

#include "Send.h"

using namespace std;

Send::Send(void) {

m_socket = INVALID_SOCKET; WSAData ws; //每个Winsock程序必须使用WSAStartup载入合适的Winsock动态链接库，如果载入失败，WSAStartup将返回SOCKET_ERROR，这个错误就是WSANOTINITIALISED if (WSAStartup(MAKEWORD(1,1),&amp;ws)!=0) { cout&lt;&lt;&quot;WSAStartup failed! Error: &quot;&lt;&lt;WSAGetLastError()&lt;&lt;endl; }

讯享网

}

Send::~Send(void) {

讯享网WSACleanup();

}

bool Send::InitSocket(const string strIPAddress,const string strPort) {

讯享网

//创建套接字,ipv4,报文，udp协议 m_socket = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP); //创建socket失败 if (INVALID_SOCKET == m_socket) { cout&lt;&lt;&quot;failed to create socket&quot;&lt;&lt;endl; return false; } //初始化sock地址 InitSockAddress(strIPAddress,strPort); // 绑定 if (bind (m_socket, (struct sockaddr FAR *) &amp;m_sockLocalAddress, sizeof (m_sockLocalAddress)) == SOCKET_ERROR) { //报错 cout&lt;&lt;&quot;Binding socket failed! Error: &quot;&lt;&lt;WSAGetLastError()&lt;&lt;endl; closesocket (m_socket); return false; } int iOptVal=64; //1秒 // 设置组播存活时间 if (setsockopt (m_socket, IPPROTO_IP, 3, (char FAR *)&amp;iOptVal, sizeof (int)) == SOCKET_ERROR) { //报错 cout&lt;&lt;&quot;setsockopt failed! Error:&quot;&lt;&lt;WSAGetLastError()&lt;&lt;endl; closesocket (m_socket); return false; } return true;

}

void Send::CleanSocket() {

讯享网shutdown(m_socket,0x01); closesocket(m_socket);

} bool Send::SendStringData(const string strMessage) {

if (sendto (m_socket, (char *)&amp;strMessage, sizeof(strMessage), 0, (struct sockaddr FAR *) &amp;m_sockDesAddress, sizeof (m_sockDesAddress)) == SOCKET_ERROR) { //报错 cout&lt;&lt;&quot;sendto failed! Error: %d&quot;&lt;&lt;WSAGetLastError ()&lt;&lt;endl; closesocket (m_socket); return false; } else { return true; }

}

bool Send::SendStructeData(const Person person) {

讯享网if (sendto (m_socket, (char *)&amp;person, sizeof(person), 0, (struct sockaddr FAR *) &amp;m_sockDesAddress, sizeof (m_sockDesAddress)) == SOCKET_ERROR) { //报错 cout&lt;&lt;&quot;sendto failed! Error: %d&quot;&lt;&lt;WSAGetLastError ()&lt;&lt;endl; closesocket (m_socket); return false; } else { return true; }

} void Send::InitSockAddress(const string strIPAddress,const string strPort) {

//本地sock地址设置 m_sockLocalAddress.sin_family = AF_INET; //ipv4地址类型 m_sockLocalAddress.sin_addr.S_un.S_addr = htonl(INADDR_ANY); m_sockLocalAddress.sin_port = htons(0); memset(m_sockLocalAddress.sin_zero,0,8); //目的sock地址设置 //IPv4版本 m_sockDesAddress.sin_family = AF_INET; //端口 m_sockDesAddress.sin_port = htons (atol(strPort.c_str())); //地址 m_sockDesAddress.sin_addr.s_addr = inet_addr (strIPAddress.c_str());

}

udp组播接收和发送程序（udp组播发送需要绑定ip吗）

相关推荐