代码拉取完成,页面将自动刷新
package RabbitmqRoute
import (
"bytes"
"encoding/base64"
"encoding/gob"
"errors"
"fmt"
"strings"
)
//结构体二进制处理
/**
数据协议封装
*/
func dataBinary(data interface{}) ([]byte, error) {
buf := new(bytes.Buffer)
if err := gob.NewEncoder(buf).Encode(data); err != nil {
return nil, err
}
return buf.Bytes(), nil
}
/**
数据解析
*/
func DataEngineParse(base64Str string, out interface{}) error {
base64Bytes, err := base64.StdEncoding.DecodeString(base64Str)
if err != nil {
return errors.New(fmt.Sprintf("base64 decode error :%s", err.Error()))
}
var buf bytes.Buffer
buf.Write(base64Bytes)
ad := buf.String()
buf.Reset()
err = gob.NewDecoder(strings.NewReader(ad)).Decode(out)
return nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。