| flatbuffers의 union을 이용해 네트웍으로 패킷을 보내는 간단한 예제를 만들어 보자. 이 예제는 flatbuffers로 네트웍으로 송신, 수신 가능성을 확인하기 위한 소스이다. 프로젝트에서 그대로 사용 하기에는 많이 부족한 점이 있다. 네트웍 코드는 아래 싸이트에서 다운로드 받아 조금 수정 하였다. https://his130.tistory.com/378 수정한 네트웍 코드: networkTest.zip union을 이용하는 방법은 앞장에서 배웠다. flatbuffers02 union을 이용한 타입 구분 IDL 작성event.fbs 파일namespace MyEvent;
table EventStart { id : int; time : float; } table EventEnd { id : int; message : string; } union EventCmd { EventStart, EventEnd } table EventHolder { event : EventCmd; } root_type EventHolder; 서버, 클라이언트 공통 헤더클라이언트와 서버에 공통으로 사용하는 헤더이다.PACKET_SAMPLE3 선언 주석을 해제하면 flatbuffers를 이용해 송수신을 테스트 한다. common.h #ifndef _CCOMMON_H
#define _CCOMMON_H //아래 3가지 중에 한개만 주석을 해제 해야 한다. //#define PACKET_SAMPLE1 1 //문자열 보내기 //#define PACKET_SAMPLE2 1 //구조체 보내기 #define PACKET_SAMPLE3 1 //flatbuffers 보내기 #endif // !_CCOMMON_H //send()함수를 통해서 클라이언트에 메세지 전송
#ifdef PACKET_SAMPLE1 char message[] = "hello ! Welcome Sample1!"; send(CliSock, message, sizeof(message), 0); #endif #ifdef PACKET_SAMPLE2 SC_HELLO packet; send(CliSock, (char*)&packet, packet.size, 0); #endif #ifdef PACKET_SAMPLE3 Send_UnionSample_Satart(CliSock, 100, 0.8f); Send_UnionSample_End(CliSock, 5, "quit5"); #endif server.cpp에서 송신서버에서 클라이언트 전송할때 FinishSizePrefixed 함수를 이용해 앞에 4byte에 버퍼의 길이를 저장한다.앞의 4byte에 저장되는 크기는 bufSize보다 4 적을 것이다. 서버에서는 두개의 패킷을 보낸다. #ifdef PACKET_SAMPLE3
Send_UnionSample_Satart(CliSock, 100, 0.8f); Send_UnionSample_End(CliSock, 5, "quit5"); #endif 두개의 패킷 코드를 별도의 함수로 작성 하였다. void Send_UnionSample_Satart(SOCKET socket, int id, float startTime)
{ flatbuffers::FlatBufferBuilder builder; //직렬화 serialize auto startOffset = MyEvent::CreateEventStart(builder, id, startTime); auto rootOffset = MyEvent::CreateEventHolder(builder, MyEvent::EventCmd_EventStart, startOffset.Union()); builder.FinishSizePrefixed(rootOffset); auto data = builder.GetBufferPointer(); auto bufSize = builder.GetSize(); flatbuffers::Verifier verifier(data, bufSize); bool ok = MyEvent::VerifySizePrefixedEventHolderBuffer(verifier); if (ok) { send(socket, (const char*)data, bufSize, 0); } } void Send_UnionSample_End(SOCKET socket, int id, std::string msg) { flatbuffers::FlatBufferBuilder builder; //직렬화 serialize auto offset = MyEvent::CreateEventEnd(builder, id, builder.CreateString(msg.c_str())); auto rootOffset = MyEvent::CreateEventHolder(builder, MyEvent::EventCmd_EventEnd, offset.Union()); builder.FinishSizePrefixed(rootOffset); auto data = builder.GetBufferPointer(); auto bufSize = builder.GetSize(); flatbuffers::Verifier verifier(data, bufSize); bool ok = MyEvent::VerifySizePrefixedEventHolderBuffer(verifier); if (ok) { send(socket, (const char*)data, bufSize, 0); } } 클라이언트에서 수신flattbuffers 데이터를 받을때는 4byte로 버퍼의 길이를 읽고, 버퍼 크기 만큼 데이터를 받는다.데이터를 받아서 역직렬화 한다. 두개의 패킷을 받는다. #ifdef PACKET_SAMPLE3
DoRecv(sock); DoRecv(sock); #endif flatbuffers의 크기를 받는다. int len = recv(sock, (char*)&buffLen, 4, 0); 버퍼를 생성하고 버퍼 크기 만큼 네트웍으로 수신한다. std::unique_ptr<uint8_t[]> buff(new uint8_t[buffLen]); len = recv(sock, (char*)buff.get(), buffLen, 0); DeserializeUnion 함수에서 이벤트 타입에 따라 패킷을 처리한다. int DoRecv(SOCKET sock)
{ int buffLen = 0; int len = recv(sock, (char*)&buffLen, 4, 0); if (len == -1) { ErrorHandling("recv buffer length Error\n"); return -1; } std::unique_ptr<uint8_t[]> buff(new uint8_t[buffLen]); len = recv(sock, (char*)buff.get(), buffLen, 0); if (len == -1) { ErrorHandling("recv buffer Error\n"); return -1; } DeserializeUnion(buff.get(), buffLen); return 0; } void DeserializeUnion(uint8_t* data, int deBufSize) { flatbuffers::Verifier verifier(data, deBufSize); bool res = MyEvent::VerifyEventHolderBuffer(verifier); if (res) { auto eventHolder = MyEvent::GetEventHolder(data); if (eventHolder->event_type() == MyEvent::EventCmd_EventStart) { const MyEvent::EventStart* e = eventHolder->event_as<MyEvent::EventStart>(); std::cout << "MyEvent::EventStart " << "아이디 : " << e->id() << std::endl; std::cout << "MyEvent::EventStart " << "타임 : " << e->time() << std::endl; } else if (eventHolder->event_type() == MyEvent::EventCmd_EventEnd) { const MyEvent::EventEnd* e = eventHolder->event_as<MyEvent::EventEnd>(); if (e == nullptr) { printf("\n EventEnd is nullptr\n"); } else { int id = e->id(); std::cout << "MyEvent::EventEnd 아이디 : " << e->id() << std::endl; std::cout << "MyEvent::EventEnd 메세지 : " << e->message()->c_str() << std::endl; } } } } 클라이언트 실행 결과MyEvent::EventStart 아이디 : 100MyEvent::EventStart 타임 : 0.8 MyEvent::EventEnd 아이디 : 5 MyEvent::EventEnd 메세지 : quit5 SOCKET OVER 다운로드: server.cpp client.cpp flatbuffers_networkTest.zip 참고) flatbuffer 패킷 보내기 https://copynull.tistory.com/416?category=194491 https://swjman.tistory.com/12 https://zepeh.tistory.com/517 https://gall.dcinside.com/mgallery/board/view/?id=game_dev&no=2599 데이터를 보낼때는 FinishSizePrefixed를 사용 받을때는 4byte로 패킷크기를 체크후 나머지를 받는다. https://blog.csdn.net/guotianqing/article/details/100691267 union 정의 https://zepeh.tistory.com/517 https://www.huaweicloud.com/articles/cab74552246ce06561b24873d4d7c07e.html https://base64.work/so/c%23/1073875 FlatBuffers + Boost Asio 서버 예제 https://copynull.tistory.com/414 |