Broadcasting 예제

이번엔 브로드캐스팅 예제입니다. 자신이 속한 세그먼트에 데이터를 한방에 보낼 때 사용하는 프로토콜 이죠.
일단 예제를 보시죠. 아주 아주 간단합니다.
이제까지와 다른 점이라곤 소켓에 옵션을 주는 것 밖에 없는데요. 그 옵션들은 다음에 포스팅 하도록 하겠습니다.


Sender
 #include <iostream> #include <winsock.h> #pragma comment( lib, "ws2_32.lib" ) using namespace std; // 브로드캐스팅 전송 예제 void main( void ) { WSAData wsaData; SOCKET sock; SOCKADDR_IN addrSender; try { // socket 생성 까지는 똑같습니다. if( WSAStartup( MAKEWORD( 2, 2 ), &wsaData ) != 0 ) { throw WSAGetLastError(); } // 소켓 생성, 브로드캐스팅은 UDP 입니다. sock = socket( AF_INET, SOCK_DGRAM, 0 ); if( sock == INVALID_SOCKET ) { throw WSAGetLastError(); } // 브로드캐스팅 활성화, 소켓에 옵션을 줍니다. BOOL bEnable = TRUE; if( setsockopt( sock, SOL_SOCKET, SO_BROADCAST, ( char * )&bEnable, sizeof( bEnable ) ) == SOCKET_ERROR ) { throw WSAGetLastError(); } memset( ( void * )&addrSender, 0, sizeof( SOCKADDR ) ); addrSender.sin_family = AF_INET; addrSender.sin_port = htons( 9000 ); // 브로드캐스팅 옵션 addrSender.sin_addr.s_addr = htonl( INADDR_BROADCAST ); // 전송 char buf[ 128 ] = { 0, }; while( 1 ) { cin >> buf; if( sendto( sock, buf, strlen( buf ), 0, ( SOCKADDR * )&addrSender, sizeof( SOCKADDR ) ) == SOCKET_ERROR ) { throw WSAGetLastError(); } } } catch( int &ex ) { cout << "Error Code: " << ex << endl; } closesocket( sock ); WSACleanup(); }

Receiver
 #include <iostream> #include <winsock.h> #pragma comment( lib, "ws2_32.lib" ) using namespace std; // 브로드캐스팅 수신 예제 void main( void ) { WSAData wsaData; SOCKET sockReceiver; SOCKADDR_IN addrReceiver; try { // socket 생성 까지는 똑같습니다. if( WSAStartup( MAKEWORD( 2, 2 ), &wsaData ) != 0 ) { throw WSAGetLastError(); } // 소켓 생성, 브로드캐스팅은 UDP 입니다. sockReceiver = socket( AF_INET, SOCK_DGRAM, 0 ); if( sockReceiver == INVALID_SOCKET ) { throw WSAGetLastError(); } // 브로드캐스팅 활성화, 소켓에 옵션을 줍니다. BOOL bEnable = TRUE; if( setsockopt( sockReceiver, SOL_SOCKET, SO_BROADCAST, ( char * )&bEnable, sizeof( bEnable ) ) == SOCKET_ERROR ) { throw WSAGetLastError(); } memset( ( void * )&addrReceiver, 0, sizeof( SOCKADDR ) ); addrReceiver.sin_family = AF_INET; addrReceiver.sin_port = htons( 9000 ); // 브로드캐스팅 옵션 addrReceiver.sin_addr.s_addr = htonl( INADDR_ANY ); // 바인딩 if( bind( sockReceiver, ( SOCKADDR * )&addrReceiver, sizeof( SOCKADDR ) ) == SOCKET_ERROR ) { throw WSAGetLastError(); } // 브로드캐스팅 데이터 받기 SOCKADDR_IN senderAddr; int addrLen = sizeof( SOCKADDR_IN ); char buf[ 128 ] = { 0, }; while( 1 ) { if( recvfrom( sockReceiver, buf, 128, 0, ( SOCKADDR * )&senderAddr, &addrLen ) == SOCKET_ERROR ) { throw WSAGetLastError(); } cout << buf << endl; memset( buf, 0, 128 ); } } catch( int &ex ) { cout << "Error Code: " << ex << endl; } closesocket( sockReceiver ); WSACleanup(); }