Java 및 WebSocket: 실시간 로그 모니터링 구현 방법

인터넷 시대의 도래와 함께 실시간 통신은 현대 소프트웨어 개발에 없어서는 안 될 부분이 되었습니다. WebSocket은 프런트엔드와 백엔드가 실시간으로 통신할 수 있도록 하는 전이중 통신 프로토콜로, 실시간 로그 모니터링이라는 중요한 기능의 구현을 크게 촉진합니다. 이번 글에서는 Java와 WebSocket이 실시간 로그 모니터링을 구현하는 방법을 소개하고, 이해를 돕기 위해 실용적인 코드 예제를 제공하겠습니다.

1단계: WebSocket 환경 구축

먼저 Java WebSocket 및 log4j2를 포함한 관련 종속성을 도입해야 합니다. 다음과 같이 Maven을 통해 이러한 종속성을 관리할 수 있습니다.

<dependency>
    <groupId>javax.websocket</groupId>
    <artifactId>javax.websocket-api</artifactId>
    <version>1.1</version>
</dependency>

<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-core</artifactId>
    <version>2.11.2</version>
</dependency>

<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-api</artifactId>
    <version>2.11.2</version>
</dependency>

<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-web</artifactId>
    <version>2.11.2</version>
</dependency>

다음으로 다음과 같이 WebSocket 서버 코드를 생성합니다.

@ServerEndpoint("/log")
public class WebSocketServer {
    private static final Logger logger = LogManager.getLogger(WebSocketServer.class.getName());

    @OnOpen
    public void onOpen(Session session) {
        logger.info("WebSocket opened: " + session.getId());
    }

    @OnClose
    public void onClose(Session session) {
        logger.info("WebSocket closed: " + session.getId());
    }

    @OnError
    public void onError(Session session, Throwable throwable) {
        logger.error("WebSocket error: " + throwable.getMessage());
    }

    @OnMessage
    public void onMessage(String message) {
        logger.info("WebSocket received message: " + message);
    }

    public void sendMessage(String message) {
        try {
            for (Session session : this.sessions) {
                if (session.isOpen()) {
                    session.getBasicRemote().sendText(message);
                }
            }
        } catch (Exception e) {
            logger.error("WebSocket send message error: " + e.getMessage());
        }
    }
}

위 코드에서는 @ServerEndpoint 주석을 사용하여 클라이언트 연결 요청을 수신할 수 있는 WebSocket 서버를 정의합니다. . 연결이 성공적으로 설정된 후 @OnOpen 메서드가 호출됩니다. 연결이 닫히면 @OnClose 메서드가 호출됩니다. 오류가 발생하면 @OnError 메서드가 호출됩니다. 서버는 클라이언트가 보낸 정보를 받으면 처리를 위해 @OnMessage 메서드를 호출합니다. 또한 클라이언트에 정보를 보내기 위한 sendMessage 메서드도 구현했습니다.

2단계: 로그 모니터링 구현

다음으로 특정 로그 모니터링 기능을 구현해야 합니다. 여기서는 지정된 로그 파일을 모니터링하기 위한 예로 log4j2를 사용합니다. 먼저, 지정된 파일에 로그를 출력하려면 log4j2 구성 파일에 Appender를 추가해야 합니다.

<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="INFO">
    <Appenders>
        <RollingFile
            name="RollingFile"
            fileName="logs/app.log"
            filePattern="${sys:logPath}/app-%d{MM-dd-yyyy}-%i.log.gz"
            ignoreExceptions="false">
            <PatternLayout>
                <pattern>%d %p %c{1.} [%t] %m%n</pattern>
            </PatternLayout>
            <Policies>
                <SizeBasedTriggeringPolicy size="64 MB" />
            </Policies>
            <DefaultRolloverStrategy max="10" />
        </RollingFile>
    </Appenders>
    <Loggers>
        <Logger name="com.your.package" level="debug" additivity="false">
            <AppenderRef ref="RollingFile" />
        </Logger>
        <Root level="info">
            <AppenderRef ref="RollingFile" />
        </Root>
    </Loggers>
