linux 멀티캐스트 example

[ 리눅스 멀티캐스트 예제 ]

멀티캐스트는 특정 네트워크 상에서 해당 채널에 등록된 모든 컴퓨터에 데이터를 전송하는 방법이다.

브로드캐스트에 비해 훨씬 효율적으로 네트워크 자원을 사용할 수 있다.

멀티캐스트로 데이터를 주고받기 위해서는 미리 정의된 D클래스 주소 범위를 논리적인 채널로 사용해야 한다.

[ 244.0.0.1 ~ 239.255.25..254 ]

간단한 테스트 코드다. 우선 데이터를 보내주는 녀석이다.

#define MULTI_NET_GROUP "224.0.0.87" #define MULTI_NET_PORT 16420 void SendMulticastMessage(void) { int sockMulticast = -1; char* msghdr = "Network Detect"; struct sockaddr_in addr; memset( &addr, 0x0, sizeof(addr) ); sockMulticast = socket( AF_INET, SOCK_DGRAM, 0 ); // UDP addr.sin_family = AF_INET; addr.sin_addr.s_addr = inet_addr( MULTI_NET_GROUP ); addr.sin_port = htons( MULTI_NET_PORT ); sendto( sockMulticast, msg, strleng(msg), 0, (struct sockaddr *)&addr, sizeof(addr) ); close( sockMulticast ); }

다음은 채널에 등록하고 메세지를 기다리는 Receiver 다.

 int ListenToMulticast(void) { int sock = -1; int sockTemp = -1; int yes = -1; int addrlen = -1; int nbytes = -1; char msgbuf[MSGBUFSIZE] = {0,}; struct sockaddr_in addr; struct ip_mreq mreq; if( sock == -1 ) { sockTemp = socket( AF_INET, SOCK_DGRAM, 0 ); // UDP if( sockTemp > -1 ) { mreq.imr_multiaddr.s_addr = inet_addr(MULTI_NET_GROUP); // 멀티캐스트 주소 mreq.imr_interface.s_addr = htonl(INADDR_ANY); // 데이터를 받을 인터페이스의 주소 if( setsockopt( sockTemp, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq) ) > -1 ) // 멀티캐스트 채널에 등록 { if( setsockopt( sockTemp, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes) ) > -1 ) // for bind { memset( &addr, 0x0, sizeof(addr) ); addr.sin_family = AF_INET; addr.sin_addr.s_addr = htonl(INADDR_ANY); addr.sin_port = htons(MULTI_NET_PORT); if( bind( sockTemp, (struct sockaddr*)&addr, sizeof(addr) ) > -1 ) { sock = sockTemp; } else { printf("[%s] socket bind fail", __func__); close( sockTemp ); return -1; } } } else { printf("[%s] error, can't find route setting!!", __func__); close( sockTemp ); return -1; } } else { printf("[%s] Create socket fail", __func__); return -1; } } // setting done. if( sock != -1 ) { addrlen = sizeof(addr); memset( msgbuf, 0x0, sizeof(addr) ); while(1) { nbytes = recvfrom( sock, msgbuf, MSGBUFSIZE, 0, (struct sockaddr *)&addr, (socklen_t*)&addrlen ); if( nbytes ) { printf("[%s] Rev msg : %s", __func__, msgbuf); // TODO: } else if( nbytes == -1 ) { printf("[%s] receive msg fail", __func__); close( sock ); return -1; } } } printf("[%s] All Done..", __func__); return 0; }