fly63前端网

www.fly63.com

首页文章资源工具教程 栏目
  • 关于我们
  • 网站投稿
  • 赞助一下
搜索

在线工具_工作生活好帮手

打造各种简单、易用、便捷的在线工具,网友无需注册和下载安装即可使用

点击查看

关闭

提交网站

protobuf.js
分享
复制链接
新浪微博
QQ 好友

扫一扫分享

GitHub:https://github.com/protobufjs/protobuf.js
网站描述:纯 JavaScript 实现构建在 ByteBuffer.js 之上的 .proto 文件解析库

protobuf.js是一个纯JavaScript实现,支持Node.js和浏览器的TypeScript,它容易使用速度快速,可以直接反射.proto文件,不需要生成任何文件。 

Google Protocol Buffers 传输的数据是二进制格式,JavaScript 天生不具备处理二进制数据的能力,所以要依赖 ByteBuffer.js ,ByteBuffer 和 ProtoBuf 都是由同一个团队 dcode.io 出品,ByteBuffer 可以单独使用,兼容 IE8+。

protobuf.js是基于ByteBuffer.js的Protocol Buffers纯JavaScript实现,主要功能是解析.proto文件,构建Message类,编码解码。

全局安装protobufjs,使用pbjs直接生成proto文件对应的js protobuf描述文件,这样就可以在普通页面中直接使用了。

安装

npm install protobufjs [--save --save-prefix=~]

使用

// const protobufjs = require('protobufjs')
import protobufjs from 'protobufjs'


// 要用到load模块
const { load } = protobufjs

实例

export default class protobuf {
static exportBuffer(parsedJsonList, molecule, proto , taskitem){
return new Promise((resolve, reject) => {
load(proto, (err, root) => {
if (err) {
console.log(err)
return reject(new Error('proto文件加载出错!'));
}
let prototxts = []
parsedJsonList.forEach(parsedJson => {
let parsedMessage = root.lookupType('TIV.' + parsedJson.header.type + 'Def')
const single = parsedMessage.create(parsedJson)
const singleBuffer = parsedMessage.encode(single).finish() // 这个singleBuffer发给后台就好
prototxts.push({
msgId: parsedJson.id,
msgType: parsedJson.header.type,
msgContent: singleBuffer,
taskType: parsedJson.taskType,
isEntry: isEntry(parsedJson.header.type, parsedJson.id, molecule)
})
})

let prototxtsMessage = root.lookupType('TIV.AllOperatorPb')
const all = prototxtsMessage.create({
allOperatorPb: prototxts,
taskFlow: taskitem ? taskitem : ''
})
const allBuffer = prototxtsMessage.encode(all).finish() // 这个buffer发给后台就好
const b64 = btoa(String.fromCharCode.apply(null, allBuffer))
// this.analysisBuffer(b64, proto)
resolve(b64);
})
})
}
static analysisBuffer(b64, proto) {
let allBuffer = atob(b64).split('').map(function (c) { return c.charCodeAt(0) })
return new Promise((resolve, reject) => {
load(proto, (err, root) => {
if (err) {
reject(err)
return console.log('proto文件加载出错');
}
let prototxtsMessage = root.lookupType('TIV.AllOperatorPb')
const alldata = prototxtsMessage.decode(allBuffer)
alldata.allOperatorPb.map(item => {
let parsMessage = root.lookupType('TIV.' + item.msgType + 'Def')
const fields = [];
if (Object.keys(parsMessage.Parameter.fields).length > 0) {
Object.keys(parsMessage.Parameter.fields).forEach(ikey => {
let value = 0;
if (parsMessage.Parameter.fields[ikey].type === "bool") {
value = false;
}
fields.push({
title: ikey,
value: parsMessage.Parameter.fields[ikey].typeDefault || value
})
})
}
const prototxt = parsMessage.decode(item.msgContent)
fields.forEach(field => {
if(prototxt['param']){
prototxt['param'][field.title] = prototxt['param'][field.title] ? prototxt['param'][field.title] : field.value;
}
})
prototxt.header.type = prototxt.header.type.split('Operator')[0]
item.msgContent = formatInit(prototxt)
})
if(process.env.NODE_ENV === 'development'){
console.log('解析后json数据:',alldata.allOperatorPb)
}
resolve(alldata.allOperatorPb);
})
})
}
}

