pomelo-flatbuffer

FlatBuffer

使用说明

pomelo 中安装与使用

安装

npm install pomelo-flatbuffer --save

使用

在 app.js 中添加一下脚本

// app configuration
app.configure('development', 'gate|connector', () =>
{
	app.use(flatBuffer, {
		serverProtos : '/serverProtos.json',
        clientProtos : '/clientProtos.json',
        serverFBPath : '/serverBFBS/',
        clientFBPath : '/clientBFBS/'
	});
	app.set('connectorConfig',
		{
			connector   : pomelo.connectors.hybridconnector,
			// timeout:10,
			handshake   : handshake,
			heartbeat   : 5,
			useProtobuf : false,
			setNoDelay  : true,
			// disconnectOnTimeOut : true
			// ,distinctHost:true
		});
});

参数说明

• serverProtos dafault: config/serverProtos.json 服务器发送到客户端的消息
• clientProtos default: config/clientProtos.json 客户端发送到服务器的消息
• serverFBPath default: config/serverBFBS/ flatbuffer 序列化服务器发送的数据（bfbs 格式文件）
• clientFBPath default: config/clientBFBS/ flatbuffer 反序列化服务器接受的数据（bfbs 格式文件）

bfbs 文件生成

# cd tests
# flatc -o bfbsData  -b --schema flatSchema/*.fbs

实例使用

文件夹说明

• serverBFBS 服务器发送到客户端的消息， 和 serverProtos.json 一致

  • .json route与class对照表
  • .bfbs flatc生成的数据

• clientBFBS 客户端发送到服务器的消息， 和 clientProtos.json 一致

  • .json route与class对照表
  • .bfbs flatc生成的数据

• flatSchema flat文件的消息格式

const FlatBuffer = require('../lib/components/flatbuffer');
const flatBufferInstance = FlatBuffer(app, {
	serverProtos : '/serverProtos.json',
	clientProtos : '/clientProtos.json',
	serverFBPath : '/serverBFBS/',
	clientFBPath : '/clientBFBS/'
});

FlatBuffer.start(()=>{
    // 序列化数据
    const data = flatBufferInstance.encode('ItemDistances', exampleData.ItemDistances);
    // 反序列化数据
    flatBufferInstance.decode('ItemDistances', data);
})

测试

node ./test/PomeloFlatBuffer.js 
node ./test/FlatBufferTest.js