Spring 4.x Websocket 사용해보기

먼저 pom.xml 에 아래 추가

<dependency> <groupId>org.springframework</groupId> <artifactId>spring-websocket</artifactId> <version>4.1.4.RELEASE</version> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>servlet-api</artifactId> <version>2.5</version> <scope>provided</scope> </dependency> <dependency> <groupId>javax.servlet.jsp</groupId> <artifactId>jsp-api</artifactId> <version>2.1</version> <scope>provided</scope> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>jstl</artifactId> <version>1.1.2</version> </dependency> <dependency> <groupId>taglibs</groupId> <artifactId>standard</artifactId> <version>1.1.2</version> </dependency>

wbe.xml 의 namespace 수정

<?xml version="1.0" encoding="UTF-8"?> <web-app version="3.0" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">

dispatcher-servlet.xml 에 아래 추가

<beans ... xmlns:websocket="http://www.springframework.org/schema/websocket" xsi:schemaLocation="... http://www.springframework.org/schema/websocket http://www.springframework.org/schema/websocket/spring-websocket.xsd"> <!-- ========================= WEBSOCKET DEFINITION ========================= --> <!-- http://docs.spring.io/spring/docs/current/spring-framework-reference/html/websocket.html https://github.com/dilbertside/sandbox/tree/master/extjs-websocket --> <websocket:handlers> <websocket:mapping path="/echo" handler="websocketEndPoint"/> <!-- <websocket:handshake-interceptors> <bean class="org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor"/> </websocket:handshake-interceptors> --> </websocket:handlers> <bean id="websocketEndPoint" class="com.springapp.mvc.EchoHandler"/> <bean class="org.springframework.web.socket.server.standard.ServletServerContainerFactoryBean"> <property name="maxTextMessageBufferSize" value="8192"/> <property name="maxBinaryMessageBufferSize" value="8192"/> </bean> </beans>

Configuration.java 추가

package com.springapp.mvc; import org.springframework.context.annotation.Configuration; import org.springframework.web.servlet.config.annotation.DefaultServletHandlerConfigurer; import org.springframework.web.servlet.config.annotation.EnableWebMvc; import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter; import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.WebSocketConfigurer; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; /** * Description. * * @author Ha Neul Kim * @version 0.1 * @since 2015-02-10 */ @Configuration @EnableWebSocket @EnableWebMvc public class ControllerConfiguration extends WebMvcConfigurerAdapter implements WebSocketConfigurer { @Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(new EchoHandler(), "/echo"); } @Override public void configureDefaultServletHandling(DefaultServletHandlerConfigurer configurer) { configurer.enable(); } }

EchoHandler.java 추가

package com.springapp.mvc; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.socket.TextMessage; import org.springframework.web.socket.WebSocketSession; import org.springframework.web.socket.handler.TextWebSocketHandler; /** * Description. * * @author Ha Neul Kim * @version 0.1 * @since 2015-02-10 */ public class EchoHandler extends TextWebSocketHandler { /** * SLF4J Logging */ private Logger logger = LoggerFactory.getLogger(EchoHandler.class); @Override protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { session.sendMessage(new TextMessage("ECHO : " + message.getPayload())); } }

jsp 로 테스트 body 부분에 아래 추가