本家の説明はこちら
前回の記事はこちら
今回のソースはこちら

1.依存関係追加

JUnitとvertx-unitテスト用の依存関係をpom.xmlに追加

<dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.12</version>
    <scope>test</scope>
</dependency>
<dependency>
    <groupId>io.vertx</groupId>
    <artifactId>vertx-unit</artifactId>
    <version>3.1.0</version>
    <scope>test</scope>
</dependency>

追加後libraryを更新[Maven Project パネルより->Reimport all maven projectsを実施]

2.テストソース

以下ソースをsrc/test/java/tutorial/vertx/HelloVerticleTest.javaに生成

/**
 * Created by bhags on 15/11/08.
 */

package tutorial.vertx;
import io.vertx.core.Vertx;
import io.vertx.ext.unit.Async;
import io.vertx.ext.unit.TestContext;
import io.vertx.ext.unit.junit.VertxUnitRunner;

import io.vertx.core.logging.LoggerFactory;
import io.vertx.core.logging.Logger;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;

@RunWith(VertxUnitRunner.class)
public class HelloVerticleTest {

    private Vertx vertx;
    private final static Logger log = LoggerFactory.getLogger(HelloVerticleTest.class);
    @Before
    public void setUp(TestContext context) {
        log.info("SETUP");
        vertx = Vertx.vertx();
        vertx.deployVerticle(HelloVerticle.class.getName(),
                context.asyncAssertSuccess());
    }

    @After
    public void tearDown(TestContext context) {
        log.info("TEAR DOWN");
        vertx.close(context.asyncAssertSuccess());
    }

    @Test
    public void testMyApplication(TestContext context) {
        log.info("TEST MY APPLICATION");
        final Async async = context.async();

        vertx.createHttpClient().getNow(8080, "localhost", "/",
                response -> {
                    response.handler(body -> {
                        context.assertTrue(body.toString().contains("Hello"));
                        async.complete();
                    });
                });
    }
}

3.TEST 実行

mvn clean test

4.JUnit テスト Methods

以上でHelloVeticleの JUnit テストが無事完了した。上記のunitテストはvertx-unitを使っていてcustom runnerを利用している。vertx-unitのおかげでvert.xアプリケージョンの非同期動作を簡単にテストできるようになっている。

setUp

setup methodではvertxのインスタンスが生成される。そして、HelloVeticle verticleデプロイしてくれる。また、setUpがTestContextを引数として取っている。このオブジェクトがテストの非同期面をコントロール可能にしてくれている。例えばverticleをデプロイするとそれは非同期で実行されるためそれが正しく実行されるまでプログラム側でチェックすることはできない。そのためdeployVerticleメソッドの2番目の引数としてresult handlerを渡している。それがcontext.axyncAssertSuccess();である。これはverticleが正しく実行されなければ失敗を返す。さらにこれはverticleのstart シーケンスが終了することを待ってくれる。実際にはHelloVerticleのfut.complete()を待つのである。

tearDown

tearDownでは単純に生成されたvertx instanceを終了している。

testMyApplication

このメソッドは実際にリクエストを発行し結果をチェックしている。リクエストの発行および結果の取得はもちろん非同期である。これらを制御するためにTestContextを利用する。このオブジェクトのasync.complete()を利用することでいつテストが終わるのかを制御できる。

つまり、async handleが生成されるとgetNow()メソッドを利用してHTTPクライアントを作成し,また、テストアプリケージョンによって管理されるhttpリクエストを発行することができる(getNow() は　get(…).end() のショートカット)。リクエストの結果はlambdaで管理されbodyの中にHelloがあるかを確認している。

context.assert…はエラーが発生した段階ですぐにテストを中止し、エラーを出力する。非同期のVert.xアプリケージョンでのテストは常にassertionメッソドを利用する必要がある。

まず、今回のソースコードはこちら

0.開発環境

• Mac OS  X
• java 1.8 以上
• IntelliJ 14.

1 : IntelliJでmaven新規プロジェクト作成

1. File ->New -> Project
2. Mavenを選択しNext
   
3. maven project 設定
   • GroupId : totorial.vertx
   • ArtifactId : hello-verticle
   • Version : 1.0-SNAPSHOT
4. Project name / location
   • name : hello-virticle
   • location : すきなところへ

2 : pom.xml に依存関係を追加

以下の依存関係およびbuildをpom.xml のversionの下に追加

<dependencies>
    <dependency>
        <groupId>io.vertx</groupId>
        <artifactId>vertx-core</artifactId>
        <version>3.1.0</version>
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <artifactId>maven-compiler-plugin</artifactId>
            <version>3.3</version>
            <configuration>
                <source>1.8</source>
                <target>1.8</target>
            </configuration>
        </plugin>
    </plugins>
</build>

Maven Project Windowより[Reimport All Maven Projects]を実行

3.Hello Verticle

HelloVerticle 作成

package tutorial.vertx;