</Configuration>

Appender에서는 fileName을logs/app.log로 설정했는데, 이는 로그가 지정된 파일로 출력된다는 의미입니다. 다음으로, log4j2에서 FileTailer 인터페이스를 구현하고 로그 파일 변경 사항을 모니터링하는 클래스를 작성해야 합니다.

public class FileTailerListener implements FileTailer {
    private static final Logger logger = LogManager.getLogger(FileTailerListener.class.getName());
    private WebSocketServer webSocketServer;

    public FileTailerListener(WebSocketServer webSocketServer) {
        this.webSocketServer = webSocketServer;
    }

    @Override
    public void handle(String line) {
        logger.info(line);
        this.webSocketServer.sendMessage(line);
    }
}

위 코드에서는 FileTailer 인터페이스를 구현하고 로그 파일을 모니터링하기 위한 핸들 메소드를 정의했습니다. 동시에 WebSocketServer의 sendMessage 메소드를 호출하여 로그 정보를 클라이언트에 보냅니다.

3단계: WebSocket 서버 및 로그 모니터 시작

WebSocket 서버 및 로그 모니터 작성을 완료한 후 애플리케이션에서 이를 시작해야 합니다. 다음과 같이 시작 시 WebSocket 서버와 FileTailerListener를 각각 시작할 수 있습니다.

public class Application {
    public static void main(String[] args) {
        try {
            WebSocketServer webSocketServer = new WebSocketServer();
            FileTailerListener fileTailerListener = new FileTailerListener(webSocketServer);

            FileTailerService fileTailerService = new FileTailerService();
            fileTailerService.addListener(fileTailerListener);
            fileTailerService.start(new File("logs/app.log"));

            ServerEndpointConfig.Builder.create(WebSocketServer.class, "/log")
                .configurator(new ServerEndpointConfig.Configurator())
                .build();

            Server server = new Server(8080);
            server.setHandler(new WebSocketHandler(webSocketServer));
            server.start();
            server.join();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

위 코드에서는 FileTailerService를 시작하여 로그 파일 변경 사항을 모니터링하고 FileTailerListener를 서비스에 등록합니다. 동시에 WebSocket 연결 요청을 처리하기 위해 Jetty 서버가 시작됩니다.

4단계: 프런트엔드 코드 작성

이전 코드를 되돌아보면 WebSocket 환경을 설정하고 로그 모니터링 및 전송을 구현했습니다. 마지막으로 로그 정보를 실시간으로 표시하고 업데이트하는 프런트엔드 코드를 작성해야 합니다. 여기서는 JavaScript를 사용하여 프런트엔드 개발을 완료할 수 있습니다.

var webSocket = new WebSocket("ws://localhost:8080/log");

webSocket.onopen = function(event) {
    console.log("WebSocket opened");
};

webSocket.onmessage = function(event) {
    var message = event.data;
    var logContainer = document.getElementById("logContainer");
    var textNode = document.createTextNode(message);
    logContainer.appendChild(textNode);
    logContainer.scrollTop = logContainer.scrollHeight;
};

webSocket.onclose = function(event) {
    console.log("WebSocket closed");
};

webSocket.onerror = function(event) {
    console.error("WebSocket error: " + event);
};

코드에서는 WebSocket 개체를 사용하여 연결을 설정하고 에서 보낸 메시지를 받을 때 페이지에 동적으로 메시지를 추가합니다. 서버. 동시에, 로그 정보 스크롤을 유지하기 위해 scrollTop 속성을 사용합니다.

이제 Java와 WebSocket을 이용한 실시간 로그 모니터링 구현 과정이 완료되었습니다. 위의 코드 예제를 통해 Java와 WebSocket을 사용하여 실시간 로그 모니터링을 구현하는 방법을 배울 수 있으며, 로그 파일을 모니터링하는 방법과 WebSocket을 사용하는 방법도 배울 수 있습니다.

위 내용은 Java 및 WebSocket: 실시간 로그 모니터링 구현 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!