广告业务系统之框架沉淀 —— “数据消费型服务框架”

Posted 2023-01-14 魏小言

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了广告业务系统之框架沉淀 —— “数据消费型服务框架”相关的知识，希望对你有一定的参考价值。

文章目录

- 广告业务系统之框架沉淀 —— “数据消费型服务框架”
- - 数据消费型服务统一框架
  - - 主流程
    - Plugin 构建

广告业务系统之框架沉淀 —— “数据消费型服务框架”

数据消费型服务统一框架

由于 ADX 系统中，大量数据以流式涌动，整个链路中出现了 “多处流转都需要以消费中间件数据的模式完成“ 的奇观。为了提升代码的复用性、及可扩展性，我们将 ”数据消费“ 逻辑做抽象隔离成统一框架，业务逻辑以 “组件” 的形式进行嵌入。

在具体的实现中，需要用到的就是 Goland 中的 Plugin 功能。

主流程

我们将消费中间件数据的逻辑确认后，在处理数据的时候，以抽象函数做接口实现。

如图，我们把消费数据放置于 channel 中，在抽象函数 Deal() 中做数据处理。各个业务服务只需实现 Deal() 函数以组件形式构建就可以直接复用公共库A’ 。

Plugin 构建

在业务服务 A\\B\\C 中，我们需要实现对应的处理函数 Deal()。

在服务 A 中，除了消费处理 Deal () 外，还可以覆盖实现主流程中的 Init() 函数，做一切附带的其他功能实现。

#!/bin/bash

# build
export GOPROXY=https://goproxy.cn,direct
export GONOPROXY=*XXXX*
export GOINSECURE=*XXXX*

mkdir -p target/bin

git config --global url."ssh://git@XXXX:PPPP".insteadOf "https://XXXX"
GOBIN=`pwd`/bin go install XXXX/A'
mv bin/A' bin/A'_consumer

go build -buildmode=plugin -o bin/A.so  ./main
if [[ $? -eq 0 ]]; then
    echo "succeed to build."
else
    echo "fail to build!!!"
fi