LoginSignup
0
0

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?

@keniooi(keniooi)inIBM

JAX-RS の HelloWorld を LibertyとtWASでためす

Last updated at Posted at 2025-02-24

目的

LibertyとtWASのJAX-RS環境を構築して HelloWorld のような簡単なプログラムでテストします。

Libertyテスト環境の構築

用意したGitレポジトリをクローンします。

git clone http://github.com/pdprof/jaxrs.git
cd jaxrs/jaxrs-docker

Libertyのイメージをビルドして開始します。

./setup-docker.sh
./start.sh

Libertyの起動を確認します。jaxrs.clientにアクセスします。

tWASテスト環境の構築

Libetyを起動している場合には停止します。

docker stop jaxrs

tWASのイメージをビルドして開始します。

./setup-was90.sh
./was90-start.sh

Liberty, tWAS どちらかを起動しテストします。

構成済みのユーザー

tWASの管理ユーザーは

User Password
wsadmin passw0rd

になっています。Liberty はセキュリティが無効になっています。構成は以下のファイルでされています。

テストコード

実行しているHelloWorldの説明をしつつ、テストします。

JAX-RS Provider

JAX-RS Provider 側は

PdprofApplication.java
package pdprof.jaxrs;

import javax.ws.rs.ApplicationPath;
import javax.ws.rs.core.Application;

@ApplicationPath("pdprof")
public class PdprofApplication extends Application {

}

SleepService.java
package pdprof.jaxrs;

import javax.ws.rs.FormParam;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;

@Path("sleep")
public class SleepService {
    
	@GET
    public String hello() {
        return "Hello World!!";
    }
	
	@POST
    @Produces(MediaType.TEXT_PLAIN)
	public String sleep(@FormParam("time") String t) {
		int i = 10000;
		try { i = Integer.parseInt(t); } catch (Exception e) {}
		try {
			Thread.sleep(i);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		return "Sleep " + t + " milliseconds";
	}
	
}

の2つを WARにパッケージすることで動作します。

@ApplicationPath("pdprof")
@Path("sleep")
@GET

でブラウザで

にアクセスすることで

image.png

になります。

JAX-RS Client

クライアントの用意はいくつかあります。確認は以下のフォルダの javaファイルを見ます。

ここでは ReceiveClientServlet をもとに説明します。

ReceiveClientServlet.java
	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		System.out.println("*** ReceiveClientServlet START ***");
		String timeout = request.getParameter("timeout");
		String sleep = request.getParameter("sleep");
		String port = request.getParameter("port");
		try { Integer.parseInt(timeout); } catch (Exception e) { timeout = "10000";}
		try { Integer.parseInt(sleep); } catch (Exception e) { sleep = "20000";}
		try { Integer.parseInt(port); } catch (Exception e) { port = "9080";}
		String host = request.getParameter("host");
		if (host == null) { host = "localhost"; }
		ClientBuilder cb = ClientBuilder.newBuilder().register(new PdprofResponseFilter()).property("com.ibm.ws.jaxrs.client.receive.timeout", timeout);

		Client c = cb.build();
		String res = null;
		Entity<Form> entity = Entity.entity(new Form().param("time", sleep).param("method", "post"),
			    MediaType.APPLICATION_FORM_URLENCODED_TYPE);
		
		MultivaluedMap<String, Object> headers = new MultivaluedHashMap<>();
		headers.putSingle("Expect", "100-continue");
		
		try {
			res = c.target("http://"+ host + ":" + port + "/jaxrs/pdprof/sleep").request().headers(headers).post(entity, String.class);
		} catch (Exception e) {
			res = "[Error]:" + e.toString();
			System.out.println("*** ReceiveClientServlet ***");
			e.printStackTrace();
		} finally {
			c.close();
		}
		response.getWriter().append(res);

ほかのクライアントもあわせて、JAX-RSの処理として覚えておくと良いのは

ClientBuilder cb = ClientBuilder.newBuilder().register(new PdprofResponseFilter()).property("com.ibm.ws.jaxrs.client.connection.timeout", timeout);

ClientBuilder cb = ClientBuilder.newBuilder().register(new 
PdprofResponseFilter()).property("com.ibm.ws.jaxrs.client.receive.timeout", timeout);

Entity<Form> entity = Entity.entity(new Form().param("time", sleep).param("method", "post"),
			    MediaType.APPLICATION_FORM_URLENCODED_TYPE);

res = c.target("http://"+ host + ":" + port + "/jaxrs/pdprof/sleep").request().headers(headers).post(entity, String.class);
  • Connect Timeout : com.ibm.ws.jaxrs.client.connection.timeout
  • Response Timeout : com.ibm.ws.jaxrs.client.receive.timeout
  • ClientResponseFilter : PdprofResponseFilter()
  • POSTするデータの登録とリクエスト送信

やりたいことに合わせて、コードを変更します。

JAX-RS クライアントのテスト

コードの説明をしたのでテストします。LibertyやtWASが起動できていれば、http://localhost:9080/jaxrs.client/ にアクセスできます。

image.png

Connect timeout

相手先がみつからず、TCPIPの接続完了がタイムアウトするテストです。10.10.10.10 などネットワークにいないIPを指定して submit です。

image.png

[Error]:javax.ws.rs.ProcessingException: java.net.SocketTimeoutException: SocketTimeoutException invoking http://10.10.10.10:9080/jaxrs/pdprof/sleep: connect timed out

Libertyテスト時のログです。

console.log
*** ConnectClientServlet ***
[err] javax.ws.rs.ProcessingException: java.net.SocketTimeoutException: SocketTimeoutException invoking http://10.10.10.10:9080/jaxrs/pdprof/sleep: connect timed out
[err] 	at org.apache.cxf.jaxrs.client.AbstractClient.checkClientException(AbstractClient.java:632)
[err] 	at [internal classes]
[err] 	at pdprof.jaxrs.client.ConnectClientServlet.doGet(ConnectClientServlet.java:57)
[err] 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:686)
[err] 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:791)
[err] 	at com.ibm.ws.webcontainer.servlet.ServletWrapper.service(ServletWrapper.java:1260)
[err] 	at [internal classes]
[err] 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[err] 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[err] 	at java.base/java.lang.Thread.run(Thread.java:839)
[err] Caused by: 
[err] java.net.SocketTimeoutException: SocketTimeoutException invoking http://10.10.10.10:9080/jaxrs/pdprof/sleep: connect timed out
[err] 	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
[err] 	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
[err] 	at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
[err] 	at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
[err] 	at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.mapException(HTTPConduit.java:1458)
[err] 	at [internal classes]
[err] 	... 34 more
[err] Caused by: 
[err] java.net.SocketTimeoutException: connect timed out
[err] 	at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)
[err] 	at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)
[err] 	at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)
[err] 	at java.base/java.net.Socket.connect(Socket.java:609)
[err] 	at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:177)
[err] 	at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:507)
[err] 	at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:602)
[err] 	at java.base/sun.net.www.http.HttpClient.<init>(HttpClient.java:275)
[err] 	at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:374)
[err] 	at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:395)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1253)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1232)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1081)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1015)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1367)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1342)
[err] 	at org.apache.cxf.transport.http.URLConnectionHTTPConduit$URLConnectionWrappedOutputStream.setupWrappedStream(URLConnectionHTTPConduit.java:334)
[err] 	at [internal classes]
[err] 	... 41 more
*** ConnectClientServlet END ***

