WebSocket client example with OkHttp

thangpt2019 · thangpt2019 · commit 118ccbd9b644 · 2016-12-24T14:49:31.000+07:00
diff --git a/okhttp-examples/pom.xml b/okhttp-examples/pom.xml
@@ -18,7 +18,7 @@
 		<dependency>
 			<groupId>com.squareup.okhttp3</groupId>
 			<artifactId>okhttp</artifactId>
-			<version>3.4.2</version>
+			<version>3.5.0</version>
 		</dependency>
 		<dependency>
 			<groupId>junit</groupId>
diff --git a/okhttp-examples/src/main/java/com/howtoprogram/okhttp/websocket/EchoWebSocketListener.java b/okhttp-examples/src/main/java/com/howtoprogram/okhttp/websocket/EchoWebSocketListener.java
@@ -0,0 +1,40 @@
+package com.howtoprogram.okhttp.websocket;
+
+import okhttp3.Response;
+import okhttp3.WebSocket;
+import okhttp3.WebSocketListener;
+import okio.ByteString;
+
+public final class EchoWebSocketListener extends WebSocketListener {
+	private static final int NORMAL_CLOSURE_STATUS = 1000;
+
+	@Override
+	public void onOpen(WebSocket webSocket, Response response) {
+		webSocket.send("Knock, knock!");
+		webSocket.send("Hello!");
+		webSocket.send(ByteString.decodeHex("deadbeef"));
+		webSocket.close(NORMAL_CLOSURE_STATUS, "Goodbye!");
+	}
+
+	@Override
+	public void onMessage(WebSocket webSocket, String text) {
+		System.out.println("Receiving: " + text);
+	}
+
+	@Override
+	public void onMessage(WebSocket webSocket, ByteString bytes) {
+		System.out.println("Receiving: " + bytes.hex());
+	}
+
+	@Override
+	public void onClosing(WebSocket webSocket, int code, String reason) {
+		webSocket.close(NORMAL_CLOSURE_STATUS, null);
+		System.out.println("Closing: " + code + " " + reason);
+	}
+
+	@Override
+	public void onFailure(WebSocket webSocket, Throwable t, Response response) {
+		t.printStackTrace();
+	}
+
+}
diff --git a/okhttp-examples/src/main/java/com/howtoprogram/okhttp/websocket/WebSocketClientTest.java b/okhttp-examples/src/main/java/com/howtoprogram/okhttp/websocket/WebSocketClientTest.java
@@ -0,0 +1,22 @@
+package com.howtoprogram.okhttp.websocket;
+
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.WebSocket;
+
+public class WebSocketClientTest {
+
+	public static void main(String... args) {
+
+		OkHttpClient client = new OkHttpClient();
+		
+		Request request = new Request.Builder().url("ws://echo.websocket.org").build();
+		EchoWebSocketListener listener = new EchoWebSocketListener();
+
+		WebSocket ws = client.newWebSocket(request, listener);
+
+		// Trigger shutdown of the dispatcher's executor so this process can
+		// exit cleanly.
+		client.dispatcher().executorService().shutdown();
+	}
+}
