Java Day Tokyo 2017 ダウンロード資料

Transcription

1 Java EE 8 ハンズオン GlassFish 5 EA 版を用いて Version 1.0 日本オラクル株式会社

2 Table of Contents 1.0 はじめに NetBeans と GlassFish の設定と動作確認 Servlet 4.0 アプリケーションの作成 JAX-RS 2.1 Reactive REST クライアント実行

3 1.0 はじめに Java EE 8 は Java EE 7 をベースに 3 つの新しいテーマ ( 開発生産性の向上 HTML 5 対応 クラウド対応 ) を提供し 新機能やアップデート等 リリースに向けて最終調整中です 本ハンズオン ラボでは Servlet 4.0 と JAX-RS 2.1 にフォーカスをあて 簡単なアプリケーションの構築を行い Servlet 4.0 と JAX-RS 2.1 の動きを確認して頂きます 本ハンズオン ラボは Java EE 8 に含まれる下記の技術を使用します Servlet 4.0 (JSR 369) JAX-RS 2.1 (JSR 370) なお この演習で Java コードや HTML の入力が多い部分については この PDF ファイルから随時コピー ペーストを行って下さい この PDF ファイルおよびハンズオンで使用する画像ファイルは下記よりダウンロードしてください リンクは 2017/5/31 まで有効です 必須ソフトウェア 最新の JDK 8 を入手してインストールしてください ml 下図は Java SE 8u131 のダウンロードページですが ご利用時点でリリースされている最新の Java SE 8 をご利用下さい 3

4 NetBeans 8.2 以降のバージョンを入手してインストールしてください NetBeans のダウンロードサイトより Java EE もしくは すべて のパッケージを選択し ダウンロード ボタンを押下してください GlassFish v4.1.1 がバンドルされていますが 本ハンズオンでは使用しません なお NetBeans インストール時に インストールパックとランタイムを選択するダイアログが表示されるので カスタマイズ をクリック 4

5 し GlassFish v4.1.1 と Apache Tomcat のチェックを外してください 後ほど GlassFish5 をランタイムとして追加します また 下記には NetBeans や GlassFish をインストールしないでください Program Files ディレクトリ ディレクトリ名に空白やマルチバイトが入っているディレクトリ 5

6 GlassFish 5 EA 版の Promoted ビルド glassfish-5.0-b05 を下記よりダウンロードし 任意のディレクトリに展開してください b05.zip 下記には NetBeans や GlassFish をインストールしないでください Program Files ディレクトリ ディレクトリ名に空白やマルチバイトが入っているディレクトリ GlassFish 5 EA 版を展開すると glassfish4 というフォルダが作成されますが 問題ありません 6

7 2.0 NetBeans と GlassFish の設定と動作確認 NetBeans をインストールしたのち アイコンをダブル クリックし NetBeans を起動してください 起動すると下記のような画面が表示されます ここで NetBeans のランタイムに GlassFish 5 を指定します 新しくプロジェクトを作成してください メニューから ファイル (F) 新規プロジェクト (W)... を選択してください 7

8 新規プロジェクト (W)... を選択すると下記のウィンドウが表示されます カテゴリ (C) : より Java Web を選択し プロジェクト (P): より Web アプリケーション を選択し 次 > ボタンを押下してください 次 > ボタンを押下すると下記のウィンドウが表示されます プロジェクト名 : に JavaEE8-HoL と入力して ライブラリの格納用に専用フォルダを使用 (D) にチェックを入れ 参照 (R) ボタンを押下してください 8

9 展開した GlassFish 5 内の lib フォルダを指定し 開く ボタンを押下してください glassfish4 > glassfish > lib GlassFish 5 EA 版を展開すると glassfish4 というフォルダが作成されますが 問題ありません 次 > ボタンを押下すると下記の画面が表示されます サーバー (S) の 追加 (D) ボタンを押下してください 9

10 サーバーを選択 画面で GlassFish Server を選択し 名前 (N) に GlassFish 5 EA と入力して 次 > ボタンを押下してください サーバーの場所 で 参照 (O) ボタンを押下ください 展開した GlassFish 5 の glassfish4 フォルダを指定し 選択 ボタンを押下してください GlassFish 5 EA 版を展開すると glassfish4 というフォルダが作成されますが 問題ありません 10

11 次 > ボタンを押下してください ドメインの場所 はデフォルトのまま 終了 (F) ボタンを押下してください Java EE バージョン (J) と コンテキスト パス (P): の変更は今回不要なので そのまま 次 > ボタンを押下してください 11

12 フレームワークは今回不要なので そのまま 終了 (F) ボタンを押下してください 終了 (F) ボタンを押下すると下記の画面が表示されます 12

13 新規プロジェクトを作成したので このプロジェクトを実行します プロジェクトを実行するために NetBeans のツールバーより プロジェクトを実行 (F6) ボタンを押下してください 13

14 もしくは NetBeans のメニューから 実行 (R) > プロジェクトを実行 (R) を選択し実行してください プロジェクトを実行するとブラウザが自動的に起動し デフォルトのページが表示されます 14