protobufjs使用,数据的转换依赖 proto配置文件,protobufjs默认支持本地同源文件请求,如果proto文件是固定的不需要更改的,配置在前端静态文件就好了;如何会动态变更的话,需要用到绝对路径,需要解决跨域问题;

修改protobufjs对象原型默认的load请求文件方式:

protobufjs.util.fetch.xhr = function fetch_xhr(filename, options, callback) {
var xhr = new XMLHttpRequest();
xhr.onreadystatechange /* works everywhere */ = function fetchOnReadyStateChange() {

if (xhr.readyState !== 4)
return undefined;

// local cors security errors return status 0 / empty string, too. afaik this cannot be
// reliably distinguished from an actually empty file for security reasons. feel free
// to send a pull request if you are aware of a solution.
if (xhr.status !== 0 && xhr.status !== 200)
return callback(Error("status " + xhr.status));

// if binary data is expected, make sure that some sort of array is returned, even if
// ArrayBuffers are not supported. the binary string fallback, however, is unsafe.
if (options.binary) {
var buffer = xhr.response;
if (!buffer) {
buffer = [];
for (var i = 0; i < xhr.responseText.length; ++i)
buffer.push(xhr.responseText.charCodeAt(i) & 255);
}
return callback(null, typeof Uint8Array !== "undefined" ? new Uint8Array(buffer) : buffer);
}
return callback(null, xhr.responseText);
};

if (options.binary) {
// ref: https://developer.mozilla.org/en-US/docs/Web/api/XMLHttpRequest/Sending_and_Receiving_Binary_Data#Receiving_binary_data_in_older_browsers
if ("overrideMimeType" in xhr)
xhr.overrideMimeType("text/plain; charset=x-user-defined");
xhr.responseType = "arraybuffer";
}

xhr.open("GET", filename);
let headers = options.headers || {};

if (process.env.NODE_ENV !== 'development') {
headers['X-TC-Action'] = 'WorkbenchPb'
headers['X-TC-Region'] = 'ap-guangzhou'
headers['X-TC-Timestamp'] = Math.round(new Date().getTime()/1000).toString()
headers['X-TC-Service'] = 'AMTPGate'
headers['X-TC-Version'] = '2020-05-14'
}

for (let item in headers) {
if (headers.hasOwnProperty(item) && headers[item] !== null) {
xhr.setRequestHeader(item, headers[item]);
}
}
xhr.send();
};

Buffer数据流,传输速度非常快,数据保密性更强,前后端数据传输跟健壮。

文中的示例,最终使用的是base64,这样对ajax请求无影响,直接使用post请求,即可。如果直接用buffer,需要自己封装ajax;
大概设置:

xhr.responseType = 'blob'


链接: https://fly63.com/nav/3927

more>>
相关栏目
layer
layer是一款口碑极佳的web弹层组件
点击进入GitHub
iScroll.js
IScroll是移动页面上被使用的一款仿系统滚动插件。
官网GitHub
wangEditor
基于javascript和css开发的 Web富文本编辑器
官网GitHub
ueditor
由百度web前端研发部开发所见即所得富文本web编辑器
官网GitHub
highlight
Highlight.js 是一个用 JavaScript 写的代码高亮插件,在客户端和服务端都能工作。
官网GitHub
UglifyJS
一个js 解释器、最小化器、压缩器、美化器工具集
官网GitHub
lozad.js
高性能,轻量级,可配置的懒加载图片工具
官网GitHub
Sortable.js
简单灵活的 JavaScript 拖放排序插件
官网GitHub
validate.js
表单提供了强大的验证功能,让客户端表单验证变得更简单
官网GitHub
Draggin.js
一款兼容移动手机的js拖拽插件
官网GitHub
lazysizes.js
响应式图像延迟加载JS插件【懒加载】
官网GitHub
cropper.js
通过canvas实现图片裁剪
官网GitHub
clipboard.js
浏览器中复制文本到剪贴板的插件,不需要Flash,仅仅2kb
官网GitHub
siema
轻量级简单的纯 Js轮播插件
官网GitHub
Mermrender
用于生成序列和UML图的RESTful渲染管道
官网GitHub
Editor.js
JSON格式输出数据的富文本和媒体编辑器
官网GitHub

手机预览