Java Websocket 개발 가이드: 클라이언트와 서버 간의 실시간 통신을 달성하는 방법

Java Websocket 개발 가이드: 클라이언트와 서버 간의 실시간 통신을 구현하는 방법, 구체적인 코드 예제가 필요합니다.

웹 애플리케이션의 지속적인 개발로 인해 실시간 통신은 프로젝트의 필수 부분이 되었습니다. 기존 HTTP 프로토콜에서는 클라이언트가 서버에 요청을 보내고 응답을 받은 후에만 데이터를 얻을 수 있습니다. 이로 인해 클라이언트가 최신 데이터를 얻기 위해 지속적으로 서버를 폴링하게 되므로 성능 및 효율성 문제가 발생합니다. . WebSocket은 이러한 문제를 해결하기 위해 탄생했습니다.

WebSocket은 HTML5의 새로운 프로토콜입니다. 양방향 통신을 제공하고 클라이언트 폴링 작업을 줄입니다. 클라이언트는 서버의 응답을 기다리지 않고 서버에 직접 메시지를 보낼 수 있습니다. 이를 통해 실시간 애플리케이션을 더욱 쉽고 효율적으로 개발할 수 있습니다.

Java는 웹 애플리케이션 개발에 널리 사용되는 언어로 Websocket을 쉽게 구현할 수 있는 방법도 제공합니다. Java에서 웹소켓을 사용하는 방법은 다음과 같습니다.

첫 번째 단계는 Java의 WebSocket API를 가져오는 것입니다. Maven 중앙 저장소에서 또는 Java EE 7 프레임워크의 javax.websocket 패키지에 있는 API를 사용하여 이 작업을 수행할 수 있습니다.

다음은 Java EE 7의 javax.websocket 패키지에 있는 API를 사용하여 Websocket을 구현하는 예입니다.

1. ServerEndpoint 주석 클래스를 생성합니다.

@WebSocket 주석을 사용하여 클래스를 생성하여 Java 서버에 이 클래스가 있음을 알립니다. 이 세션을 전송할 수 있습니다. WebSocket 끝점으로서 URI를 제공하면 이 주소를 WebSocket 끝점과 일치시킵니다.

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
 
@ServerEndpoint(value = "/websocket")
public class WebSocketExample {
     
    @OnOpen
    public void onOpen(){
        System.out.println("Connection opened");
    }
     
    @OnClose
    public void onClose(){
        System.out.println("Connection closed");
    }
     
    @OnMessage
    public void onMessage(String message){
        System.out.println("Message received: " + message);
    }
}

WebSocketExample 클래스를 WebSocket 프로그램의 입구로 사용하세요. 위의 예에서는 @ServerEndpoint 주석을 Endpoint 클래스와 함께 사용하여 클래스를 지정된 URI에 매핑했습니다.

@OnOpen, @OnMessage 및 @OnClose 주석은 이벤트 기반이며 WebSocket 연결이 열리고 메시지가 수신되고 연결이 닫힐 때 호출될 메서드를 지정하는 데 사용됩니다.

얻은 메시지 문자열은 onMessage 콜백 메서드에 직접 전달됩니다. 이제 WebSocket 서버 측에서 엔드포인트를 정의했습니다.

2. 클라이언트 예제 만들기

public class WebSocketClientExample extends Endpoint {
 
    public static CountDownLatch latch;
 
    @Override
    public void onOpen(final Session session, EndpointConfig config) {
        System.out.println("Connected");
 
        try {
            session.getBasicRemote().sendText("Hello");
        } catch (IOException ex) {
        }
    }
 
    @Override
    public void onError(final Session session, Throwable t) {
        t.printStackTrace();
    }
}

WebSocket 클라이언트는 WebSocket API의 일부인 기본 클래스로 javax.websocket.Endpoint를 사용할 수 있습니다.

CountDownLatch를 사용하여 클라이언트가 서버에 연결되어 있는지 확인합니다.

onOpen() 콜백 메소드에서 서버에 연결하여 메시지를 보냈습니다.

참고: 이 예에서는 session.getBasicRemote().sendText(“Hello”) 메서드를 사용하여 메시지가 전송됩니다. WebSocket API에는 메시지를 보내는 또 다른 방법, 즉 session.getAsyncRemote().sendText("Hello");가 있습니다. 차이점은 getBasicRemote() 메서드는 차단하는 반면 getAsyncRemote() 메서드는 비차단이라는 것입니다. . 의. 비동기적으로 메시지를 보내고 싶다면 getAsyncRemote()를 사용할 수 있습니다.

3. 테스트 클래스 생성 및 애플리케이션 실행

서버와 클라이언트를 서비스하는 테스트 클래스를 구축하여 정상적인 연결 설정을 보장합니다. 애플리케이션을 시작하고 실행 중인 애플리케이션이 WebSocket 서버와 상호 작용하도록 해야 합니다. 모든 것이 정상이면 개발 도구 콘솔에 일부 메시지가 인쇄되는 것을 볼 수 있습니다.

import javax.websocket.*;
import java.net.URI;
import java.util.concurrent.CountDownLatch;
 
public class AppRunner {
 
    public static void main(String[] args) throws Exception {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
 
        CountDownLatch latch = new CountDownLatch(1);
 
        container.connectToServer(new WebSocketExample(), new URI("ws://localhost:8080/websocket"));
 
        latch.await();
    }
}

이 테스트 코드는 WebSocket 클라이언트를 시작하고 localhost:8080에서 WebSocket 서버에 연결을 시도합니다. CountDownLatch 개체를 사용하여 몇 가지 추가 정보와 함께 성공적인 연결을 기다립니다.

테스트를 실행할 때 웹 브라우저를 통해 http://localhost:8080/websocket을 입력하고 JavaScript 콘솔을 열어 JavaScript WebSocket 개체를 통해 WebSocket 클라이언트에 메시지를 보고 보낼 수 있습니다.

요약:

실시간 통신을 위해 WebSocket을 사용하는 것은 기존 HTTP 주기적 폴링을 사용하는 것보다 훨씬 더 효율적입니다. Java 언어에서는 WebSocket API를 사용하여 Websocket을 구현할 수 있습니다. 이 기사에서는 WebSocket 서버 및 클라이언트용 Java 샘플 프로그램과 특정 코드 구현 예제를 제공합니다. 이것이 독자들에게 도움이 되기를 바랍니다.

위 내용은 Java Websocket 개발 가이드: 클라이언트와 서버 간의 실시간 통신을 달성하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!