WebSocketServer

pom.xml

@@ -114,6 +114,11 @@
 			<artifactId>spring-boot-devtools</artifactId>
 			<optional>true</optional>
 		</dependency>
+		<dependency>
+			<groupId>org.yeauty</groupId>
+			<artifactId>netty-websocket-spring-boot-starter</artifactId>
+			<version>0.8.0</version>
+		</dependency>
 	</dependencies>
 
 	<build>

src/main/java/com/kingkong/bljs/common/WebSocketServer.java

@@ -0,0 +1,67 @@
+package com.kingkong.bljs.common;
+
+import io.netty.handler.codec.http.HttpHeaders;
+import io.netty.handler.timeout.IdleStateEvent;
+import org.springframework.stereotype.Component;
+import org.yeauty.annotation.*;
+import org.yeauty.pojo.ParameterMap;
+import org.yeauty.pojo.Session;
+
+import java.io.IOException;
+
+
+@ServerEndpoint(prefix = "netty-websocket")
+@Component
+public class WebSocketServer {
+    @OnOpen
+    public void onOpen(Session session, HttpHeaders headers, ParameterMap parameterMap) throws IOException {
+        System.out.println("new connection");
+
+        //String paramValue = parameterMap.getParameter("paramKey");
+        //System.out.println(paramValue);
+    }
+
+    @OnClose
+    public void onClose(Session session) throws IOException {
+        System.out.println("one connection closed");
+    }
+
+    @OnError
+    public void onError(Session session, Throwable throwable) {
+        throwable.printStackTrace();
+    }
+
+    @OnMessage
+    public void onMessage(Session session, String message) {
+        System.out.println(message);
+        session.sendText("Hello Netty!");
+    }
+
+    @OnBinary
+    public void onBinary(Session session, byte[] bytes) {
+        for (byte b : bytes) {
+            System.out.println(b);
+        }
+        //session.sendBinary(bytes);
+    }
+
+    @OnEvent
+    public void onEvent(Session session, Object evt) {
+//        if (evt instanceof IdleStateEvent) {
+//            IdleStateEvent idleStateEvent = (IdleStateEvent) evt;
+//            switch (idleStateEvent.state()) {
+//                case READER_IDLE:
+//                    System.out.println("read idle");
+//                    break;
+//                case WRITER_IDLE:
+//                    System.out.println("write idle");
+//                    break;
+//                case ALL_IDLE:
+//                    System.out.println("all idle");
+//                    break;
+//                default:
+//                    break;
+//            }
+//        }
+    }
+}

src/main/resources/application-c.properties

@@ -45,4 +45,10 @@ spring.thymeleaf.cache=false
 spring.thymeleaf.prefix=classpath:/templates/
 spring.thymeleaf.check-template-location=true
 spring.thymeleaf.suffix=.html
-spring.thymeleaf.encoding=UTF-8
+spring.thymeleaf.encoding=UTF-8
+
+
+#websocketÅäÖÃ
+netty-websocket.host=192.168.1.146
+netty-websocket.path=/
+netty-websocket.port=9021

src/main/resources/application.properties

@@ -1 +1 @@
-spring.profiles.active=h
+spring.profiles.active=c