flatbuffers에서 union을 이용하면 타입을 구분 할 수 있다.
flatbuffers의 union은 enum과 C언어의 union을 버무린것과 비슷하다.
패킷의 타입이나 이벤트 타입등 여러개의 구조체를 사용한다면 union을 사용 하는것이 좋다.
IDL 작성
여기서는 EventStart, EventEnd 두가지 이벤트 타입을 사용하고 있다.
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;
union 자체로 만들지 못하기 때문에 EvnetHolder 테이블에 event 변수로 지정 했다.
union 직렬화 예
MyEvent::CreateEventHolder(builder, MyEvent::EventCmd_EventStart, startOffset.Union());
Finish 대신 FinishSizePrefixed 함수를 사용하면 버퍼 앞에 4byte의 버퍼의 크기를 추가 한다.
나중에 역직렬화 할때 앞의 데이터 4byte로 크기를 읽고 나머지는 크기만큼 데이터를 읽으면 된다.
FinishSizePrefixed로 만들어진 flatbuffers 버퍼는 검사도 VerifySizePrefixedEventHolderBuffer로 한다.
버퍼 앞의 4바이트를 제거하면 VerifyEventHolderBuffer로 검사 한다.
EventStart, EventEnd를 직렬화 한다.
void UnionSample_Satart(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)
{
DeserializeUnion(data);
}
}
void UnionSample_End(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)
{
DeserializeUnion(data);
}
}
union 역 직렬화
union의 타입을 체크 하는 방법은 다음과 같다.
union 타입 이름 = "union 변수 이름" + "_type( )"
eventHolder->event_type() = eventHolder->event + _type( )
auto eventHolder = MyEvent::GetEventHolder(data+(bufSize-prefixedSize));
if (eventHolder->event_type() == MyEvent::EventCmd_EventStart)
버퍼를 해당 타입으로 변환하는 방법은 다음과 같다.
변활할 타입 변수 = "union 변수 이름" + "_as" + <변환할 타입>( )
const MyEvent::EventStart* e = eventHolder->event_as<MyEvent::EventStart>( )
const MyEvent::EventStart* e = eventHolder->event_as<MyEvent::EventStart>();
역 직렬화 코드는 다음과 같다.
void DeserializeUnion(uint8_t* data)
{
int deBufSize = data[0];
flatbuffers::Verifier verifier1(data + 4, deBufSize);
bool res = MyEvent::VerifyEventHolderBuffer(verifier1);
if (res)
{
auto eventHolder = MyEvent::GetEventHolder(data + 4);
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>();
std::cout << "아이디 : " << e->id() << std::endl;
std::cout
<< "타임 : " << e->message()->c_str() <<
std::endl;
}
}
}
전체 코드는 다음과 같다.
#include <iostream>
#include "flatbuffers/flatbuffers.h"
#include "event_generated.h"
void DeserializeUnion(uint8_t* data)
{
int deBufSize = data[0];
flatbuffers::Verifier verifier1(data + 4, deBufSize);
bool res = MyEvent::VerifyEventHolderBuffer(verifier1);
if (res)
{
auto eventHolder = MyEvent::GetEventHolder(data + 4);
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>();
std::cout << "아이디 : " << e->id() << std::endl;
std::cout
<< "타임 : " << e->message()->c_str() <<
std::endl;
}
}
}
void UnionSample_Satart(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)
{
DeserializeUnion(data);
}
}
void UnionSample_End(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)
{
DeserializeUnion(data);
}
}
int main()
{
UnionSample_Satart(2, 88.8f);
UnionSample_Satart(5, 3.8f);
std::cout << "--------------------------" << std::endl;
UnionSample_End(2, "quit2");
UnionSample_End(5, "quit5");
getchar();
}
다운로드 : flatbuffer_union_test.zip
참고)
Flatbuffers로 만들어진 바이너리 식별 방법
https://zepeh.tistory.com/576
데이터를 보낼때는 FinishSizePrefixed를 사용 받을때는 4byte로 패킷크기를 체크후 나머지를 받는다.
https://blog.csdn.net/guotianqing/article/details/100691267
union 스키마 예제
https://realtrick.tistory.com/5
|