使用插件

在Cloudopt Next使用插件非常简单,只需要在服务器启动前增加即可。

  1. CloudoptServer.addPlugin(JooqPlugin())
  2. CloudoptServer.run(App::class.java)
  1. CloudoptServer.addPlugin(new JooqPlugin());
  2. CloudoptServer.run(App.class);

编写插件

编写一个自己的插件,只需要实现Plugin接口即可。如果在启动或者停止返回false,Cloudopt Next将会自动输出错误日志。

  1. class TestPlugin:Plugin{
  2. override fun start(): Boolean {
  3. println("TestPlugin is starting!")
  4. return true
  5. }
  6. override fun stop(): Boolean {
  7. println("TestPlugin is stopping!")
  8. return true
  9. }
  10. }
  1. public class TestPlugin implements Plugin {
  2. @Override
  3. public boolean start() {
  4. System.out.println("TestPlugin is starting!");
  5. return true;
  6. }
  7. @Override
  8. public boolean stop() {
  9. System.out.println("TestPlugin is starting!");
  10. return true;
  11. }
  12. }

我们还提供了大量的工具来帮助你更方便的开发插件。

自动扫描注解

  1. Classer.scanPackageByAnnotation(CloudoptServer.packageName, true, AutoKafka::class.java)
  2. .forEach { clazz ->
  3. println(clazz)
  4. }
  5. }

自动创建对象

  1. var obj = Beaner.newInstance<KafkaListener>(clazz)

读取配置文件

  1. var config = ConfigManager.init("test")

获取所有的路由器

  1. var controllers = CloudoptServer.controllers