activej下載 - activej源代碼下載

activej

網站數據

1.0.0

下載

介紹

ActiveJ是一個從頭開始建造的現代Java平台。它旨在自給自足（沒有第三方依賴性），簡單，輕巧，並提供競爭性能。 ActiveJ由一系列正交庫組成，從依賴注入和高性能異步I/O（由Node.js啟發）到應用程序服務器和大數據解決方案。

這些庫相對於彼此具有盡可能少的依賴關係，並且可以一起使用或分別使用。 ActiveJ在不是另一個框架中迫使用戶在全有或全無的基礎上使用它，但是它可以為用戶提供盡可能多的自由，以選擇特定任務的庫組件。

ActiveJ組件

ActiveJ由幾個模塊組成，可以將其分組為以下類別：

異步- 高性能異步IO，具有有效的事件循環，Nio，Promises，Promises，Streaming和CSP。替代Netty，Rxjava，Akka等。（Promise，Eventloop，Net，CSP，DataStream）

 // Basic eventloop usage
public static void main ( String [] args ) {
    Eventloop eventloop = Eventloop . create ();

    eventloop . post (() -> System . out . println ( "Hello, world!" ));

    eventloop . run ();
}

 // Promise chaining
public static void main ( String [] args ) {
    Eventloop eventloop = Eventloop . builder ()
        . withCurrentThread ()
        . build ();

    Promises . delay ( Duration . ofSeconds ( 1 ), "world" )
        . map ( string -> string . toUpperCase ())
        . then ( string -> Promises . delay ( Duration . ofSeconds ( 3 ))
            . map ( $ -> "HELLO " + string ))
        . whenResult ( string -> System . out . println ( string ));

    eventloop . run ();
}

 // CSP workflow example
ChannelSuppliers . ofValues ( 1 , 2 , 3 , 4 , 5 , 6 )
    . filter ( x -> x % 2 == 0 )
    . map ( x -> 2 * x )
    . streamTo ( ChannelConsumers . ofConsumer ( System . out :: println ));

 // Datastream workflow example
StreamSuppliers . ofValues ( 1 , 2 , 3 , 4 , 5 , 6 )
    . transformWith ( StreamTransformers . filter ( x -> x % 2 == 0 ))
    . transformWith ( StreamTransformers . mapper ( x -> 2 * x ))
    . streamTo ( StreamConsumers . ofConsumer ( System . out :: println ));

HTTP-高性能HTTP服務器和client具有WebSocket支持。它可以用作簡單的Web服務器或應用程序服務器。替代其他常規HTTP客戶和服務器。（HTTP）

 // Server
public static void main ( String [] args ) throws IOException {
    Eventloop eventloop = Eventloop . create ();

    AsyncServlet servlet = request -> HttpResponse . ok200 ()
        . withPlainText ( "Hello world" )
        . toPromise ();

    HttpServer server = HttpServer . builder ( eventloop , servlet )
        . withListenPort ( 8080 )
        . build ();

    server . listen ();

    eventloop . run ();
}

 // Client
public static void main ( String [] args ) {
    Eventloop eventloop = Eventloop . create ();

    HttpClient client = HttpClient . create ( eventloop );

    HttpRequest request = HttpRequest . get ( "http://localhost:8080" ). build ();

    client . request ( request )
        . then ( response -> response . loadBody ())
        . map ( body -> body . getString ( StandardCharsets . UTF_8 ))
        . whenResult ( bodyString -> System . out . println ( bodyString ));

    eventloop . run ();
}

ActiveJ注入- 依賴注入的輕質庫。優化用於快速應用程序啟動和運行時性能。支持基於註釋的組件接線以及無反射接線。（ActiveJ注入）

 // Manual binding
public static void main ( String [] args ) {
    Module module = ModuleBuilder . create ()
        . bind ( int . class ). toInstance ( 101 )
        . bind ( String . class ). to ( number -> "Hello #" + number , int . class )
        . build ();

    Injector injector = Injector . of ( module );

    String string = injector . getInstance ( String . class );

    System . out . println ( string ); // "Hello #101"
}

 // Binding via annotations
public static class MyModule extends AbstractModule {
    @ Provides
    int number () {
        return 101 ;
    }

    @ Provides
    String string ( int number ) {
        return "Hello #" + number ;
    }
}

public static void main ( String [] args ) {
    Injector injector = Injector . of ( new MyModule ());

    String string = injector . getInstance ( String . class );

    System . out . println ( string ); // "Hello #101"
}

