<Spring WebSocket>
<개발환경>
- SpringFramework 4.3.5 (이상 버전부터 호환)
- Spring legacy project (mvc project)
- WebSocket 4.1.6
<!-- WebSocket -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-websocket</artifactId>
<version>4.1.6.RELEASE</version>
</dependency> cs
- jackson (필수)
<!-- jackson -->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.5.3</version>
<scope>runtime</scope>
</dependency> cs
- Tomcat 8.0 (이상 버전부터 호환)
- jdk 1.8.0 (이상 버전부터 호환)
<추가설정>
<<경로>>
- EchoHandler.java 생성
import java.util.ArrayList;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;
public class EchoHandler extends TextWebSocketHandler{
private static Logger logger = LoggerFactory.getLogger(EchoHandler.class);
private List<WebSocketSession> sessionList = new ArrayList<WebSocketSession>();
/**
* 클라이언트 연결 이후에 실행되는 메소드
*/
@Override
public void afterConnectionEstablished(WebSocketSession session)
throws Exception {
sessionList.add(session);
logger.info("{} 연결됨", session.getId());
}
/**
* 클라이언트가 웹소켓서버로 메시지를 전송했을 때 실행되는 메소드
*/
@Override
protected void handleTextMessage(WebSocketSession session,
TextMessage message) throws Exception {
logger.info("{}로 부터 {} 받음", session.getId(), message.getPayload());
for(WebSocketSession sess : sessionList){
sess.sendMessage(new TextMessage(session.getId() +" : "+ message.getPayload()));
}
}
/**
* 클라이언트가 연결을 끊었을 때 실행되는 메소드
*/
@Override
public void afterConnectionClosed(WebSocketSession session,
CloseStatus status) throws Exception {
sessionList.remove(session);
logger.info("{} 연결 끊김", session.getId());
}
}
cs
- Spring legacy project (mvc project)
<!-- WebSocket -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-websocket</artifactId>
<version>4.1.6.RELEASE</version>
</dependency> | cs |
- jackson (필수)
<!-- jackson -->
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.5.3</version>
<scope>runtime</scope>
</dependency> | cs |
- Tomcat 8.0 (이상 버전부터 호환)
- jdk 1.8.0 (이상 버전부터 호환)
<추가설정>
|
| <<경로>> |
- EchoHandler.java 생성
import java.util.ArrayList;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;
public class EchoHandler extends TextWebSocketHandler{
private static Logger logger = LoggerFactory.getLogger(EchoHandler.class);
private List<WebSocketSession> sessionList = new ArrayList<WebSocketSession>();
/**
* 클라이언트 연결 이후에 실행되는 메소드
*/
@Override
public void afterConnectionEstablished(WebSocketSession session)
throws Exception {
sessionList.add(session);
logger.info("{} 연결됨", session.getId());
}
/**
* 클라이언트가 웹소켓서버로 메시지를 전송했을 때 실행되는 메소드
*/
@Override
protected void handleTextMessage(WebSocketSession session,
TextMessage message) throws Exception {
logger.info("{}로 부터 {} 받음", session.getId(), message.getPayload());
for(WebSocketSession sess : sessionList){
sess.sendMessage(new TextMessage(session.getId() +" : "+ message.getPayload()));
}
}
/**
* 클라이언트가 연결을 끊었을 때 실행되는 메소드
*/
@Override
public void afterConnectionClosed(WebSocketSession session,
CloseStatus status) throws Exception {
sessionList.remove(session);
logger.info("{} 연결 끊김", session.getId());
}
} | cs |
- socket.js 다운로드
- sockjs-0.3.4.js << click
- servlet-context.xml 설정
- namespaces에 websocket 추가
- source에 소스 추가
<beans:bean id="echoHandler" class="ms.mscom.msapp.EchoHandler"/>
<websocket:handlers>
<websocket:mapping handler="echoHandler" path="/echo" />
<websocket:sockjs />
</websocket:handlers> | cs |
- chat.jsp 생성
- jquery CDN : https://code.jquery.com/jquery-3.1.1.min.js
<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>JSP</title>
<script type="text/javascript" src="<c:url value="/resources/js/jquery-3.1.1.min.js"/>"></script>
<script type="text/javascript" src="<c:url value="/resources/js/sockjs-0.3.4.js"/>"></script>
<script type="text/javascript">
$(document).ready(function() {
$("#sendBtn").click(function() {
sendMessage();
});
});
var sock;
//웸소켓을 지정한 url로 연결한다.
sock = new SockJS("<c:url value="/echo"/>");
//자바스크립트 안에 function을 집어넣을 수 있음.
//데이터가 나한테 전달되?쩜? 때 자동으로 실행되는 function
sock.onmessage = onMessage;
//데이터를 끊고싶을때 실행하는 메소드
sock.onclose = onClose;
/* sock.onopen = function(){
sock.send($("#message").val());
}; */
function sendMessage() {
/*소켓으로 보내겠다. */
sock.send($("#message").val());
}
//evt 파라미터는 웹소켓을 보내준 데이터다.(자동으로 들어옴)
function onMessage(evt) {
var data = evt.data;
$("#data").append(data + "<br/>");
//sock.close();
}
function onClose(evt) {
$("#data").append("연결 끊김");
}
</script>
</head>
<body>
<input type="text" id="message" />
<input type="button" id="sendBtn" value="전송" />
<div id="data"></div>
</body>
</html> | cs |
- client 실행
