iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #363 from giuseppebueti/master 

HttpClient with Connection Pool
This commit is contained in:
Eugen 2016-02-19 21:57:09 +02:00
parent 54a1235d17 e00f62fb03
commit e38a4d77b7
1 changed files with 59 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
resteasy/src/test/java/com/baeldung/server/RestEasyClientTest.java
View File

@ -3,11 +3,15 @@ package com.baeldung.server;
import com.baeldung.client.ServicesInterface; import com.baeldung.client.ServicesInterface;
import com.baeldung.model.Movie; import com.baeldung.model.Movie;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.codehaus.jackson.map.DeserializationConfig; import org.codehaus.jackson.map.DeserializationConfig;
import org.codehaus.jackson.map.ObjectMapper; import org.codehaus.jackson.map.ObjectMapper;
import org.jboss.resteasy.client.jaxrs.ResteasyClient; import org.jboss.resteasy.client.jaxrs.ResteasyClient;
import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder; import org.jboss.resteasy.client.jaxrs.ResteasyClientBuilder;
import org.jboss.resteasy.client.jaxrs.ResteasyWebTarget; import org.jboss.resteasy.client.jaxrs.ResteasyWebTarget;
import org.jboss.resteasy.client.jaxrs.engines.ApacheHttpClient4Engine;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import javax.naming.NamingException; import javax.naming.NamingException;
@ -21,6 +25,7 @@ import java.util.Locale;
public class RestEasyClientTest { public class RestEasyClientTest {
public static final UriBuilder FULL_PATH = UriBuilder.fromPath("http://127.0.0.1:8080/RestEasyTutorial/rest");
Movie transformerMovie = null; Movie transformerMovie = null;
Movie batmanMovie = null; Movie batmanMovie = null;
ObjectMapper jsonMapper = null; ObjectMapper jsonMapper = null;
@ -54,15 +59,15 @@ public class RestEasyClientTest {
public void testListAllMovies() { public void testListAllMovies() {
ResteasyClient client = new ResteasyClientBuilder().build(); ResteasyClient client = new ResteasyClientBuilder().build();
ResteasyWebTarget target = client.target(UriBuilder.fromPath("http://127.0.0.1:8080/RestEasyTutorial/rest")); ResteasyWebTarget target = client.target(FULL_PATH);
ServicesInterface simple = target.proxy(ServicesInterface.class); ServicesInterface proxy = target.proxy(ServicesInterface.class);
Response moviesResponse = simple.addMovie(transformerMovie); Response moviesResponse = proxy.addMovie(transformerMovie);
moviesResponse.close(); moviesResponse.close();
moviesResponse = simple.addMovie(batmanMovie); moviesResponse = proxy.addMovie(batmanMovie);
moviesResponse.close(); moviesResponse.close();
List<Movie> movies = simple.listMovies(); List<Movie> movies = proxy.listMovies();
System.out.println(movies); System.out.println(movies);
} }
@ -72,13 +77,13 @@ public class RestEasyClientTest {
String transformerImdbId = "tt0418279"; String transformerImdbId = "tt0418279";
ResteasyClient client = new ResteasyClientBuilder().build(); ResteasyClient client = new ResteasyClientBuilder().build();
ResteasyWebTarget target = client.target(UriBuilder.fromPath("http://127.0.0.1:8080/RestEasyTutorial/rest")); ResteasyWebTarget target = client.target(FULL_PATH);
ServicesInterface simple = target.proxy(ServicesInterface.class); ServicesInterface proxy = target.proxy(ServicesInterface.class);
Response moviesResponse = simple.addMovie(transformerMovie); Response moviesResponse = proxy.addMovie(transformerMovie);
moviesResponse.close(); moviesResponse.close();
Movie movies = simple.movieByImdbId(transformerImdbId); Movie movies = proxy.movieByImdbId(transformerImdbId);
System.out.println(movies); System.out.println(movies);
} }
@ -86,31 +91,61 @@ public class RestEasyClientTest {
public void testAddMovie() { public void testAddMovie() {
ResteasyClient client = new ResteasyClientBuilder().build(); ResteasyClient client = new ResteasyClientBuilder().build();
ResteasyWebTarget target = client.target(UriBuilder.fromPath("http://127.0.0.1:8080/RestEasyTutorial/rest")); ResteasyWebTarget target = client.target(FULL_PATH);
ServicesInterface simple = target.proxy(ServicesInterface.class); ServicesInterface proxy = target.proxy(ServicesInterface.class);
Response moviesResponse = simple.addMovie(batmanMovie); Response moviesResponse = proxy.addMovie(batmanMovie);
moviesResponse.close(); moviesResponse.close();
moviesResponse = simple.addMovie(transformerMovie); moviesResponse = proxy.addMovie(transformerMovie);
if (moviesResponse.getStatus() != Response.Status.CREATED.getStatusCode()) { if (moviesResponse.getStatus() != Response.Status.CREATED.getStatusCode()) {
System.out.println("Failed : HTTP error code : " + moviesResponse.getStatus()); System.out.println("Failed : HTTP error code : " + moviesResponse.getStatus());
} }
moviesResponse.close(); moviesResponse.close();
System.out.println("Response Code: " + Response.Status.OK.getStatusCode()); System.out.println("Response Code: " + moviesResponse.getStatus());
}
@Test
public void testAddMovieMultiConnection() {
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
CloseableHttpClient httpClient = HttpClients.custom()
.setConnectionManager(cm)
.build();
ApacheHttpClient4Engine engine = new ApacheHttpClient4Engine(httpClient);
ResteasyClient client = new ResteasyClientBuilder().httpEngine(engine).build();
ResteasyWebTarget target = client.target(FULL_PATH);
ServicesInterface proxy = target.proxy(ServicesInterface.class);
Response batmanResponse = proxy.addMovie(batmanMovie);
Response transformerResponse = proxy.addMovie(transformerMovie);
if (batmanResponse.getStatus() != Response.Status.CREATED.getStatusCode()) {
System.out.println("Batman Movie creation Failed : HTTP error code : " + batmanResponse.getStatus());
}
if (batmanResponse.getStatus() != Response.Status.CREATED.getStatusCode()) {
System.out.println("Batman Movie creation Failed : HTTP error code : " + batmanResponse.getStatus());
}
batmanResponse.close();
transformerResponse.close();
cm.close();
} }
@Test @Test
public void testDeleteMovie() { public void testDeleteMovie() {
ResteasyClient client = new ResteasyClientBuilder().build(); ResteasyClient client = new ResteasyClientBuilder().build();
ResteasyWebTarget target = client.target(UriBuilder.fromPath("http://127.0.0.1:8080/RestEasyTutorial/rest")); ResteasyWebTarget target = client.target(FULL_PATH);
ServicesInterface simple = target.proxy(ServicesInterface.class); ServicesInterface proxy = target.proxy(ServicesInterface.class);
Response moviesResponse = simple.addMovie(batmanMovie); Response moviesResponse = proxy.addMovie(batmanMovie);
moviesResponse.close(); moviesResponse.close();
moviesResponse = simple.deleteMovie(batmanMovie.getImdbId()); moviesResponse = proxy.deleteMovie(batmanMovie.getImdbId());
if (moviesResponse.getStatus() != Response.Status.OK.getStatusCode()) { if (moviesResponse.getStatus() != Response.Status.OK.getStatusCode()) {
System.out.println(moviesResponse.readEntity(String.class)); System.out.println(moviesResponse.readEntity(String.class));
@ -118,27 +153,27 @@ public class RestEasyClientTest {
} }
moviesResponse.close(); moviesResponse.close();
System.out.println("Response Code: " + Response.Status.OK.getStatusCode()); System.out.println("Response Code: " + moviesResponse.getStatus());
} }
@Test @Test
public void testUpdateMovie() { public void testUpdateMovie() {
ResteasyClient client = new ResteasyClientBuilder().build(); ResteasyClient client = new ResteasyClientBuilder().build();
ResteasyWebTarget target = client.target(UriBuilder.fromPath("http://127.0.0.1:8080/RestEasyTutorial/rest")); ResteasyWebTarget target = client.target(FULL_PATH);
ServicesInterface simple = target.proxy(ServicesInterface.class); ServicesInterface proxy = target.proxy(ServicesInterface.class);
Response moviesResponse = simple.addMovie(batmanMovie); Response moviesResponse = proxy.addMovie(batmanMovie);
moviesResponse.close(); moviesResponse.close();
batmanMovie.setTitle("Batman Begins"); batmanMovie.setTitle("Batman Begins");
moviesResponse = simple.updateMovie(batmanMovie); moviesResponse = proxy.updateMovie(batmanMovie);
if (moviesResponse.getStatus() != Response.Status.OK.getStatusCode()) { if (moviesResponse.getStatus() != Response.Status.OK.getStatusCode()) {
System.out.println("Failed : HTTP error code : " + moviesResponse.getStatus()); System.out.println("Failed : HTTP error code : " + moviesResponse.getStatus());
} }
moviesResponse.close(); moviesResponse.close();
System.out.println("Response Code: " + Response.Status.OK.getStatusCode()); System.out.println("Response Code: " + moviesResponse.getStatus());
} }
} }