插件开发

插件开发

  • 消费器插件
  1. 继承AbstractDataConsumer类
  3. 通过spring.factories发布:
  5. cn.vbill.middleware.porter.core.consumer.DataConsumer=xxx
  7. 通过配置文件生效:
  9. porter.task[index].consumer.consumerName=pluginName
  • EventConverter(消费源消息转换器插件)
  1. 通过spring.factories发布:
  3. cn.vbill.middleware.porter.core.event.s.EventConverter = \
  4.   cn.vbill.middleware.porter.plugin.OggXmlConverter
  6. 通过配置文件生效:
  8. porter.task[index].consumer.converter=oggXml
  • EventProcessor(自定义消费数据抽取插件)
  1. 可以以jar、class、源码的形式编写
  3. 通过配置文件生效：
  5. porter.task[index].consumer.eventProcessor.className=cn.vbill.middleware.porter.plugin.CustomEventProcessor
  6. porter.task[index].consumer.eventProcessor.content=文件路径
  • 载入器插件
  1. 继承AbstractDataLoader类
  3. 通过spring.factories发布:
  5. cn.vbill.middleware.porter.core.loader.DataLoader=xxx
  7. 通过配置文件生效:
  9. porter.task[index].loader.loaderName=pluginName
  • 告警插件
  1. 暂不开放

插件注册

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

开发样例

demo