ユニットテストJava Sparkマイクロフレーム

Question

Javaマイクロサービスに安らかなAPIを追加しようとしています。私は、APIを立ち上がる非常に単純なクラスを作成しました

http://sparkjava.com/documentation.html

：このため、私は火花を使用しています。そのクラスはここにある：今

public class Routes { 
    public void establishRoutes(){ 
     get("/test", (req, res) -> "Hello World"); 
     after((req, res) -> { 
      res.type("application/json"); 
     }); 

     exception(IllegalArgumentException.class, (e, req, res) -> { 
      res.status(400); 
     }); 
    } 

、誰かがhttp://localhost:4567/testを訪問することを決定したイベントでの「Hello World」を示すだろうAPIを立たなければならない（）Routes.establishRoutesを実行しています。これは実際には機能します。ハレイ！

次のステップは、コードの単体テストです。私のユニットテストは、残念ながら成功しません。スパークのドキュメンテーションは、テストのための健全な方法を詳述していないので、私が持っているものは、ネットの周りに見いだされた例からまとめられています。ここに私のJUnitテストがある：

public class TestRoutes { 
     @Before 
     public void setUp() throws Exception { 
      Routes newRoutes = new Routes(); 
      newRoutes.establishRoutes(); 
     } 

     @After 
     public void tearDown() throws Exception { 
      stop(); 
     } 

     @Test 
     public void testModelObjectsPOST(){ 

      String testUrl = "/test"; 


      ApiTestUtils.TestResponse res = ApiTestUtils.request("GET", testUrl, null); 
      Map<String, String> json = res.json(); 
      assertEquals(201, res.status); 
     } 

ここApiTestUtils.requestの背後にあるコードは）（です：

public class ApiTestUtils { 
    public static TestResponse request(String method, String path, String requestBody) { 


     try { 
      URL url = new URL("http://localhost:4567" + path); 
      HttpURLConnection connection = (HttpURLConnection) url.openConnection(); 
      connection.setRequestMethod(method); 
      connection.setDoOutput(true); 
      connection.connect(); 
      String body = IOUtils.toString(connection.getInputStream()); 
      return new TestResponse(connection.getResponseCode(), body); 
     } catch (IOException e) { 
      e.printStackTrace(); 
      fail("Sending request failed: " + e.getMessage()); 
      return null; 
     } 
    } 

    public static class TestResponse { 

     public final String body; 
     public final int status; 

     public TestResponse(int status, String body) { 
      this.status = status; 
      this.body = body; 
     } 

     public Map<String,String> json() { 
      return new Gson().fromJson(body, HashMap.class); 
     } 
    } 
} 

私はApiTestUtils.request()内connection.connect()に失敗しています。具体的には、次のエラーが表示されます。java.lang.AssertionError: Sending request failed: Connection refused

私のテストがリクエストを行おうとしたときにアプリケーションがリッスンしていないと考えられます。しかし、なぜそうなるのか分かりません。私はここで見つけるデモプロジェクトからテストコードを借り： https://github.com/mscharhag/blog-examples/blob/master/sparkdemo/src/test/java/com/mscharhag/sparkdemo/UserControllerIntegrationTest.java

はUPDATE： 私は上記のリンクの例を実行してみました。それはうまくいかない。この文脈でスパークのインスタンスを回転させるように見えるのは、私が思ったよりも難しいでしょうか？私はそうする方法を見つけようとはしていない。

Answer 1

埋め込みサーバの初期化を待っているために使用されるコードが含まれていません。 あなたのコードを試してみたのと同じ問題が発生しましたが、デバッグした後で、組み込みスパークサーバーが新しく作成されたスレッドで初期化されていることに気付きました。 （方法spark.Service#init()を参照）。 あなたのテストでやらなければならないことは、あなたはユニットテストと統合テストとの差にまで読んでください方法spark.Spark#awaitInitialization()

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

import static junit.framework.TestCase.assertEquals; 
import static spark.Spark.awaitInitialization; 
import static spark.Spark.stop; 

public class TestRoutes { 
    @Before 
    public void setUp() throws Exception { 
     Routes newRoutes = new Routes(); 
     newRoutes.establishRoutes(); 

     awaitInitialization(); 

    } 

    @After 
    public void tearDown() throws Exception { 
     stop(); 
    } 

    @Test 
    public void testModelObjectsPOST() { 

     String testUrl = "/test"; 


     ApiTestUtils.TestResponse res = ApiTestUtils.request("GET", testUrl, null); 
     assertEquals(200, res.status); 
    } 

} 

Answer 2

私はSparkを手助けすることはできませんが、マイクロサービスを書くための軽量なJavaライブラリを試してみるには、Moleculeをご覧ください。

ユニットテストと統合テストを記述するためのドキュメントと例があります。私はあなたが正しくテストしようとしているものを理解していれば、テストは次のようになります。あなたのテストケースで

HttpRequest request = new HttpRequest(4567); 
HttpResponse response = request.get("/test"); 
assertThat(response).hasStatusCode(201) 
        .hasContentType("application/json") 
        .hasBodyText("Hello World");