Added experiment with jnr-unixsocket.

frankscholten · frankscholten · commit a19aa436da8b · 2013-12-20T16:13:14.000+01:00
diff --git a/pom.xml b/pom.xml
@@ -57,6 +57,7 @@
         <commons-lang.version>2.6</commons-lang.version>
         <slf4j-api.version>1.7.5</slf4j-api.version>
         <jsr305.version>1.3.9</jsr305.version>
+        <jnr.unixsocket.version>0.3</jnr.unixsocket.version>
 
         <!--test dependencies -->
         <version.logback>1.0.1</version.logback>
@@ -123,6 +124,12 @@
             <version>${commons-io.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.github.jnr</groupId>
+            <artifactId>jnr-unixsocket</artifactId>
+            <version>${jnr.unixsocket.version}</version>
+        </dependency>
+
         <dependency>
             <groupId>org.slf4j</groupId>
             <artifactId>slf4j-api</artifactId>
diff --git a/src/main/java/com/kpelykh/docker/client/DockerClient.java b/src/main/java/com/kpelykh/docker/client/DockerClient.java
@@ -15,6 +15,7 @@
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.http.client.HttpClient;
+import org.apache.http.conn.ClientConnectionManager;
 import org.apache.http.conn.scheme.PlainSocketFactory;
 import org.apache.http.conn.scheme.Scheme;
 import org.apache.http.conn.scheme.SchemeRegistry;
@@ -60,8 +61,9 @@ public DockerClient(String serverUrl) {
         // Increase default max connection per route
         cm.setDefaultMaxPerRoute(1000);
 
-        HttpClient httpClient = new DefaultHttpClient(cm);
-        client = new ApacheHttpClient4(new ApacheHttpClient4Handler(httpClient, null, false), clientConfig);
+        // HttpClient httpClient = new DefaultHttpClient(cm);
+        // client = new ApacheHttpClient4(new ApacheHttpClient4Handler(httpClient, null, false), clientConfig);
+        client = new UnixSocketClient();
 
         client.addFilter(new JsonClientFilter());
         //client.addFilter(new LoggingFilter());
diff --git a/src/main/java/com/kpelykh/docker/client/UnixSocketClient.java b/src/main/java/com/kpelykh/docker/client/UnixSocketClient.java
@@ -0,0 +1,11 @@
+package com.kpelykh.docker.client;
+
+import com.sun.jersey.api.client.Client;
+
+
+public class UnixSocketClient extends Client {
+
+  public UnixSocketClient() {
+    super(new UnixSocketClientHandler());
+  }
+}
diff --git a/src/main/java/com/kpelykh/docker/client/UnixSocketClientHandler.java b/src/main/java/com/kpelykh/docker/client/UnixSocketClientHandler.java
@@ -0,0 +1,52 @@
+package com.kpelykh.docker.client;
+
+import com.sun.jersey.api.client.ClientHandler;
+import com.sun.jersey.api.client.ClientHandlerException;
+import com.sun.jersey.api.client.ClientRequest;
+import com.sun.jersey.api.client.ClientResponse;
+import jnr.unixsocket.UnixSocketAddress;
+import jnr.unixsocket.UnixSocketChannel;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.nio.CharBuffer;
+import java.nio.channels.Channels;
+
+public class UnixSocketClientHandler implements ClientHandler {
+
+  @Override
+  public ClientResponse handle(ClientRequest cr) throws ClientHandlerException {
+    System.out.println("UnixSocketClientHandler.handle " + cr);
+
+    File path = new File("/var/run/docker.sock");
+
+    String data = "GET /images/json?all=0 HTTP/1.1\n\n";
+
+    UnixSocketAddress address = new UnixSocketAddress(path);
+    UnixSocketChannel channel = null;
+    try {
+      channel = UnixSocketChannel.open(address);
+    } catch (IOException e) {
+      e.printStackTrace();
+    }
+    System.out.println("connected to " + channel.getRemoteSocketAddress());
+    PrintWriter w = new PrintWriter(Channels.newOutputStream(channel));
+    w.print(data);
+    w.flush();
+
+    InputStreamReader r = new InputStreamReader(Channels.newInputStream(channel));
+
+    CharBuffer result = CharBuffer.allocate(1024);
+    try {
+      r.read(result);
+    } catch (IOException e) {
+      e.printStackTrace();
+    }
+    result.flip();
+    System.out.println("read from server: " + result.toString());
+
+    return null;
+  }
+}
