Class HttpClient

Utils/src/eu/the5zig/util/io/http/HttpClient.java:19–76

import java.util.concurrent.TimeUnit;

public class HttpClient {

	public static final int TIMEOUT = 5000;
	private static final Cache<String, InetAddress> addressCache = CacheBuilder.newBuilder().expireAfterWrite(5, TimeUnit.MINUTES).build();

	@SuppressWarnings("UnusedAssignment")
	public static void get(String url, EventLoopGroup eventLoop, final HttpResponseCallback callback) {
		Preconditions.checkNotNull(url, "url");
		Preconditions.checkNotNull(eventLoop, "eventLoop");
		Preconditions.checkNotNull(callback, "callBack");

		final URI uri = URI.create(url);

		Preconditions.checkNotNull(uri.getScheme(), "scheme");
		Preconditions.checkNotNull(uri.getHost(), "host");
		boolean ssl = uri.getScheme().equals("https");
		int port = uri.getPort();
		if (port == -1) {
			if (uri.getScheme().equals("http"))
				port = 80;
			else if (uri.getScheme().equals("https"))
				port = 443;
			else
				throw new IllegalArgumentException("Unknown scheme " + uri.getScheme());
		}

		InetAddress inetHost = addressCache.getIfPresent(uri.getHost());
		if (inetHost == null) {
			try {
				inetHost = InetAddress.getByName(uri.getHost());
			} catch (UnknownHostException ex) {
				callback.call(null, -1, ex);
				return;
			}
			addressCache.put(uri.getHost(), inetHost);
		}

		ChannelFutureListener future = new ChannelFutureListener() {
			@Override
			public void operationComplete(ChannelFuture future) throws Exception {
				if (future.isSuccess()) {
					String path = uri.getRawPath() + ((uri.getRawQuery() == null) ? "" : "?" + uri.getRawQuery());

					HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, path);
					request.headers().set(HttpHeaders.Names.HOST, uri.getHost());

					future.channel().writeAndFlush(request);
				} else {
					callback.call(null, -1, future.cause());
				}
			}
		};

		new Bootstrap().channel(NioSocketChannel.class).group(eventLoop).handler(new HttpInitializer(callback, ssl, uri.getHost(), port)).
				option(ChannelOption.CONNECT_TIMEOUT_MILLIS, TIMEOUT).remoteAddress(inetHost, port).connect().addListener(future);
	}

}