15 3.0 Servlet 4.0 アプリケーションの作成 本章より実装をはじめていきます 従来の Servlet API は HTTP/1.x に対応しており 単一リクエストに対し 単一レスポンスを返すアーキテクチャになっておりました この場合 例えば 同一クライアントから大量の HTTP リクエストをサーバーに投げるケースや 特定のリクエストで処理時間が長く要するケース等 後続の処理が待ち状態になり 全体としてパフォーマンスが低下しまうことがありました しかし HTTP/2 では この問題点を改善するために 単一コネクションで リクエストとレスポンスを多重化できるようになります これにより 例え一つのリクエスト処理に時間を要しても後続の処理に影響が発生しにくくなるため より効率的なデータ転送を行う事ができるようになります 本章では この HTTP/2 に対応した Servlet 4.0 の PushBuilder インターフェースを使用し Server Push の動きをご確認頂きます Server Push により クライアントリクエストを待たないレスポンスが可能となります Server Push の基本的な流れは下記のようになります このように クライアントからのリクエストの度にレスポンスを返すのではなく ( 上図の場合.css や.js ファイルを ) サーバー側からプッシュすることができます 今回は Servlet 4.0 の Server Push の動きを把握頂くため Servlet を使用して複数の画像を表示させるシンプルな Web ページを作成し 従来の HTTP/1.1 と Server Push を利用した HTTP/2 における処理の違いを確認して頂きます 15

16 まず HTTP/2 用の Server Push を実装する Servlet ファイルを作成します プロジェクトを選択し 右クリックした後 新規 サーブレット... を選択してください 選択すると 下記のウィンドウが表示されます ここで クラス名 (N): に HTTP2 を入力し パッケージ (K): に jp.co.oracle.servlets を入力した後 次 > ボタンを押下してください ボタンを押下すると下記のウィンドウが表示されます デフォルトのまま 終了 (F) ボタンを押下してください 16

