feature: Klassen-Stub für den "WebSocketController" hinzugefügt

Thomas Ziemer
1 parent 868b6113
Showing 3 changed files with 85 additions and 5 deletions
pom.xml
src/main/java/net/ziemers/swxercise/ui/ws/WebSocketController.java
src/main/webapp/websockets.html
@@ -24,6 +24,7 @@
 		<slf4j-version>1.7.25</slf4j-version>
         <jglue-version>3.1.4</jglue-version>
 		<jackson-version>2.8.8.1</jackson-version>
+		<jetty-version>9.4.8.v20171121</jetty-version>
 		<!-- Substituiert die Platzhalter in der "persistence.xml" -->
 		<TEST_SCHEMA_NAME>swxercise_test</TEST_SCHEMA_NAME>
@@ -97,6 +98,24 @@
             <version>${jglue-version}</version>
             <scope>test</scope>
         </dependency>
+		<dependency>
+			<groupId>org.eclipse.jetty</groupId>
+			<artifactId>jetty-server</artifactId>
+			<version>${jetty-version}</version>
+			<scope>provided</scope>
+		</dependency>
+		<dependency>
+            <groupId>org.eclipse.jetty</groupId>
+            <artifactId>jetty-servlet</artifactId>
+			<version>${jetty-version}</version>
+			<scope>provided</scope>
+        </dependency>
+		<dependency>
+			<groupId>org.eclipse.jetty.websocket</groupId>
+			<artifactId>javax-websocket-server-impl</artifactId>
+			<version>${jetty-version}</version>
+			<scope>provided</scope>
+		</dependency>
         <!-- Sorgt für eine schnellere Verwaltung der JSON-Umwandlung im REST-Kontext -->
 		<!-- dependency>
 			<groupId>com.fasterxml.jackson.core</groupId>
@@ -124,6 +143,11 @@
 					<target>${java-version}</target>
 				</configuration>
 			</plugin>
+			<plugin>
+				<groupId>org.eclipse.jetty</groupId>
+				<artifactId>jetty-maven-plugin</artifactId>
+				<version>${jetty-version}</version>
+			</plugin>
 		</plugins>
 	</build>
 </project>
+package net.ziemers.swxercise.ui.ws;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.websocket.CloseReason;
+import javax.websocket.OnClose;
+import javax.websocket.OnMessage;
+import javax.websocket.OnOpen;
+import javax.websocket.Session;
+import javax.websocket.server.ServerEndpoint;
+import java.io.IOException;
+
+/**
+ * Stub für die WebSocket-Unterstützung.
+ */
+@ApplicationScoped
+@ServerEndpoint(WebSocketController.serverEndpointPath)
+public class WebSocketController {
+
+    static final String serverEndpointPath = "/ws/api/v1/anEndpoint";
+
+    /**
+     * Callback-Methode für das Öffnen einer neuen WebSocket-Verbindung.
+     *
+     * @param session das {@link Session}-Objekt der neuen WebSocket-Verbindung
+     */
+    @OnOpen
+    public void onOpen(Session session) {
+        System.out.println("WebSocket opened with session id #" + session.getId());
+    }
+
+    /**
+     * Callback-Methode, die den Empfang einer neuen WebSocket-Nachricht signalisiert.
+     *
+     * @param message der Inhalt der WebSocket-Nachricht
+     * @param session das {@link Session}-Objekt der sendenden WebSocket-Verbindung
+     */
+    @OnMessage
+    public void onMessage(String message, Session session) {
+        System.out.println("WebSocket Message '" + message + "' received by session id #" + session.getId());
+        try {
+            session.getBasicRemote().sendText(message);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * Callback-Methode für das Schließen einer geöffneten WebSocket-Verbindung.
+     *
+     * @param reason die Ursache für das Schließen der WebSocket-Verbindung
+     * @param session das {@link Session}-Objekt der geschlossenen WebSocket-Verbindung
+     */
+    @OnClose
+    public void onClose(CloseReason reason, Session session) {
+        System.out.println("Closing WebSocket due to " + reason.getReasonPhrase() + " by id #" + session.getId());
+    }
+
+}
@@ -6,7 +6,7 @@
 </head>
 <body>
     <script>
-        var url = "ws://localhost:8080/swxercise/ws/api/v1/test";
+        var url = "ws://localhost:8080/swxercise/ws/api/v1/anEndpoint";
         var webSocket = new WebSocket(url);
         // Callback-Methoden für die WebSocket-Kommunikation
@@ -32,10 +32,8 @@
         }
         function sendWebSocketMessage() {
-            if (webSocket.send('Hello World!'))
-                console.log("WebSocket Message sent.");
-            else
-                alert("WebSocket Message not sent!");
+            webSocket.send('Hello World!');
+            console.log("Tried to send WebSocket Message.");
         }
     </script>
     <button onclick="sendWebSocketMessage()">Klick mich.</button>