Java dan WebSocket: Bagaimana untuk melaksanakan pemantauan log masa nyata

Dengan kemunculan era Internet, komunikasi masa nyata telah menjadi bahagian yang amat diperlukan dalam pembangunan perisian moden. WebSocket ialah protokol komunikasi dupleks penuh yang membolehkan bahagian hadapan dan bahagian belakang berkomunikasi dalam masa nyata, yang sangat memudahkan pelaksanaan fungsi penting pemantauan log masa nyata. Dalam artikel ini, saya akan memperkenalkan anda kepada cara Java dan WebSocket melaksanakan pemantauan log masa nyata, dan memberikan contoh kod praktikal untuk membantu anda memahami dengan lebih baik.

Langkah pertama: Bina persekitaran WebSocket

Mula-mula, anda perlu memperkenalkan kebergantungan yang berkaitan, termasuk Java WebSocket dan log4j2. Kami boleh menguruskan kebergantungan ini melalui Maven, seperti berikut:

<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>

Seterusnya, buat kod WebSocket Server, seperti berikut:

@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());
        }
    }
}

Dalam kod di atas, kami menggunakan anotasi @ServerEndpoint untuk menentukan pelayan WebSocket yang boleh menerima permintaan sambungan pelanggan . Selepas sambungan berjaya diwujudkan, kaedah @OnOpen akan dipanggil. Apabila sambungan ditutup, kaedah @OnClose dipanggil. Apabila ralat berlaku, kaedah @OnError dipanggil. Apabila pelayan menerima maklumat yang dihantar oleh pelanggan, ia memanggil kaedah @OnMessage untuk pemprosesan. Selain itu, kami juga melaksanakan kaedah sendMessage untuk menghantar maklumat kepada pelanggan.

Langkah 2: Laksanakan pemantauan log

Seterusnya, kita perlu melaksanakan fungsi pemantauan log khusus. Di sini kami mengambil log4j2 sebagai contoh untuk memantau fail log yang ditentukan. Mula-mula, anda perlu menambah Appender pada fail konfigurasi log4j2 untuk mengeluarkan log ke fail yang ditentukan.

<?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>

Dalam Appender, kami menetapkan nama fail kepada log/app.log, yang bermaksud bahawa log akan dikeluarkan kepada fail yang ditentukan. Seterusnya, kita perlu menulis kelas untuk melaksanakan antara muka FileTailer dalam log4j2 dan memantau perubahan fail log.

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);
    }
}

Dalam kod di atas, kami melaksanakan antara muka FileTailer dan menentukan kaedah pemegang untuk memantau fail log. Pada masa yang sama, kami memanggil kaedah sendMessage dalam WebSocketServer untuk menghantar maklumat log kepada pelanggan.

Langkah 3: Mulakan WebSocket Server dan log monitor

Selepas melengkapkan penulisan WebSocket Server dan log monitor, kita perlu memulakannya dalam aplikasi. Kami boleh memulakan Pelayan WebSocket dan FileTailerListener masing-masing pada permulaan, seperti berikut:

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();
        }
    }
}

Dalam kod di atas, kami memulakan FileTailerService untuk memantau perubahan fail log dan mendaftarkan FileTailerListener kepada Perkhidmatan. Pada masa yang sama, Pelayan Jeti mula mengendalikan permintaan sambungan WebSocket.

Langkah 4: Tulis kod bahagian hadapan

Melihat kembali kod sebelumnya, kami telah menyediakan persekitaran WebSocket dan melaksanakan pemantauan dan penghantaran log. Akhir sekali, kita perlu menulis kod bahagian hadapan untuk memaparkan dan mengemas kini maklumat log dalam masa nyata. Di sini, kami boleh menggunakan JavaScript untuk melengkapkan pembangunan bahagian hadapan Kod khusus adalah seperti berikut:

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);
};

Dalam kod, kami menggunakan objek WebSocket untuk mewujudkan sambungan dan secara dinamik menambah mesej ke halaman apabila menerima mesej yang dihantar oleh. pelayan. Pada masa yang sama, kami menggunakan atribut scrollTop untuk memastikan maklumat log terus ditatal.

Pada ketika ini, kami telah menyelesaikan proses melaksanakan pemantauan log masa nyata dengan Java dan WebSocket. Melalui contoh kod di atas, anda boleh belajar cara menggunakan Java dan WebSocket untuk melaksanakan pemantauan log masa nyata, dan juga belajar cara memantau fail log dan menggunakan WebSocket.

Atas ialah kandungan terperinci Java dan WebSocket: Bagaimana untuk melaksanakan pemantauan log masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!