import io.vertx.core.AbstractVerticle;
import io.vertx.core.Future;
/**
 * Created by bhags on 15/11/07.
 */
public class HelloVerticle extends AbstractVerticle {

    @Override
    public void start(Future<Void> fut) {
        vertx
                .createHttpServer()
                .requestHandler(r -> {
                    r.response().end(
                            "<h1>Hello Verticle!!! "</h1>");
                })
                .listen(8080, result -> {
                    if (result.succeeded()) {
                        fut.complete();
                    } else {
                        fut.fail(result.cause());
                    }
                });
    }
}

まず、HelloVerticleは AbstractVerticleを継承している。Vert.xの世界では 全てのverticleはコンポーネントである。AbstractVerticleを継承することでHelloVerticleよりvertxフィールドを取得することができる。

startメソッドはverticleがデプロイされると呼び出される。stopメソッドの実装も必要だがここではVert.xが代わりにGCを行ってくれる。また、startメッソドはFutureオブジェクトを受け取る。Futureメッソドはstartシーケンスの無事終わったか、エラーが発生したかなどをVert.x側に教えられる。Vert.xの特徴の一つとして非同期/non-blockingがある。verticleがデプロイされるとverticleはstart methodの終了を待たない。だからFutureパラメータの終了通知が大事である。

このHelloVerticleのstartではHTTPサーバーを生成しリクエストハンドラーをアタッチしている。request handlerはlambda式でrequestHandlerへ伝達されている。最後にサーバーは8080ポートにバウンドされポートのバウンドに問題なければfut.complete()を問題があれば(8080が使われているなど)fut.fail(失敗)を通知する。

4:Create fatjar

pom.xmlに以下ソースを追加

<plugin>
    <groupId>org.apache.maven.plugins</groupId>
    <artifactId>maven-shade-plugin</artifactId>
    <version>2.3</version>
    <executions>
        <execution>
            <phase>package</phase>
            <goals>
                <goal>shade</goal>
            </goals>
            <configuration>
                <transformers>
                    <transformer
                            implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
                        <manifestEntries>
                            <Main-Class>io.vertx.core.Launcher</Main-Class>
                            <Main-Verticle>tutorial.vertx.HelloVerticle</Main-Verticle>
                        </manifestEntries>
                    </transformer>
                </transformers>
                <artifactSet/>
                <outputFile>${project.build.directory}/${project.artifactId}-${project.version}-fat.jar</outputFile>
            </configuration>
        </execution>
    </executions>
</plugin>

Run/Debug Configurationsでmaven実行configurationを追加 (Command line : clean package)

5:結果確認

targetに生成されたhello-verticle-1.0-SNAPSHOT-fat.jarを実行

java -jar /path/to/fatjar/hello-verticle-1.0-SNAPSHOT-fat.jar

*以下が表示されれば
11 07, 2015 10:31:44 午後 io.vertx.core.impl.launcher.commands.VertxIsolatedDeployer
情報: Succeeded in deploying verticle

http://127.0.0.1:8080へアクセス後以下が表示されればOK

Hello Verticle!!!

[Tutorial]
1.pom.xmlに以下のService Factory Dependencyを追加

<dependency>
  <groupId>io.vertx</groupId>
  <artifactId>vertx-service-factory</artifactId>
  <version>3.0.0</version>
</dependency>

ServiceFactoryはservice nameを元にverticleをdeployするためのVeticleFactoryの実装

2.First Sample Service – Serviceが呼び出されたら”This is my test service”を出力

package biz.playport.vertx.services;
import io.vertx.core.AbstractVerticle;
import io.vertx.core.logging.Logger;
import io.vertx.core.logging.LoggerFactory;

/**
 * Created by bhags on 15/11/07.
 */
public class FirstServiceVerticle extends AbstractVerticle {
    private final static Logger log = LoggerFactory.getLogger(FirstServiceVerticle.class);

    @Override
    public void start(){
        log.info("This is my test service");
    }

}

3.Serviceを呼び側

参考URL

https://github.com/vert-x3/vertx-service-factory

https://groups.google.com/forum/?hl=ja#!searchin/vertx/Service/vertx/vezlmH-H4NI/uBe9iM5Z1U8J

http://qiita.com/p-baleine@github/items/d26999fe42ace182aca1

Vert.x

To do list -
1.Vert.x用 + message pack用のjava socket libraryを構築
2.multi port를 쓰는것이 좋은가?

3.vertx에서
서비스 만들기
서비스 쓰기
서비스 프록시 쓰기
Vert.x 3 Tutorials
1. Start with maven
To run with maven
mvn compile exec:java

To build a “fat jar”
mvn package

To run the fat jar:
java -jar target/maven-simplest-3.1.0-fat.jar

>>(You can take that jar and run it anywhere there is a Java 8+ JDK. It contains all the dependencies it needs so you don’t need to install Vert.x on the target machine).

1.