서버는 새로운 클라이언트의 접속을 위해 대기(accept)하거나, 종료(close)할 수 있습니다.
웹소켓(WebSocket)이란
일반적인웹 환경은 클라이언트의 요청을 받으면 응답 후 바로 연결을 종료하는 비연결 동기 소켓 방식을 사용합니다
하지만 웹소켓은 클라이언트의 요청에 응답한 후에도 연결을 그대로 유지하는 연결 지향 방식입니다
따라서 별도의 요청이 없어도 서버는 원하면 언제든 클라이언트로 데이터를 전송할 수 있습니다.
앞에서 소켓의 통신 절차가 꽤나 복잡한 것을 알 수 있는데, 웹소켓은 이 복잡한 절차를 간단히 구현할 수 있는 장치가 마련되어있습니다. 웹소캣 서버의 구현은 애너테이션을 이용됩니다
@ServerEndpoint : 웹소캣 서버의 요청명을 설정합니다
@OnOpen : 클라이언트가 접속했을 때 요청되는 메서드를 정의합니다
@OnMessage : 클라이언트로부터 메시지가 전송되었을 때 실행되는 메서드를 정의합니다.
@OnClose : 클라이언트의 접속이 종료되면 실행되는 메서드를 정의합니다.
@OnError : 에러 발생 시 실행되는 메서드를 정의합니다.
위의 애너테이션을 이용해 클라이언트의 요청이 있을 때 적절한 메서드가 실행되어 응답하게 됩니다. 응답은 이벤트 객체를 통해 전달되고, 자바스크립트에서 리스너 메서드를 통해 전달받을 수 있습니다
구현하기
채팅 서버 구현하기
접속한 클라이언트들을 컬렉션으로 관리하면서 한 클라이언트가 메시지를 보내면 다른 모든 클라이언트에 전달하는 간단한 서버입니다.
package websocket;
import java.io.IOException;
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
// 웹소켓 서버의 요청명 지정
@ServerEndpoint("/ChatingServer")
public class ChatServer {
// 접속한 클라이언트의 세션을 저장할 컬렉션 생성
private static Set<Session> clients = Collections.synchronizedSet(new HashSet<Session>());
@OnOpen // 클라이언트 접속 시 실행
public void onOpen(Session session) {
clients.add(session); // 세션 추가
}
@OnMessage // 메시지를 받으면 실행
public void onMessage(String message, Session session) throws IOException {
synchronized (clients) {
for (Session client : clients) { // 모든 클라이언트에 메시지 전달
if (!client.equals(session)) { // 단, 메시지를 보낸 클라이언트는 제외
client.getBasicRemote().sendText(message);
}
}
}
}
@OnClose // 클라이언트와의 연결이 끊기면 실행
public void onClose(Session session) {
clients.remove(session);
}
@OnError // 에러 발생 시 실행
public void onError(Throwable e) {
e.printStackTrace();
}
}
Point
1. @ServerEndpoint 애너테이션으로 해당 요청명으로 접속하는 클라이언트를 이 클래스가 처리하게 합니다.
