update

pom.xml

@@ -314,6 +314,12 @@
 			<artifactId>activemq-all</artifactId>
 			<version>5.11.0</version>
 		</dependency>
+		
+		<dependency>
+			<groupId>org.java-websocket</groupId>
+			<artifactId>Java-WebSocket</artifactId>
+			<version>1.5.1</version>
+		</dependency>
 	
 	</dependencies>
 	

src/main/java/kr/co/swh/lecture/opensource/websocket/ExampleClient.java

@@ -0,0 +1,67 @@
+package kr.co.swh.lecture.opensource.websocket; 
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.Map;
+
+import org.java_websocket.client.WebSocketClient;
+import org.java_websocket.drafts.Draft;
+import org.java_websocket.handshake.ServerHandshake;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.opensource.websocket 
+ * ExampleClient.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 8. 2.
+ * @author : tobby48
+ * @version : v1.0
+ */
+/** This example demonstrates how to create a websocket connection to a server. Only the most important callbacks are overloaded. */
+public class ExampleClient extends WebSocketClient {
+
+	public ExampleClient( URI serverUri , Draft draft ) {
+		super( serverUri, draft );
+	}
+
+	public ExampleClient( URI serverURI ) {
+		super( serverURI );
+	}
+
+	public ExampleClient( URI serverUri, Map<String, String> httpHeaders ) {
+		super(serverUri, httpHeaders);
+	}
+
+	@Override
+	public void onOpen( ServerHandshake handshakedata ) {
+		send("You are connected to ChatServer: " + getURI() + "\n" );
+		System.out.println( "opened connection" );
+		// if you plan to refuse connection based on ip or httpfields overload: onWebsocketHandshakeReceivedAsClient
+	}
+
+	@Override
+	public void onMessage( String message ) {
+		System.out.println( "received: " + message );
+	}
+
+	@Override
+	public void onClose( int code, String reason, boolean remote ) {
+		// The codecodes are documented in class org.java_websocket.framing.CloseFrame
+		System.out.println( "Connection closed by " + ( remote ? "remote peer" : "us" ) + " Code: " + code + " Reason: " + reason );
+	}
+
+	@Override
+	public void onError( Exception ex ) {
+		ex.printStackTrace();
+		// if the error is fatal then onClose will be called additionally
+	}
+
+	public static void main( String[] args ) throws URISyntaxException {
+		ExampleClient c = new ExampleClient( new URI( "ws://localhost:8887" )); // more about drafts here: http://github.com/TooTallNate/Java-WebSocket/wiki/Drafts
+		c.connect();
+	}
+
+}

src/main/java/kr/co/swh/lecture/opensource/websocket/ExampleServer.java

@@ -0,0 +1,84 @@
+package kr.co.swh.lecture.opensource.websocket; 
+
+import java.net.InetSocketAddress;
+import java.net.UnknownHostException;
+import java.nio.ByteBuffer;
+import java.util.Collections;
+
+import org.java_websocket.WebSocket;
+import org.java_websocket.drafts.Draft;
+import org.java_websocket.drafts.Draft_6455;
+import org.java_websocket.handshake.ClientHandshake;
+import org.java_websocket.server.WebSocketServer;
+
+/**
+ * <pre>
+ * kr.co.swh.lecture.opensource.websocket 
+ * ExampleServer.java
+ *
+ * 설명 :
+ * </pre>
+ * 
+ * @since : 2020. 8. 2.
+ * @author : tobby48
+ * @version : v1.0
+ */
+public class ExampleServer extends WebSocketServer {
+
+	public static void main(String[] args) throws UnknownHostException {
+		ExampleServer server = new ExampleServer(8887);
+		server.setReuseAddr(true);
+		server.setTcpNoDelay(false);
+		server.start();
+	}
+	public ExampleServer( int port ) throws UnknownHostException {
+		super( new InetSocketAddress( port ) );
+	}
+
+	public ExampleServer( InetSocketAddress address ) {
+		super( address );
+	}
+
+	public ExampleServer(int port, Draft_6455 draft) {
+		super( new InetSocketAddress( port ), Collections.<Draft>singletonList(draft));
+	}
+
+	@Override
+	public void onOpen( WebSocket conn, ClientHandshake handshake ) {
+		conn.send("Welcome to the server!"); //This method sends a message to the new client
+		broadcast( "new connection: " + handshake.getResourceDescriptor() ); //This method sends a message to all clients connected
+		System.out.println( conn.getRemoteSocketAddress().getAddress().getHostAddress() + " entered the room!" );
+	}
+
+	@Override
+	public void onClose( WebSocket conn, int code, String reason, boolean remote ) {
+		broadcast( conn + " has left the room!" );
+		System.out.println( conn + " has left the room!" );
+	}
+
+	@Override
+	public void onMessage( WebSocket conn, String message ) {
+		broadcast( message );
+		System.out.println( conn + ": " + message );
+	}
+	@Override
+	public void onMessage( WebSocket conn, ByteBuffer message ) {
+		broadcast( message.array() );
+		System.out.println( conn + ": " + message );
+	}
+	
+	@Override
+	public void onError( WebSocket conn, Exception ex ) {
+		ex.printStackTrace();
+		if( conn != null ) {
+			// some errors like port binding failed may not be assignable to a specific websocket
+		}
+	}
+
+	@Override
+	public void onStart() {
+		System.out.println("Server started!");
+		setConnectionLostTimeout(0);
+		setConnectionLostTimeout(100);
+	}
+}

src/main/nodejs/rabbitmq-receiver.js

@@ -26,11 +26,11 @@ amqp.connect(url, function(error, connect){
                     else if(message){
                         console.log(message.content.toString());
                         channel.ack(message);
-                        setTimeout(recevieMessage, 5000);
+//                        setTimeout(recevieMessage, 5000);
                     }
                     else{
-                        console.log('NO MESSAGE');
-                        setTimeout(recevieMessage, 5000);
+//                        console.log('NO MESSAGE');
+//                        setTimeout(recevieMessage, 5000);
                     }
                 });
             }