UDP UDP广播的实现IPv4&IPv6

#include "udpctl.h" namespace myspace { #define MIN_BUFFSISE 128 char time_buff[MIN_BUFFSISE]; char *GetCurTime() { time_t tm_struct; tm *ptr; time(&tm_struct); ptr = localtime(&tm_struct); bzero(time_buff, MIN_BUFFSISE); sprintf(time_buff, "%04d_%02d_%02d %02d:%02d:%02d ", ptr->tm_year + 1900, ptr->tm_mon + 1, ptr->tm_mday, ptr->tm_hour, ptr->tm_min, ptr->tm_sec); return time_buff; } int UDP_Controler::Init() { m_local_fd = socket(AF_INET6, SOCK_DGRAM, 0); if (m_local_fd < 0) { perror("socket"); return -1; } m_ctl_type = ctl_unknowtype; return 0; } int UDP_Controler::BroadCast() { if (m_ctl_type != ctl_unknowtype && m_ctl_type != ctl_broadcast_send) { LOGS << "Type error" << LOGE; return -1; } int iset = 1; if (setsockopt(m_local_fd, SOL_SOCKET, SO_BROADCAST, &iset, sizeof(iset))) { perror("setsockopt"); return -1; } char buff[MIN_BUFFSISE] = {0x00}; sprintf(buff, "%s", "FF02::1"); sockaddr_in6 addr; addr.sin6_family = AF_INET6; int res = inet_pton(AF_INET6, buff, &addr.sin6_addr); if(res <= 0) { perror("inet_pton"); return -1; } addr.sin6_port = htons(9100); addr.sin6_scope_id = if_nametoindex("ens33"); bzero(buff,MIN_BUFFSISE); sprintf(buff, "%s", "@TEST IPV6 GETJOB \r\n"); res = sendto(m_local_fd, buff, strlen(buff), 0, (sockaddr *)&addr, sizeof(addr)); if (res == -1) { perror("sendto"); return -1; } LOGS << "send broadcast msg:" << buff << "." << LOGE; m_ctl_type = ctl_broadcast_send; return 0; } int UDP_Controler::BroadCast_Recv() { if (m_ctl_type != ctl_unknowtype && m_ctl_type != ctl_broadcast_recv) { LOGS << "Type error" << LOGE; return -1; } char buff[MIN_BUFFSISE] = {0x00}; sockaddr_in6 local_addr, addr; socklen_t len = sizeof(sockaddr_in6); local_addr.sin6_addr = in6addr_any; local_addr.sin6_port = htons(9100); local_addr.sin6_family = AF_INET6; if(bind(m_local_fd, (sockaddr*)&local_addr, len) == -1) { perror("bind"); return -1; } int res = recvfrom(m_local_fd, buff, MIN_BUFFSISE, 0, (sockaddr *)&addr, &len); if (res == 0) { perror("recvfrom return 0"); return -1; } else if (res == -1) { perror("recvfrom return -1"); return -1; } char addrv6[128] = { 0x00 }; inet_ntop(AF_INET6, &addr.sin6_addr , addrv6, 128 ); LOGS << "recv broadcast msg:" << buff << ",from:" << addrv6 << ":" << ntohs(addr.sin6_port) << LOGE; m_ctl_type = ctl_broadcast_recv; return res; } }