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

cleanup work

Browse Source
This commit is contained in:
eugenp 2014-07-06 16:51:41 +03:00
parent 2b704f933a
commit fc6e8af9ea
2 changed files with 34 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
httpclient/src/test/java/org/baeldung/httpclient/conn/MultiHttpClientConnThread.java
View File

@ -1,8 +1,6 @@
package org.baeldung.httpclient.conn; package org.baeldung.httpclient.conn;
import java.io.IOException; import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.apache.http.HttpResponse; import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException; import org.apache.http.client.ClientProtocolException;
@ -10,52 +8,56 @@ import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.util.EntityUtils; import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class MultiHttpClientConnThread extends Thread { public class MultiHttpClientConnThread extends Thread {
private final Logger logger = LoggerFactory.getLogger(getClass());
private final CloseableHttpClient client; private final CloseableHttpClient client;
private final HttpGet get; private final HttpGet get;
private PoolingHttpClientConnectionManager connManager = null;
private PoolingHttpClientConnectionManager connManager;
private static HttpResponse response; private static HttpResponse response;
private Logger logger;
public int leasedConn; public int leasedConn;
public MultiHttpClientConnThread(final CloseableHttpClient client, final HttpGet get, final PoolingHttpClientConnectionManager connManager) { public MultiHttpClientConnThread(final CloseableHttpClient client, final HttpGet get, final PoolingHttpClientConnectionManager connManager) {
this.client = client; this.client = client;
this.get = get; this.get = get;
this.connManager = connManager; this.connManager = connManager;
logger = Logger.getLogger(MultiHttpClientConnThread.class.getName()); this.leasedConn = 0;
leasedConn = 0;
} }
public MultiHttpClientConnThread(final CloseableHttpClient client, final HttpGet get) { public MultiHttpClientConnThread(final CloseableHttpClient client, final HttpGet get) {
this.client = client; this.client = client;
this.get = get; this.get = get;
logger = Logger.getLogger(MultiHttpClientConnThread.class.getName());
} }
public int getLeasedConn() { // API
public final int getLeasedConn() {
return leasedConn; return leasedConn;
} }
@Override //
public void run() {
@Override
public final void run() {
try { try {
if (this != null) logger.info("Thread Running: " + getName());
logger.log(Level.SEVERE, "Thread Running: " + getName());
response = client.execute(get); response = client.execute(get);
if (connManager != null) { if (connManager != null) {
logger.log(Level.SEVERE, "Leased Connections " + connManager.getTotalStats().getLeased()); logger.info("Leased Connections " + connManager.getTotalStats().getLeased());
leasedConn = connManager.getTotalStats().getLeased(); leasedConn = connManager.getTotalStats().getLeased();
logger.log(Level.SEVERE, "Available Connections " + connManager.getTotalStats().getAvailable()); logger.info("Available Connections " + connManager.getTotalStats().getAvailable());
} }
EntityUtils.consume(response.getEntity()); EntityUtils.consume(response.getEntity());
} catch (final ClientProtocolException ex) { } catch (final ClientProtocolException ex) {
logger.error("", ex);
} catch (final IOException ex) { } catch (final IOException ex) {
logger.error("", ex);
}
} }
}
} }

28
httpclient/src/test/java/org/baeldung/httpclient/conn/TesterVersion_MultiHttpClientConnThread.java
View File

@ -1,49 +1,49 @@
package org.baeldung.httpclient.conn; package org.baeldung.httpclient.conn;
import java.io.IOException; import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.apache.http.client.ClientProtocolException; import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class TesterVersion_MultiHttpClientConnThread extends Thread { public class TesterVersion_MultiHttpClientConnThread extends Thread {
private final Logger logger = LoggerFactory.getLogger(getClass());
private final CloseableHttpClient client; private final CloseableHttpClient client;
private final HttpGet get; private final HttpGet get;
private PoolingHttpClientConnectionManager connManager = null; private PoolingHttpClientConnectionManager connManager;
private Logger logger;
public int leasedConn; public int leasedConn;
public TesterVersion_MultiHttpClientConnThread(final CloseableHttpClient client, final HttpGet get, final PoolingHttpClientConnectionManager connManager) { public TesterVersion_MultiHttpClientConnThread(final CloseableHttpClient client, final HttpGet get, final PoolingHttpClientConnectionManager connManager) {
this.client = client; this.client = client;
this.get = get; this.get = get;
this.connManager = connManager; this.connManager = connManager;
logger = Logger.getLogger(TesterVersion_MultiHttpClientConnThread.class.getName());
leasedConn = 0; leasedConn = 0;
} }
public int getLeasedConn() { //
public final int getLeasedConn() {
return leasedConn; return leasedConn;
} }
@Override @Override
public void run() { public final void run() {
try { try {
if (this != null) logger.info("Thread Running: " + getName());
logger.log(Level.SEVERE, "Thread Running: " + getName());
client.execute(get); client.execute(get);
if (connManager != null) { if (connManager != null) {
logger.log(Level.SEVERE, "Leased Connections " + connManager.getTotalStats().getLeased()); logger.info("Leased Connections " + connManager.getTotalStats().getLeased());
leasedConn = connManager.getTotalStats().getLeased(); leasedConn = connManager.getTotalStats().getLeased();
logger.log(Level.SEVERE, "Available Connections " + connManager.getTotalStats().getAvailable()); logger.info("Available Connections " + connManager.getTotalStats().getAvailable());
} }
} catch (final ClientProtocolException ex) { } catch (final ClientProtocolException ex) {
logger.error("", ex);
} catch (final IOException ex) { } catch (final IOException ex) {
logger.error("", ex);
} }
} }