17 ボタンを押下すると下記のコードが自動的に生成されます /* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools Templates * and open the template in the editor. */ package jp.co.oracle.servlets; import java.io.ioexception; import java.io.printwriter; import javax.servlet.servletexception; import javax.servlet.annotation.webservlet; import javax.servlet.http.httpservlet; import javax.servlet.http.httpservletrequest; import javax.servlet.http.httpservletresponse; /** * kenhirai = "HTTP2", urlpatterns = "/HTTP2") public class HTTP2 extends HttpServlet /** * Processes requests for both HTTP <code>get</code> and <code>post</code> * methods. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs */ protected void processrequest(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException response.setcontenttype("text/html;charset=utf-8"); try (PrintWriter out = response.getwriter()) /* TODO output your page here. You may use following sample code. */ out.println("<!doctype html>"); out.println("<html>"); 17

18 "</h1>"); out.println("<head>"); out.println("<title>servlet HTTP2</title>"); out.println("</head>"); out.println("<body>"); out.println("<h1>servlet HTTP2 at " + request.getcontextpath() + out.println("</body>"); out.println("</html>"); 以下略 上記の自動生成されたコードに 複数の画像を Server Push で表示するための PushBuilder インターフェースを実装します 下記の箇所にメソッドを追加してください ( 赤字参照 ) /* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools Templates * and open the template in the editor. */ package jp.co.oracle.servlets; import java.io.ioexception; import java.io.printwriter; import javax.servlet.servletexception; import javax.servlet.annotation.webservlet; import javax.servlet.http.httpservlet; import javax.servlet.http.httpservletrequest; import javax.servlet.http.httpservletresponse; import javax.servlet.http.pushbuilder; /** * kenhirai = "HTTP2", urlpatterns = "/HTTP2") public class HTTP2 extends HttpServlet /** * Processes requests for both HTTP <code>get</code> and <code>post</code> * methods. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs */ protected void processrequest(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException response.setcontenttype("text/html;charset=utf-8"); try (PrintWriter out = response.getwriter()) PushBuilder = request.newpushbuilder(); if (!= null) 18

19 code. */.path("./images/1.png").path("./images/2.png").path("./images/3.png").path("./images/4.png").path("./images/5.png").path("./images/6.png").path("./images/7.png").path("./images/8.png").path("./images/9.png").path("./images/10.png").path("./images/11.png").path("./images/12.png").path("./images/13.png").path("./images/14.png").path("./images/15.png") /* TODO output your page here. You may use following sample out.println("<!doctype html>"); 19

20 以下略 次に Servlet で直接画像を表示するために /* TODO output your page here. You may use following sample code. */ の箇所に下記のように out.println を追加してください ( 赤字参照 ) < 前略 > PushBuilder = request.newpushbuilder(); if (!= null).path("./images/1.png") < 中略 >.path("./images/15.png") code. */ "</h1>"); /* TODO output your page here. You may use following sample out.println("<!doctype html>"); out.println("<html>"); out.println("<head>"); out.println("<title>servlet HTTP2</title>"); out.println("</head>"); out.println("<body>"); out.println("<h1>servlet HTTP2 at " + request.getcontextpath() + out.println("<img src='./images/1.png'>"); out.println("<img src='./images/2.png'>"); out.println("<img src='./images/3.png'>"); out.println("<img src='./images/4.png'>"); out.println("<img src='./images/5.png'>"); out.println("<img src='./images/6.png'>"); out.println("<img src='./images/7.png'>"); out.println("<img src='./images/8.png'>"); out.println("<img src='./images/9.png'>"); out.println("<img src='./images/10.png'>"); out.println("<img src='./images/11.png'>"); out.println("<img src='./images/12.png'>"); out.println("<img src='./images/13.png'>"); out.println("<img src='./images/14.png'>"); out.println("<img src='./images/15.png'>"); out.println("</body>"); out.println("</html>"); 以下略 20

21 修正後の全コードは下記のようになります /* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools Templates * and open the template in the editor. */ package jp.co.oracle.servlets; import java.io.ioexception; import java.io.printwriter; import javax.servlet.servletexception; import javax.servlet.annotation.webservlet; import javax.servlet.http.httpservlet; import javax.servlet.http.httpservletrequest; import javax.servlet.http.httpservletresponse; import javax.servlet.http.pushbuilder; /** * xxx = "HTTP2", urlpatterns = "/HTTP2") public class HTTP2 extends HttpServlet /** * Processes requests for both HTTP <code>get</code> and <code>post</code> * methods. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs */ protected void processrequest(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException response.setcontenttype("text/html;charset=utf-8"); try (PrintWriter out = response.getwriter()) PushBuilder = request.newpushbuilder(); if (!= null).path("./images/1.png").path("./images/2.png").path("./images/3.png").path("./images/4.png").path("./images/5.png") 21

22 code. */ "</h1>");.path("./images/6.png").path("./images/7.png").path("./images/8.png").path("./images/9.png").path("./images/10.png").path("./images/11.png").path("./images/12.png").path("./images/13.png").path("./images/14.png").path("./images/15.png") /* TODO output your page here. You may use following sample out.println("<!doctype html>"); out.println("<html>"); out.println("<head>"); out.println("<title>servlet HTTP2</title>"); out.println("</head>"); out.println("<body>"); out.println("<h1>servlet HTTP2 at " + request.getcontextpath() + out.println("<img src='./images/1.png'>"); out.println("<img src='./images/2.png'>"); out.println("<img src='./images/3.png'>"); out.println("<img src='./images/4.png'>"); out.println("<img src='./images/5.png'>"); out.println("<img src='./images/6.png'>"); out.println("<img src='./images/7.png'>"); out.println("<img src='./images/8.png'>"); out.println("<img src='./images/9.png'>"); out.println("<img src='./images/10.png'>"); out.println("<img src='./images/11.png'>"); out.println("<img src='./images/12.png'>"); out.println("<img src='./images/13.png'>"); out.println("<img src='./images/14.png'>"); 22

23 out.println("<img src='./images/15.png'>"); out.println("</body>"); out.println("</html>"); // <editor-fold defaultstate="collapsed" desc="httpservlet methods. Click on the + sign on the left to edit the code."> /** * Handles the HTTP <code>get</code> method. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs protected void doget(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException processrequest(request, response); /** * Handles the HTTP <code>post</code> method. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs protected void dopost(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException processrequest(request, response); /** * Returns a short description of the servlet. * a String containing servlet description public String getservletinfo() return "Short description"; // </editor-fold> 23

24 次に Server Push を使わず HTTP/1.1 で画像表示をする Servlet ファイルを作成します 同様に プロジェクトを選択し 右クリックした後 新規 サーブレット... を選択します 選択すると 下記のウィンドウが表示されます ここで クラス名 (N): に HTTP1 を入力し パッケージ (K): に jp.co.oracle.servlets を入力した後 次 > ボタンを押下してください ボタンを押下すると下記のウィンドウが表示されます デフォルトのまま 終了 (F) ボタンを押下してください 24

25 ボタンを押下すると下記のコードが自動的に生成されます /* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools Templates * and open the template in the editor. */ package jp.co.oracle.servlets; import java.io.ioexception; import java.io.printwriter; import javax.servlet.servletexception; import javax.servlet.annotation.webservlet; import javax.servlet.http.httpservlet; import javax.servlet.http.httpservletrequest; import javax.servlet.http.httpservletresponse; /** * kenhirai = "HTTP1", urlpatterns = "/HTTP1") public class HTTP1 extends HttpServlet /** * Processes requests for both HTTP <code>get</code> and <code>post</code> * methods. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs */ protected void processrequest(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException response.setcontenttype("text/html;charset=utf-8"); try (PrintWriter out = response.getwriter()) /* TODO output your page here. You may use following sample code. */ 25

26 "</h1>"); out.println("<!doctype html>"); out.println("<html>"); out.println("<head>"); out.println("<title>servlet HTTP1</title>"); out.println("</head>"); out.println("<body>"); out.println("<h1>servlet HTTP1 at " + request.getcontextpath() + out.println("</body>"); out.println("</html>"); 以下略 Servlet で直接画像を表示するために /* TODO output your page here. You may use following sample code. */ の箇所に下記のように out.println を追加してください ( 赤字参照 ) < 前略 > protected void processrequest(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException response.setcontenttype("text/html;charset=utf-8"); try (PrintWriter out = response.getwriter()) /* TODO output your page here. You may use following sample code. */ out.println("<!doctype html>"); out.println("<html>"); out.println("<head>"); out.println("<title>servlet HTTP1</title>"); out.println("</head>"); out.println("<body>"); out.println("<h1>servlet HTTP1 at " + request.getcontextpath() + "</h1>"); out.println("<img src='./images/1.png'>"); out.println("<img src='./images/2.png'>"); out.println("<img src='./images/3.png'>"); out.println("<img src='./images/4.png'>"); out.println("<img src='./images/5.png'>"); out.println("<img src='./images/6.png'>"); out.println("<img src='./images/7.png'>"); out.println("<img src='./images/8.png'>"); out.println("<img src='./images/9.png'>"); out.println("<img src='./images/10.png'>"); out.println("<img src='./images/11.png'>"); out.println("<img src='./images/12.png'>"); out.println("<img src='./images/13.png'>"); out.println("<img src='./images/14.png'>"); out.println("<img src='./images/15.png'>"); out.println("</body>"); out.println("</html>"); 26

27 以下略 修正後の全コードは下記のようになります /* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools Templates * and open the template in the editor. */ package jp.co.oracle.servlets; import java.io.ioexception; import java.io.printwriter; import javax.servlet.servletexception; import javax.servlet.annotation.webservlet; import javax.servlet.http.httpservlet; import javax.servlet.http.httpservletrequest; import javax.servlet.http.httpservletresponse; /** * xxx = "HTTP1", urlpatterns = "/HTTP1") public class HTTP1 extends HttpServlet /** * Processes requests for both HTTP <code>get</code> and <code>post</code> * methods. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs */ protected void processrequest(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException response.setcontenttype("text/html;charset=utf-8"); try (PrintWriter out = response.getwriter()) /* TODO output your page here. You may use following sample code. */ out.println("<!doctype html>"); out.println("<html>"); out.println("<head>"); out.println("<title>servlet HTTP1</title>"); out.println("</head>"); out.println("<body>"); out.println("<h1>servlet HTTP1 at " + request.getcontextpath() + "</h1>"); out.println("<img src='./images/1.png'>"); out.println("<img src='./images/2.png'>"); out.println("<img src='./images/3.png'>"); out.println("<img src='./images/4.png'>"); out.println("<img src='./images/5.png'>"); out.println("<img src='./images/6.png'>"); out.println("<img src='./images/7.png'>"); out.println("<img src='./images/8.png'>"); 27

28 out.println("<img src='./images/9.png'>"); out.println("<img src='./images/10.png'>"); out.println("<img src='./images/11.png'>"); out.println("<img src='./images/12.png'>"); out.println("<img src='./images/13.png'>"); out.println("<img src='./images/14.png'>"); out.println("<img src='./images/15.png'>"); out.println("</body>"); out.println("</html>"); // <editor-fold defaultstate="collapsed" desc="httpservlet methods. Click on the + sign on the left to edit the code."> /** * Handles the HTTP <code>get</code> method. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs protected void doget(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException processrequest(request, response); /** * Handles the HTTP <code>post</code> method. * request servlet request response servlet response ServletException if a servlet-specific error occurs IOException if an I/O error occurs protected void dopost(httpservletrequest request, HttpServletResponse response) throws ServletException, IOException processrequest(request, response); /** * Returns a short description of the servlet. * a String containing servlet description public String getservletinfo() return "Short description"; // </editor-fold> ここまでで HTTP/1.1 と Server Push を使用した HTTP/2 それぞれで画像表示をする Servlet が作成できました 次に Servlet で表示する画像ファイルを配置します 事前にダウンロードして頂いた JavaEE8-HoL-images.zip を展開してください 展開してできた images フォルダを エクスプローラーから JavaEE8- HoL 内の Web ページ にドラッグ & ドロップで配置してください 28

29 まだダウンロードされていない場合は 下記よりダウンロードしてください imgaes フォルダ横の + アイコンを押下すると 画像ファイルが正しく配置できたことを確認できます 最後に自動的に作成された Index.html を下記のコードに置き換えてください <!DOCTYPE html> <!-- To change this license header, choose License Headers in Project Properties. To change this template file, choose Tools Templates and open the template in the editor. --> <html> <head> <title>servlet4.0</title> <meta charset="utf-8"> <meta name="viewport" content="width=device-width, initialscale=1.0"> </head> <body> <div>servlet4.0 HandsOn</div> <br> <div><a href=" HoL/HTTP1"><strong>HTTP1</strong></a></div> <br> <div><a href=" HoL/HTTP2"><strong>HTTP2</strong></a></div> </body> </html> 29

30 実装した後 NetBeans のプロジェクトを実行してください 図 40:NetBeans プロジェクトの実行 プロジェクトを実行すると下記の画面が表示されます HTTP1 と HTTP2 のリンクをクリックすると それぞれ作成した Servlet にアクセスできます それぞれのリンクをクリックし 開発者ツールのネットワーク監視で応答の違いをご確認ください ネットワーク監視は FireFox の場合 メニューの 開発ツール から ネットワーク を選択するとページ下部に表示されます 30

31 Chrome の場合 メニューアイコンの その他のツール から デベロッパーツール を押下し Network タブを開いてください 開発者ツールが表示されたら 開発 設定 ボタンを押下して キャッシュを無効化してください Chrome の場合は Disable Cache にチェックを入れます 31

32 ページを再読み込みして 結果を確認してください ブラウザによる違いはありますが 1 つのリクエストごとに 1 つのレスポンスを返している HTTP/1.1 と html のレスポンスを返すときに画像ファイルをまとめてプッシュしている HTTP/2 で応答が違うことが確認できます 下記に Chrome と FireFox の例を示します Chrome HTTP/1.1 HTTP/2 32

33 FireFox HTTP/1.1 HTTP/2 33

34 4.0 JAX-RS 2.1 Reactive REST クライアント実行 ハンズオン概要 本ハンズオンで参照するコードは以下の GitHub 上にアップされたコードです (git tag: beforehandson) son ハンズオンを完了したときの状態のコードは以下の URL にありますので 必要に応じて参考にしてください (git tag: afterhandson) on これらのハンズオンのコードは 下記 URL にある JAX-RS のリファレンス実装である Jersey の GitHub リポジトリ上のサンプルコードをベースにしており 本ハンズオン向けに一部コードを省略しています ( 今回の GlassFish に含まれている Jersey と同じバージョンのタグ番号 2.26-b02 のサンプルを使います ) アプリケーション構成について 34

35 ハンズオンプロジェクトの作成 新たにこれ以降のハンズオン用の新規の NetBeans プロジェクトを作成します メニューから ファイル (F) 新規プロジェクト (W)... を選択してください 表示される下記ウィンドウのカテゴリから Java Web を選択し さらにプロジェクトから Web アプリケーション を選択し 次 > を押してください 次に表示される下記ウィンドウの プロジェクト名 をここでは JavaEE8-JaxRS として設定します 前回のプロジェクトと同様に ライブラリ フォルダを今回インストールした GlassFish 5 内の lib フォルダを指定し 次 > を押してください 35

36 次に表示される下記ウィンドウの サーバー は前回のプロジェクトで作成した GlassFish 5 EA が設定されていることを確認します コンテキスト パスは URL パスを簡単にするために今回は /jaxrs21 とし 次 > を押してください 次に表示される下記ウィンドウのフレームワークは使わないので そのまま 終了 を押してください 36

37 プロジェクトへのライブラリの追加 この章のハンズオンで利用するライブラリは以下の通りです RxJava 今回のハンズオンで利用するリアクティブプログラミングのフレームワーク Jersey Reactive Client- RXJava provider JAX-RS の Reactive Client で RxJava を利用するための拡張 jersey-server.jar と jersey-guava.jar 今回のプロジェクトの REST サーバー側の実装に使用しているライブラリです JAX-RS Reactive Client とは直接は関係ありません 今回のハンズオンで利用する RxJava( バージョン 1) のライブラリ JAR ファイルを以下のサイトよりダウンロードして 自身の PC の任意のフォルダに保存してください 37

38 さらに JAX-RS の Reactive REST クライアントから RxJava を組み込むための JAX-RS の拡張実装のライブラリ (Jersey Reactive Client- RXJava provider) もダウンロードしてください RxJava と拡張ライブラリのバージョンの組み合わせ ( rxjava 1.25 と jersey-rx-client-rxjava 2.26-b02) は 必ずここで指定したものを本ハンズオンでは使用してください 組み合わせバージョンが異なると プロジェクトのコンパイルでエラーとなる場合があります 以降の手順で ダウンロードしたライブラリをプロジェクトで利用できるように設定します プロジェクトを右クリックし メニューから プロパティ を選択してください 38

39 -> 表示される下記ウィンドウのカテゴリの ソース では ソースバイナリ形式が JDK8 に設定されていることをまず確認してください 次に カテゴリから ライブラリ を選択し ライブラリの追加 ボタンを押してください 次に表示されるウィンドウで 作成 ボタンを押し ライブラリ名として rxjava と入力して OK を押してください 39

40 JAR/ フォルダの追加 を押してください さきほどダウンロードした rxjava jar を選択して JAR/ フォルダの追加 ボタンを押してください 40

41 以下のようなダイアログが表示されますので はい を押してください その後 もう一つの jar ファイル jersey-rx-client-rxjava b02.jar を選択して同様に追加してください その後 戻った下記ウィンドウの OK ボタンを押してください 41

42 OK ボタン後に下記のウィンドウに戻るので 先ほど追加したライブラリを選択した状態で ライブラリの追加 を押してください 2 つめのライブラリを登録するので もう一度 ライブラリの追加 ボタンを押してください 42

43 作成 ボタンを押し ライブラリ名を jersey-libs とし OK を押してください JAR/ ライブラリの追加 ボタンを押してください 43

44 今回は glassfish/modules フォルダ (lib フォルダと同階層のフォルダです ) にある jersey-guava.jar と jersey-server.jar を追加してください 以下のように 2 つの jar を設定したら OK ボタンを押してください 44

45 OK 押し後に戻ったウィンドウでは さきほど作成した jerseylibs を選択した上で ライブラリの追加 ボタンを押してください 以下のように 2 つのライブラリ ( 中には計 4 つの jar ファイル ) が登録されたら OK を押して ライブラリの登録は終了となります 45

46 REST サーバーの作成 以下の GitHub の URL より今回のハンズオンのサンプルコードをダウンロードしてください ダウンロードした zip ファイルを任意の場所に解凍し 中に含まれる src\java のディレクトリ配下の org フォルダをプロジェクトのソース パッケージへコピーペーストしてください -> その後 プロジェクトを右クリックし デプロイ を実行してください 46

47 デプロイが成功したのち 以下の URL をブラウザのアドレスバーに入力し JSON 形式のデータが返ってくることを確認してください 実際のブラウザ画面での JSON 文字列は整形されていません 以降も本ドキュメント内では見やすいように結果は整形している場合があります [ "destination": "Zambia", "destination": "Kiribati", "destination": "Japan", "destination": "Saudi Arabia", "destination": "Palau" ] [ "destination": "Greece", "destination": "Malta", "destination": "Benin", "destination": "Sweden", "destination": "Uganda" ] 47

48 <forecast> <destination> Tokyo </destination> </forecast> <forecast> Partly Sunny </forecast> <calculation> <from> Moon </from> <price> 1680 </price> <to> Tokyo </to> </calculation> JAX-RS sync client の作成 リアクティブな JAX-RS クライアントとの対比のために最初にベーシックな同期型の JAX-RS クライアントを作成します プロジェクトを右クリックし 新規の Java パッケージを作成してください パッケージ名は org.glassfish.jersey.examples.rx.agent とします 次に 作成したパッケージ org.glassfish.jersey.examples.rx.agent を右クリックし 新規の Java クラスを作成してください 48

49 クラス名に SyncAgentResource と入力し 終了 ボタンを押してください クラス作成後 以下の赤字の部分のコードを追加してください package org.glassfish.jersey.examples.rx.agent; import javax.ws.rs.get; import javax.ws.rs.path; import javax.ws.rs.produces; public class public AgentResponse sync() final long time = System.nanoTime(); final AgentResponse response = new AgentResponse(); response.setprocessingtime((system.nanotime() - time) / ); return response; コード変更を保存すると 自動的に変更がデプロイされます 以下の URL にブラウザからアクセスし 現段階の実行結果を確認してください ここでは単に空の AgentResponse のオブジェクトを JSON として返却しているだけです 実行結果の例 "processingtime":0,"visited":[] 49

50 次に 以下の赤字のコードを先ほどの SyncAgentResource クラスのソースに追加で挿入してください import java.util.list; import javax.ws.rs.get; import javax.ws.rs.path; import javax.ws.rs.produces; import org.glassfish.jersey.examples.rx.domain.agentresponse; import javax.ws.rs.client.client; import javax.ws.rs.client.clientbuilder; import javax.ws.rs.client.webtarget; import javax.ws.rs.core.generictype; import org.glassfish.jersey.examples.rx.domain.destination; ( 省略 ) public class SyncAgentResource final private Client client = ClientBuilder.newClient(); final private WebTarget destination = public AgentResponse sync() final long time = System.nanoTime(); final AgentResponse response = new AgentResponse(); final List<Destination> visited = destination.path("visited").request() // Identify the user..header("rx-user", "Sync") // Return a list of destinations.get(new GenericType<List<Destination>>() ); ( 省略 ) response.setvisited(visited); コードの保存により変更がデプロイされるので 以下の URL の実行結果を確認してください REST サーバーから Destination の情報を取得できるようになりました 実行結果の例 "processingtime":548,"visited":["destination":"botswana","destina tion":"spain","destination":"lesotho","destination":"iceland"," destination":"venezuela"] 次に 以下の赤字のコードを同じクラスに追加してください Recommend のデータを REST サーバーより取得するコードです ( 省略 ) response.setvisited(visited); // Obtain recommended destinations. (does not depend on visited ones) final List<Destination> recommended = destination.path("recommended").request() // Identify the user..header("rx-user", "Sync") // Return a list of destinations..get(new GenericType<List<Destination>>() ); 50

51 ( 省略 ) response.setprocessingtime((system.nanotime() - time) / ); そのまま次に 以下の赤字のコードを挿入してください Recommend の destintion データ毎に forecast データを REST サーバーに繰り返し問い合わせています import org.glassfish.jersey.examples.rx.domain.forecast; import java.util.arraylist; final private WebTarget destination = client.target(" final private WebTarget forecast = client. target(" ("remote/forecast/destination"); ( 省略 ) final List<Destination> recommended = ( 省略 ) // Forecasts. (depend on recommended destinations) final List<Forecast> forecasts = new ArrayList<>(recommended.size()); for (final Destination dest : recommended) forecasts.add(forecast.resolvetemplate("destination", dest.getdestination()).request().get(forecast.class)); response.setprocessingtime((system.nanotime() - time) / ); o <calculation><from>moon</from><price>6482</price><to>morroco</to></ca lculation> <calculation><from>moon</from><price>8239</price><to>cyprus</to></cal culation> そのまま次に 以下の赤字のコードを挿入してください Recommend の destintion データ毎に Moon からその destination までのコストを REST サーバーに繰り返し問い合わせています import org.glassfish.jersey.examples.rx.domain.calculation; final private WebTarget destination = client.target(" final private WebTarget forecast = client. target(" ("remote/forecast/destination"); final private WebTarget calculation = client. target(" ("remote/calculation/from/from/to/to"); ( 省略 ) final List<Forecast> forecasts = new ArrayList<>(recommended.size()); for (final Destination dest : recommended) forecasts.add(forecast.resolvetemplate("destination", dest.getdestination()).request().get(forecast.class)); // Calculations. (depend on recommended destinations) 51

52 final List<Calculation> calculations = new ArrayList<>(recommended.size()); for (final Destination dest : recommended) calculations.add(calculation.resolvetemplate("from", "Moon").resolveTemplate("to", dest.getdestination()).request().get(calculation.class)); response.setprocessingtime((system.nanotime() - time) / ); 最後に以下のコードを追加し レスポンスとしてセットしてます import org.glassfish.jersey.examples.rx.domain.recommendation; ( 省略 ) final List<Calculation> calculations = new ArrayList<>(recommended.size()); for (final Destination dest : recommended) calculations.add(calculation.resolvetemplate("from", "Moon").resolveTemplate("to", dest.getdestination()).request().get(calculation.class)); // Recommendations. final List<Recommendation> recommendations = new ArrayList<>(recommended.size()); for (int i = 0; i < recommended.size(); i++) recommendations.add(new Recommendation(recommended.get(i).getDestination(), forecasts.get(i).getforecast(), calculations.get(i).getprice())); response.setrecommended(recommendations); response.setprocessingtime((system.nanotime() - time) / ); 変更をデプロイし 以下の URL の実行結果を確認してください REST サーバーから Destination の情報を取得できるようになりました REST サーバーへのリクエスト回数が何回も行われていることにより レスポンスが返るまでに時間がかかっていることがわかります 実行結果の例 "processingtime": 4700, "recommended": [ "destination": "Sao Tome & Principe", "forecast": "Overcast", "price": 785, "destination": "China", "forecast": "Chance of TStorm", "price": 3647, "destination": "Malta", "forecast": "Flurries", "price": 1636, "destination": "Algeria", "forecast": "Light Rain", "price": 4053, 52

53 "destination": "St. Kitts & Nevis", "forecast": "Thunderstorm", "price": 2460 ], "visited": [ "destination": "Botswana", "destination": "Spain", "destination": "Lesotho", "destination": "Iceland", "destination": "Venezuela" ] JAX-RS reactive client の作成 ここではさきほどの JAX-RS sync client と同等の処理を JAX-RS reactive client に代え 違いを確認していきます 前回と同様のパッケージ配下に新規の Java クラスを作成します クラス名前は ObservableAgentResource としてください クラスを新規作成後 以下の赤字のコードを挿入してください package org.glassfish.jersey.examples.rx.agent; import javax.ws.rs.path; import javax.ws.rs.produces; import javax.inject.singleton; import javax.ws.rs.get; import javax.ws.rs.container.asyncresponse; import javax.ws.rs.container.suspended; @Produces("application/json") public class public void observable(@suspended final AsyncResponse async) 53

54 final long time = System.nanoTime(); final AgentResponse agentresponse = new AgentResponse(); async.resume(agentresponse); 変更をデプロイし 以下の URL 実行結果を確認してください ここでは空のデータを返されました 実行結果の例 "processingtime":0,"visited":[] 次の赤字のコードに置き換えてください AgentResponse オブジェクトとに実行時間のデータをセットし レスポンスを返しているだけですが RxJava を使ったリアクティブプログラミングとなっています ( 省略 ) import public void observable(@suspended final AsyncResponse async) final long time = System.nanoTime(); final AgentResponse agentresponse = new AgentResponse(); Observable.just(agentResponse).subscribe(response -> response.setprocessingtime((system.nanotime() - time) / ); async.resume(response); ); 変更をデプロイし 以下の URL 実行結果を確認してください 実行時間がセットされたことがわかります 実行結果の例 "processingtime":164,"visited":[] 次に リアクティブプログラミングで visited や recommendation のデータを取得し AgentRespons にセットしていくコードを挿入します ここではまだ REST サーバーへの問合せは含めず Destination 等のオブジェクトの取得は固定値として Reactive プログラミングによる実装部分に集中します ( 省略 ) import java.util.arraylist; import java.util.list; import public void observable(@suspended final AsyncResponse async) 54

55 final long time = System.nanoTime(); final AgentResponse agentresponse = new AgentResponse(); Observable.just(agentResponse).zipWith(visited(), (response, visited) -> response.setvisited(visited); return response; ).subscribe(response -> response.setprocessingtime((system.nanotime() - time) / ); async.resume(response); ); private Observable<List<Destination>> visited() List<Destination> visitedlist = new ArrayList<>(); visitedlist.add(new Destination("Chicago")); visitedlist.add(new Destination("New York")); return Observable.just(visitedList); 変更をデプロイし 以下の URL 実行結果を確認してください リアクティブプログラミングで visisted のデータをレスポンスに追加できました 実行結果の例 "processingtime": 149, "visited": [ "destination": "Chicago", "destination": "New York" ] 次に同じように recommended のデータを RxJava によるリアクティブプログラミングで用意して返します 以下の赤字のコードをセットしてください ( 省略 ) import org.glassfish.jersey.examples.rx.domain.calculation; import org.glassfish.jersey.examples.rx.domain.forecast; import org.glassfish.jersey.examples.rx.domain.recommendation; ( 省略 public void observable(@suspended final AsyncResponse async) final long time = System.nanoTime(); final AgentResponse agentresponse = new AgentResponse(); Observable.just(agentResponse).zipWith(visited(), (response, visited) -> response.setvisited(visited); return response; ).zipwith(recommended(), (response, recommendations) -> response.setrecommended(recommendations); return response; ).subscribe(response -> response.setprocessingtime((system.nanotime() - time) / ); 55

56 ); async.resume(response); private Observable<List<Destination>> visited() List<Destination> visitedlist = new ArrayList<>(); visitedlist.add(new Destination("Chicago")); visitedlist.add(new Destination("New York")); return Observable.just(visitedList); private Observable<List<Recommendation>> recommended() List<Destination> recommendedlist = new ArrayList<>(); recommendedlist.add(new Destination("Hawaii")); recommendedlist.add(new Destination("Tokyo")); final Observable<Destination> recommended = Observable.just(recommendedList) // Emit destinations one-by-one..flatmap(observable::from) // Remember emitted items for dependant requests..cache(); // Forecasts. (depend on recommended destinations) final Observable<Forecast> forecasts = recommended.flatmap(destination -> Observable.just(new Forecast(destination.getDestination(), "Sunny")) ); // Calculations. (depend on recommended destinations) final Observable<Calculation> calculations = recommended.flatmap(destination -> Observable.just(new Calculation("Moon", destination.getdestination(), -1)) ); return Observable.zip(recommended, forecasts, calculations, Recommendation::new).toList(); 実行結果の例 "processingtime": 182, "recommended": [ "destination": "Hawaii", "forecast": "Sunny", "price": -1, "destination": "Tokyo", "forecast": "Sunny", "price": -1 ], "visited": [ "destination": "Chicago", "destination": "New York" ] 56

57 最後に 上記で固定値としてデータを設定していたところを 実際の JAX-RS の REST Client から REST サーバーへの問合せ結果によるデータに代えます 赤字が変更点となります ( 省略 ) import javax.ws.rs.client.client; import javax.ws.rs.client.clientbuilder; import javax.ws.rs.client.webtarget; import javax.ws.rs.core.generictype; import org.glassfish.jersey.client.rx.rxjava.rxobservableinvoker; import org.glassfish.jersey.client.rx.rxjava.rxobservableinvokerprovider; ( 省略 ) public class ObservableAgentResource final private Client client = ClientBuilder.newClient(); final private WebTarget destination = client.target(" final private WebTarget forecast = client.target(" ination"); final private WebTarget calculation = client.target(" om/from/to/to"); ( 省略 ) private Observable<List<Destination>> visited() destination.register(rxobservableinvokerprovider.class); return destination.path("visited").request() // Identify the user..header("rx-user", "RxJava") // Reactive invoker..rx(rxobservableinvoker.class) // Return a list of destinations..get(new GenericType<List<Destination>>() ); private Observable<List<Recommendation>> recommended() destination.register(rxobservableinvokerprovider.class); final Observable<Destination> recommended = destination.path("recommended").request() // Identify the user..header("rx-user", "RxJava") // Reactive invoker..rx(rxobservableinvoker.class) // Return a list of destinations..get(new GenericType<List<Destination>>() ) // Emit destinations one-by-one..flatmap(observable::from) // Remember emitted items for dependant requests..cache(); forecast.register(rxobservableinvokerprovider.class); // Forecasts. (depend on recommended destinations) final Observable<Forecast> forecasts = recommended.flatmap(destination -> forecast.resolvetemplate("destination", destination.getdestination()).request().rx(rxobservableinvoker.class).get(forecast.class) 57

58 ); calculation.register(rxobservableinvokerprovider.class); // Calculations. (depend on recommended destinations) final Observable<Calculation> calculations = recommended.flatmap(destination -> calculation.resolvetemplate("from", "Moon").resolveTemplate("to", destination.getdestination()).request().rx(rxobservableinvoker.class).get(calculat ion.class) ); return Observable.zip(recommended, forecasts, calculations, Recommendation::new).toList(); の実行結果の例 "processingtime": 1375, "recommended": [ "destination": "Dominica", "forecast": "Rain", "price": 8696, "destination": "Cape Verde", "forecast": "Sunny", "price": 1731, "destination": "Chad", "forecast": "Flurries", "price": 8800, "destination": "Portugal", "forecast": "Mostly Cloudy", "price": 8045, "destination": "Algeria", "forecast": "Sunny", "price": 8227 ], "visited": [ "destination": "Central African Republic", "destination": "Malawi", "destination": "Ethiopia", "destination": "Cambodia", "destination": "Russia" ] 58

59 まとめ 同期型の実行と比べ リアクティブは並列で REST リクエストを発行しており 実行時間が短縮されていることがわかります JAX-RS の Invocation.Builder に新しく rx メソッドが追加され これにより REST のレスポンスを今回の場合は RxJava の Observable 型オブジェクトとして受け取ることができるようになりました final Observable<Destination> recommended = destination.path("recommended").request() // Identify the user..header("rx-user", "RxJava") // Reactive invoker..rx(rxobservableinvoker.class) < // Return a list of destinations..get(new GenericType<List<Destination>>() ) // Emit destinations one-by-one..flatmap(observable::from) // Remember emitted items for dependant requests..cache(); 日本オラクル株式会社 お問い合わせ :Oracle Digital 東京都港区北青山 Oracle.com/ jp Oracle.com/jp/direct C O N N E C T W I T H U S facebook.com/oraclejp twitter.com/oracle oracle.com/jp/ 本カタログの情報は 2017 年 5 月現在のものです 実際の製品とは内容が異なる場合があります *Oracle と Java は Oracle Corporation およびその子会社 関連会社の米国およびその他の国における登録商標です 文中の社名 商品名等は各社の商標または登録商標である場合があります Copyright 2017, Oracle and/or its affiliates. All rights reserved. 59