Springboot基于websocket实现简单在线聊天功能

2023-07-22 13:29:13 179

org.springframework.boot spring-boot-starter-parent 2.2.5.RELEASE 4.0.0 springboot-websocket springboot-websocket org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-websocket

@Configuration @EnableWebSocket publicclassMyWebSocketConfigimplementsWebSocketConfigurer{ @Override publicvoidregisterWebSocketHandlers(WebSocketHandlerRegistryregistry){ registry.addHandler(myHandler(),"/myHandler").setAllowedOrigins("*"); } @Bean publicWebSocketHandlermyHandler(){ returnnewMyTextWebSocketHandler(); } }

publicclassMyTextWebSocketHandlerextendsTextWebSocketHandler{ privateSetsessions=newHashSet<>(); @Override protectedvoidhandleTextMessage(WebSocketSessionsession,TextMessagemessage)throwsException{ if(session.isOpen()){ sessions.add(session); } sendToAll(message); } privatevoidsendToAll(TextMessagemessage)throwsIOException{ for(WebSocketSessionsession:sessions){ session.sendMessage(message); } } @Override publicvoidafterConnectionClosed(WebSocketSessionsession,CloseStatusstatus)throwsException{ sessions.remove(session); } }

if("WebSocket"inwindow){ varws=newWebSocket("ws://localhost:8080/myHandler"); ws.onopen=function(){ }; ws.onmessage=function(evt){ document.getElementById('messageDiv').innerHTML+=evt.data+"
"; }; ws.onclose=function(){ console.log("closeconnect"); }; }else{ alert("您的浏览器不支持WebSocket!"); } functionsend(){ ws.send(document.getElementById("input").value+":"+document.getElementById("message").value); } 当前用户:
发送消息:

Springboot基于websocket实现简单在线聊天功能

热门推荐

随机推荐