啟動- 用於運行和監視ActiveJ應用程序的生產的工具。同時控制服務生命週期的依賴性。具有JMX和Zabbix支持的各種服務監視實用程序。（發射器，服務圖，JMX，觸發器）

 public class MyLauncher extends Launcher {
    @ Inject
    String message ;

    @ Provides
    String message () {
        return "Hello, world!" ;
    }

    @ Override
    protected void run () {
        System . out . println ( message );
    }

    public static void main ( String [] args ) throws Exception {
        Launcher launcher = new MyLauncher ();
        launcher . launch ( args );
    }
}

字節碼操縱

ActiveJ CodeGen-在ObjectWeb ASM庫頂上的類和方法的動態字節碼生成器。摘要直接字節碼操作的複雜性，並允許您使用類似LISP的AST表達式即時創建自定義類。（ActiveJ Codegen）

 // Manually implemented method
public class MyCounter implements Counter { 
    @ Override
    public int countSum () {
        int sum = 0 ;
        for ( int i = 0 ; i < 100 ; i ++) {
            sum += i ;
        }
        return sum ;
    }
}

 // The same method generated via ActiveJ Codegen 
public static void main ( String [] args ) {
    DefiningClassLoader classLoader = DefiningClassLoader . create ();

    Counter counter = ClassGenerator . builder ( Counter . class )
        . withMethod ( "countSum" ,
            let ( value ( 0 ), sum ->
                sequence (
                    iterate (
                        value ( 0 ),
                        value ( 100 ),
                        i -> set ( sum , add ( sum , i ))),
                    sum
                )))
        . build ()
        . generateClassAndCreateInstance ( classLoader );

    System . out . println ( counter . countSum ()); // 4950
}

ActiveJ Serializer-使用字節碼工程創建的快速和空間效率的序列化器。介紹無模式的方法以獲得最佳性能。（ActiveJ序列化器）

 // A class to be serialized
public class User {
    private final int id ;
    private final String name ;

    public User ( @ Deserialize ( "id" ) int id , @ Deserialize ( "name" ) String name ) {
        this . id = id ;
        this . name = name ;
    }

    @ Serialize
    public int getId () {
        return id ;
    }

    @ Serialize
    public String getName () {
        return name ;
    }
}

 // Serialization and deserialization
public static void main ( String [] args ) {
    BinarySerializer < User > userSerializer = SerializerFactory . defaultInstance ()
        . create ( User . class );

    User john = new User ( 1 , "John" );

    byte [] buffer = new byte [ 100 ];
    userSerializer . encode ( buffer , 0 , john );

    User decoded = userSerializer . decode ( buffer , 0 );

    System . out . println ( decoded . id );   // 1
    System . out . println ( decoded . name ); // John
}

 // Serialization of Java records
@ SerializeRecord
public record User ( int id , String name ) {
}

 // StreamCodec usage example
public static void main ( String [] args ) throws IOException {
    StreamCodec < User > userStreamCodec = StreamCodec . create ( User :: new ,
        User :: getId , StreamCodecs . ofVarInt (),
        User :: getName , StreamCodecs . ofString ()
    );

    List < User > users = List . of (
        new User ( 1 , "John" ),
        new User ( 2 , "Sarah" ),
        new User ( 3 , "Ben" )
    );

    ByteArrayOutputStream baos = new ByteArrayOutputStream ();
    try ( StreamOutput streamOutput = StreamOutput . create ( baos )) {
        for ( User user : users ) {
            userStreamCodec . encode ( streamOutput , user );
        }
    }

    ByteArrayInputStream bais = new ByteArrayInputStream ( baos . toByteArray ());
    try ( StreamInput streamInput = StreamInput . create ( bais )) {
        while (! streamInput . isEndOfStream ()) {
            User decoded = userStreamCodec . decode ( streamInput );
            System . out . println ( decoded . getId () + " " + decoded . getName ());
        }
    }
}

ActiveJ Specializer-通過將類實例自動將類實例轉換為專業靜態類和類實例字段的創新技術，以提高運行時的類表現。為靜態類提供了各種各樣的JVM優化，否則是不可能的：消除死亡代碼，積極的方法和靜態常數。（ActiveJ Specializer）

 // Operators
public record IdentityOperator () implements IntUnaryOperator {
    @ Override
    public int applyAsInt ( int operand ) {
        return operand ;
    }
}

public record ConstOperator ( int value ) implements IntUnaryOperator {
    @ Override
    public int applyAsInt ( int operand ) {
        return value ;
    }
}

