1 Star 1 Fork 413

用心就好 / porter

forked from sxfad / porter 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
plugin.md 1.28 KB
一键复制 编辑 原始数据 按行查看 历史
zkevin 提交于 2019-04-04 13:18 . 告警发送模型

插件开发

插件开发

  • 消费器插件
继承AbstractDataConsumer类

通过spring.factories发布:

cn.vbill.middleware.porter.core.task.consumer.DataConsumer=xxx

通过配置文件生效:

porter.task[index].consumer.consumerName=pluginName
  • EventConverter(消费源消息转换器插件)
通过spring.factories发布:

cn.vbill.middleware.porter.core.message.converter.EventConverter = \
  cn.vbill.middleware.porter.plugin.OggXmlConverter

通过配置文件生效:

porter.task[index].consumer.converter=oggXml
  • EventProcessor(自定义消费数据抽取插件)
可以以jar、class、源码的形式编写

通过配置文件生效:

porter.task[index].consumer.eventProcessor.className=cn.vbill.middleware.porter.plugin.CustomEventProcessor
porter.task[index].consumer.eventProcessor.content=文件路径
  • 载入器插件
继承AbstractDataLoader类

通过spring.factories发布:

cn.vbill.middleware.porter.core.loader.DataLoader=xxx

通过配置文件生效:

porter.task[index].loader.loaderName=pluginName
  • 告警插件
暂不开放

插件注册

	放置到porter-boot-version/plugins目录下,重启porter-boot后生效。

开发样例

demo

Java
1
https://gitee.com/wzf08294119/porter.git
git@gitee.com:wzf08294119/porter.git
wzf08294119
porter
porter
master

搜索帮助