'브로드캐스팅' 태그의 글 목록

브로드캐스팅

Broadcasting 예제 2010.03.31

Broadcasting 예제

moltak 2010. 3. 31. 15:56

2010. 3. 31. 15:56

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

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();
}

저작자표시

'NativeCode > api' 카테고리의 다른 글

Sock 정보들 (0)	2010.04.04
소켓 옵션 (0)	2010.04.01
UDP Server, Client (0)	2010.03.31
Server Socket (0)	2010.03.19
Client Socket (0)	2010.03.19

PREV 이전 1 NEXT 다음

code toolbox