public record SumOperator ( IntUnaryOperator left , IntUnaryOperator right ) implements IntUnaryOperator {
    @ Override
    public int applyAsInt ( int operand ) {
        return left . applyAsInt ( operand ) + right . applyAsInt ( operand );
    }
}

public record ProductOperator ( IntUnaryOperator left , IntUnaryOperator right ) implements IntUnaryOperator {
    @ Override
    public int applyAsInt ( int operand ) {
        return left . applyAsInt ( operand ) * right . applyAsInt ( operand );
    }
}

 // Expression specialization
public static void main ( String [] args ) {
    // ((x + 10) * (-5)) + 33
    IntUnaryOperator expression = new SumOperator (
        new ProductOperator (
            new ConstOperator (- 5 ),
            new SumOperator (
                new ConstOperator ( 10 ),
                new IdentityOperator ()
            )
        ),
        new ConstOperator ( 33 )
    );

    Specializer specializer = Specializer . create ();
    expression = specializer . specialize ( expression );

    System . out . println ( expression . applyAsInt ( 0 ));  // -17
}

雲組件

ActiveJ FS-文件系統上的異步抽象，用於構建有效的，可擴展的本地或遠程文件存儲，以支持數據冗餘，重新平衡和重新降低。（ActiveJ FS）

 public static void main ( String [] args ) throws IOException {
    Eventloop eventloop = Eventloop . builder ()
        . withCurrentThread ()
        . build ();

    HttpClient httpClient = HttpClient . create ( eventloop );

    ExecutorService executor = Executors . newCachedThreadPool ();

    Path directory = Files . createTempDirectory ( "fs" );

    FileSystem fileSystem = FileSystem . create ( eventloop , executor , directory );

    String filename = "file.txt" ;

    fileSystem . start ()
            // Upload
            . then (() -> fileSystem . upload ( filename ))
            . then ( consumer -> httpClient . request ( HttpRequest . get ( "http://localhost:8080" ). build ())
                . then ( response -> response . loadBody ())
                . then ( body -> ChannelSuppliers . ofValue ( body ). streamTo ( consumer )))

            // Download
            . then (() -> fileSystem . download ( filename ))
            . then ( supplier -> supplier . streamTo ( ChannelConsumers . ofConsumer ( byteBuf ->
                System . out . println ( byteBuf . asString ( StandardCharsets . UTF_8 )))))

            // Cleanup
            . whenComplete ( executor :: shutdown );

    eventloop . run ();
}

ActiveJ RPC-高性能二進制客戶端服務器協議。允許建築物分佈式，碎片和容忍缺陷的微服務應用。（ActiveJ RPC）

 // Server
public static void main ( String [] args ) throws IOException {
    Eventloop eventloop = Eventloop . create ();

    RpcServer server = RpcServer . builder ( eventloop )
        . withMessageTypes ( String . class )
        . withHandler ( String . class , name -> Promise . of ( "Hello, " + name ))
        . withListenPort ( 9000 )
        . build ();

    server . listen ();

    eventloop . run ();
}

 // Client
public static void main ( String [] args ) {
    Eventloop eventloop = Eventloop . create ();

    RpcClient client = RpcClient . builder ( eventloop )
        . withStrategy ( RpcStrategies . server ( new InetSocketAddress ( 9000 )))
        . withMessageTypes ( String . class )
        . build ();

    client . start ()
        . then (() -> client . sendRequest ( "John" ))
        . whenResult ( response -> System . out . println ( response )) // "Hello, John"
        . whenComplete ( client :: stop );

    eventloop . run ();
}

各種額外服務：ActiveJ CRDT，Redis客戶端，Memcache，Olap Cube，DataFlow

快速開始

將這個片段粘貼到您的終端...

 mvn archetype:generate -DarchetypeGroupId=io.activej -DarchetypeArtifactId=archetype-http -DarchetypeVersion=6.0-beta2

...並在您喜歡的IDE中打開項目。然後構建應用程序並運行它。在Localhost：8080打開您的瀏覽器，以查看“ Hello World”消息。

具有依賴項注入的全功能嵌入式Web應用程序服務器：

 public final class HttpHelloWorldExample extends HttpServerLauncher {
    @ Provides
    AsyncServlet servlet () {
        return request -> HttpResponse . ok200 ()
            . withPlainText ( "Hello, World!" )
            . toPromise ();
    }

    public static void main ( String [] args ) throws Exception {
        Launcher launcher = new HttpHelloWorldExample ();
        launcher . launch ( args );
    }
}