使用插件

在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{

3. override fun start(): Boolean {
4. println("TestPlugin is starting!")
5. return true
6. }

8. override fun stop(): Boolean {
9. println("TestPlugin is stopping!")
10. return true
11. }

13. }
1. public class TestPlugin implements Plugin {
2. @Override
3. public boolean start() {
4. System.out.println("TestPlugin is starting!");
5. return true;
6. }

8. @Override
9. public boolean stop() {
10. System.out.println("TestPlugin is starting!");
11. return true;
12. }
13. }

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

自动扫描注解

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