Receive timeout

相手先にリクエストは送信できたが、応答が戻らずにタイムアウトするテストです。Sleep time を Receive timeout より長くして submit です。hostname の調整で、tWAS環境にアクセスさせることもできます。

image.png

[Error]:javax.ws.rs.ProcessingException: java.net.SocketTimeoutException: SocketTimeoutException invoking http://localhost:9080/jaxrs/pdprof/sleep: Read timed out

Libertyテスト時のログです。

console.log
*** ReceiveClientServlet START ***
*** ReceiveClientServlet ***
[err] javax.ws.rs.ProcessingException: java.net.SocketTimeoutException: SocketTimeoutException invoking http://localhost:9080/jaxrs/pdprof/sleep: Read timed outJAX-RS
[err] 	at org.apache.cxf.jaxrs.client.AbstractClient.checkClientException(AbstractClient.java:632)
[err] 	at [internal classes]
[err] 	at pdprof.jaxrs.client.ReceiveClientServlet.doGet(ReceiveClientServlet.java:55)
[err] 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:686)
[err] 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:791)
[err] 	at com.ibm.ws.webcontainer.servlet.ServletWrapper.service(ServletWrapper.java:1260)
[err] 	at [internal classes]
[err] 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
[err] 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
[err] 	at java.base/java.lang.Thread.run(Thread.java:839)
[err] Caused by: 
[err] java.net.SocketTimeoutException: SocketTimeoutException invoking http://localhost:9080/jaxrs/pdprof/sleep: Read timed out
[err] 	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
[err] 	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
[err] 	at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
[err] 	at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
[err] 	at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.mapException(HTTPConduit.java:1458)
[err] 	at [internal classes]
[err] 	... 33 more
[err] Caused by: 
[err] java.net.SocketTimeoutException: Read timed out
[err] 	at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
[err] 	at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
[err] 	at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
[err] 	at java.base/java.io.BufferedInputStream.fill(BufferedInputStream.java:252)
[err] 	at java.base/java.io.BufferedInputStream.read1(BufferedInputStream.java:292)
[err] 	at java.base/java.io.BufferedInputStream.read(BufferedInputStream.java:351)
[err] 	at java.base/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:787)
[err] 	at java.base/sun.net.www.http.HttpClient.parseHTTPHeader(HttpClient.java:925)
[err] 	at java.base/sun.net.www.http.HttpClient.parseHTTP(HttpClient.java:722)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1615)
[err] 	at java.base/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1520)
[err] 	at java.base/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527)
[err] 	at org.apache.cxf.transport.http.URLConnectionHTTPConduit$URLConnectionWrappedOutputStream$2.run(URLConnectionHTTPConduit.java:441)
[err] 	at [internal classes]
[err] 	at java.base/java.security.AccessController.doPrivileged(AccessController.java:746)
[err] 	at org.apache.cxf.transport.http.URLConnectionHTTPConduit$URLConnectionWrappedOutputStream.getResponseCode(URLConnectionHTTPConduit.java:437)
[err] 	at [internal classes]
[err] 	... 40 more
*** ReceiveClientServlet END ***

Simple JAX-RS client

最後にエラーなしのクライアントです。http://localhost:9080/jaxrs.client/get をクリックすると以下のページが出力されます。クライアントからの送信されたリクエストヘッダーが確認できます。

image.png

トラブルシューティング

毎度のことですが、よくつかう dockerコマンドを書いておきます。この文書でもpodman, dockerとまとまりがないですが、Linux では dockerがpodmanを呼び出すようになっていました。

docker ps # 動作中のContainer確認
docker logs -f jaxrs # ログ確認
docker restart jaxrs # 再起動
docker inspect jaxrs # container 確認
docker exec -it jaxrs bash # Container内状況確認

まとめ

LibertyとtWASの環境を構築して、JAX-RSをテストしました。

0
0
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
Sign upLogin
0
0

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?