Java用WebSocket + tail命令實現Web實時日誌

阿新 • • 發佈：2019-01-13

在Linux作業系統中，經常需要檢視日誌檔案的實時輸出內容，通常會使用tail -f或者tailf命令。檢視實時日誌可能會需要首先SSH連上Linux主機，步驟很麻煩不說，如果是生產環境的伺服器，可能還會控制各種許可權。基於Web的實時日誌可以解決這個問題。

由於傳統的HTTP協議是請求/響應模式，而實時日誌需要不定時的持續的輸出，由伺服器主動推送給客戶端瀏覽器。所以這裡使用的是HTML5的WebSocket協議。

按照慣例，先上圖：
這裡寫圖片描述

Java後臺

JSR 356是Java實現WebSocket的一套規範，所以需要一個支援JSR 356的伺服器，例如Tomcat、Jetty的最新版本。

JSR 356提供了註解@ServerEndpoint，並需要指定一個路徑，用於處理客戶端WebSocket請求。

import java.io.IOException;
import java.io.InputStream;

import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint 
("/log")
public class LogWebSocketHandle {

    private Process process;
    private InputStream inputStream;

    /**
     * 新的WebSocket請求開啟
     */
    @OnOpen
    public void onOpen(Session session) {
        try {
            // 執行tail -f命令
            process = Runtime.getRuntime().exec("tail -f /var/log/syslog" 
);
            inputStream = process.getInputStream();

            // 一定要啟動新的執行緒，防止InputStream阻塞處理WebSocket的執行緒
            TailLogThread thread = new TailLogThread(inputStream, session);
            thread.start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * WebSocket請求關閉
     */
    @OnClose
    public void onClose() {
        try {
            if(inputStream != null)
                inputStream.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        if(process != null)
            process.destroy();
    }

    @OnError
    public void onError(Throwable thr) {
        thr.printStackTrace();
    }
}

由於針對每個WebSocket連線都會建立一個新的LogWebSocketHandle例項，所以可以不用像Servlet一樣考慮執行緒安全問題。由於tail -f命令的輸入流會阻塞當前執行緒，所以一定要建立一個新的執行緒來讀取tail -f命令的返回結果：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import javax.websocket.Session;

public class TailLogThread extends Thread {

    private BufferedReader reader;
    private Session session;

    public TailLogThread(InputStream in, Session session) {
        this.reader = new BufferedReader(new InputStreamReader(in));
        this.session = session;

    }

    @Override
    public void run() {
        String line;
        try {
            while((line = reader.readLine()) != null) {
                // 將實時日誌通過WebSocket傳送給客戶端，給每一行新增一個HTML換行
                session.getBasicRemote().sendText(line + "<br>");
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Web前端

Web前端需要通過WebSocket連線到服務端，實時接收最新的日誌內容並展示到頁面上。

<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>tail log</title>
<script src="//cdn.bootcss.com/jquery/2.1.4/jquery.js"></script>
</head>
<body>
    <div id="log-container" style="height: 450px; overflow-y: scroll; background: #333; color: #aaa; padding: 10px;">
        <div>
        </div>
    </div>
</body>
<script>
    $(document).ready(function() {
        // 指定websocket路徑
        var websocket = new WebSocket('ws://localhost:8080/log');
        websocket.onmessage = function(event) {
            // 接收服務端的實時日誌並新增到HTML頁面中
            $("#log-container div").append(event.data);
            // 滾動條滾動到最低部
            $("#log-container").scrollTop($("#log-container div").height() - $("#log-container").height());
        };
    });
</script>
</body>
</html>

完成編碼後，就可以部署了。由於用到tail命令，該專案需要部署在Linux系統上。

最後，需要程式碼的同學可以在評論中留下郵箱。

Java用WebSocket + tail命令實現Web實時日誌

Java後臺

Web前端

Java用WebSocket + tail命令實現Web實時日誌

java--用一個對象實現集合

Java + Selenium + TestNG + Maven 框架實現Web Automation

Java——用兩種方法實現字串逆序

Java採用Redis相關命令實現分散式鎖

WebSocket和kafka實現資料實時推送到前端

海康IPC+NVR+EasyDarwin+EasyPusher+VLC實現Web實時播放RTSP視訊

Java用多執行緒實現賣票

使用GoEasy實現web實時推送

Java使用websocket和WebRTC實現視訊通話

FLEX實現Web實時監控

用Kibana和logstash快速搭建實時日誌查詢、收集與分析系統

slf4j+log4j實現web專案日誌輸出

用Websocket實現Web IM（一）

用Java實現Web伺服器

用websocket實現實時聊天功能

用Python實現一個類Unix的tail命令

基於GoEasy實現Java web實時資料推送

websocket+Django+python+paramiko實現web頁面執行伺服器命令和指令碼

大道至簡知易行難 JAVA 完成WebSocket demo 用GoEasy實現Hello world

Java用WebSocket + tail命令實現Web實時日誌

Java後臺

Web前端

相關推薦