开源 Java 微服务应用程序框架 KivaKit 简介

C->B->A

listener.listenTo(broadcaster)

public interface Mixin{    default <T> T state(Class<? extends Mixin> type, Factory<T> factory)    {        return MixinState.get(this, type, factory);    }}

public interface RepeaterMixin extends Repeater, Mixin{    @Override    default void addListener(Listener listener, Filter<Transmittable> filter)    {        repeater().addListener(listener, filter);    }                @Override    default void removeListener(Listener listener)    {        repeater().removeListener(listener);    }    [...]        default Repeater repeater()    {        return state(RepeaterMixin.class, BaseRepeater::new);    }        }

Database database = [...]registerObject(database);[...]var database = require(Database.class);

enum Database { PRODUCTS, SERVICES }registerObject(database, Database.PRODUCTS);[...]var database = require(Database.class, Database.SERVICES);

require(DatabaseSettings.class);

require(DatabaseSettings.class, Database.PRODUCTS);

registerAllSettingsIn(Folder)registerAllSettingsIn(Package)registerSettingsObject(Object)registerSettingsObject(Object, Enum)

class = com.mycompany.database.DatabaseSettingsport  = database.production.mypna.com:3306

public class DatabaseSettings{        @KivaKitPropertyConverter(Port.Converter.class)    private Port port;        public Connection connect()    {        // Return connection to database on desired port                [...]    }}

public class MyComponent extends BaseComponent{    [...]        var resource = listenTo(packageResource("data/data.txt"));    for (var line : resource.reader().lines())    {            }}

├── MyComponent└── data    └── data.txt

public class MyMicroservice extends Server{    public static void main(final String[] arguments)    {        new MyApplication().run(arguments);    }    private MyApplication()    {        super(MyProject());    }    @Override    protected void onRun()    {        [...]    }}

public class MyProject extends Project{    private static Lazy<MyProject> project = Lazy.of(MyProject::new);    public static ApplicationExampleProject get()    {        return project.get();    }    protected ApplicationExampleProject()    {    }    @Override    public Set<Project> dependencies()    {        return Set.of(ResourceProject.get());    }}

├── MyMicroservice└── deployments    ├── development    │   ├── WebSettings.properties    │   └── DatabaseSettings.properties    └── production        ├── WebSettings.properties        └── DatabaseSettings.properties

java -jar my-microservice.jar -deployment=development [...]

-DKIVAKIT_SETTINGS_FOLDERS=/Users/jonathan/my-microservice-settings

public class MyMicroservice extends Application{    private SwitchParser<File> DICTIONARY =         File.fileSwitchParser("input", "Dictionary file")                    .required()                    .build();    @Override    public String description()    {        return "This microservice checks spelling.";    }    @Override    protected void onRun()    {        var input = get(DICTIONARY);            if (input.exists())        {            [...]        }        else        {            problem("Dictionary does not exist: $", input.path());        }    }        @Override    protected Set<SwitchParser<?>> switchParsers()    {        return Set.of(DICTIONARY);    }}

┏-------- COMMAND LINE ERROR(S) -----------   ┋ ○ Required File switch -input is missing  ┗------------------------------------------ KivaKit 1.0.0 (puffy telephone)Usage: MyApplication 1.0.0 <switches> <arguments>This microservice checks spelling.Arguments:  NoneSwitches:    Required:      -input=File (required) : Dictionary file

private SwitchParser<File> INPUT =     File.fileSwitchParser("input", "Input text file")                .required()                .build();

public Builder<T> name(String name)public Builder<T> type(Class<T> type)public Builder<T> description(String description)public Builder<T> converter(Converter<String, T> converter)public Builder<T> defaultValue(T defaultValue)public Builder<T> optional()public Builder<T> required()public Builder<T> validValues(Set<T> validValues)

public static SwitchParser.Builder<File> fileSwitchParser(String name, String description){    return SwitchParser.builder(File.class)            .name(name)            .converter(new File.Converter(LOGGER))            .description(description);}

public static class Converter extends BaseStringConverter<File>{    public Converter(Listener listener)    {        super(listener);    }    @Override    protected File onToValue(String value)    {        return File.parse(value);    }}

public interface Validatable{    /**     * @param type The type of validation to perform     * @return A {@link Validator} instance     */    Validator validator(ValidationType type);}

public class User implements Validatable{    String name;        [...]        @Override    public Validator validator(ValidationType type)    {        return new BaseValidator()        {            @Override            protected void onValidate()            {                problemIf(name == null, "User must have a name");            }        };    }}public class MyComponent extends BaseComponent{    public void myMethod()    {        var user = new User("Jonathan");        if (user.isValid(this))        {            [...]        }    }}

public class ConsoleLogger extends BaseLogger{    private Log log = new ConsoleLog();    @Override    protected Set<Log> logs()    {        return Sets.of(log);    }}public class BaseLogger implements Logger{    void onMessage(final Message message)    {        log(message);    }    public void log(Message message)     {         [...]                 for (var log : logs())        {            log.log(entry);        }    }        }public class ConsoleLog extends BaseTextLog{    private Console console = new Console();    @Override    public synchronized void onLog(LogEntry entry)    {        console.printLine(entry.message().formatted());    }}

@Overrideprotected void onRun(){    final var port = (int) get(PORT);    final var application = new MyRestApplication();    // and start up Jetty with Swagger, Jersey and Wicket.    listenTo(new JettyServer())            .port(port)            .add("/*", new JettyWicket(MyWebApplication.class))            .add("/open-api/*", new JettySwaggerOpenApi(application))            .add("/docs/*", new JettySwaggerIndex(port))            .add("/webapp/*", new JettySwaggerStaticResources())            .add("/webjar/*", new JettySwaggerWebJar(application))            .add("/*", new JettyJersey(application))            .start();}