java+websocket+html5实现⽇志⽂件在前端页⾯实施监控引⽤tomcat中的两个jar：websocket-api.jar 、tomcat7-websocket.jar
java后台：
package com.itor;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;
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;
import org.apachemons.logging.Log;
import org.apachemons.logging.LogFactory;
import com.inspur.datamon.utils.ConfUtil;
/**
* @ServerEndpoint 注解是⼀个类层次的注解，它的功能主要是将⽬前的类定义成⼀个websocket服务器端,
* 注解的值将被⽤于监听⽤户连接的终端访问URL地址，客户端可以通过这个URL来连接到WebSocket服务器端
*/
@ServerEndpoint("/websocket")
public class LogMonitor {
// 静态变量，⽤来记录当前在线连接数。
private static int onlineCount = 0;
// 记录线程与session之间的对应关系
private static Map<String, Process> sessionProcessRelate=new HashMap<String,Process>();
private Process process;
private InputStream inputStream;
/**
* 连接建⽴成功调⽤的⽅法
*
* @param session
*session为与某个客户端的连接会话，需要通过它来给客户端发送数据
*/
@OnOpen
public void onOpen(Session session) {
addOnlineCount(); // 在线数加1
LOG.info("有新连接加⼊！当前在线⼈数为" + getOnlineCount());
}
/**
* 连接关闭调⽤的⽅法
*/
@OnClose
public void onClose(Session session) {
subOnlineCount(); // 在线数减1
subOnlineCount(); // 在线数减1
LOG.info("有连接关闭！当前在线⼈数为" + getOnlineCount());
//删除该session对应的process
if ((Id())!= null){
<(Id()).destroy();
}
}
/**
* 收到客户端消息后调⽤的⽅法
*
* @param message
*            客户端发送过来的消息
* @param session
*            可选的参数
*/
@OnMessage
public void onMessage(String message, Session session) {
// 执⾏tail -f命令
// 如果⾮root启动liunux注意权限问题
// ConfValue("logDir")为获取⽇志⽂件路径，message为前端传⼊的需要监控的⽂件名
String logDir = ConfValue("logDir");
logDir = "tail -f " + logDir + message;
try {
process = Runtime().exec(logDir);
sessionProcessRelate.Id(), process);
} catch (Exception e) {
<("读取⽇志出错", e);
return;
}
inputStream = InputStream();
// 启动新的线程，防⽌InputStream阻塞处理WebSocket的线程
TailLogThread thread = new TailLogThread(inputStream, session);
thread.start();
}
/**
* 发⽣错误时调⽤
*
* @param session
* @param error
*/
@OnError
public void onError(Session session, Throwable error) {
<("websocket服务器端出现错误", error);
error.printStackTrace();
}
public static synchronized int getOnlineCount() {
return onlineCount;
}
public static synchronized void addOnlineCount() {  lineCount++;
}
public static synchronized void subOnlineCount() {  lineCount--;
}
}
新线程：
package com.itor;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import javax.websocket.Session;
import org.apachemons.logging.Log;
import org.apachemons.logging.LogFactory;
public class TailLogThread extends Thread {
public BufferedReader reader;
private Session session;
private static final Log log = Log(TailLogThread.class);
public TailLogThread(InputStream in, Session session) {
try {
<("读取⽇志⽂件转码失败"+e.getMessage(),e);
}
this.session = session;
}
@Override
public void run() {
String line;
try {
while ((line = adLine()) != null) {
// 将实时⽇志通过WebSocket发送给客户端
if (session.isOpen()) {
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
前端jsp：
<%@ page language="java" pageEncoding="UTF-8" %>
<!DOCTYPE html>
<html>
<body>
<div class="dmp-tool operation-froup">
<button id="open" class="btn btn-info btn-sm"
οnclick="openLogMonitor()">开始监控运⾏过程</button>
<button id="close" class="btn btn-info btn-sm"
οnclick="closeLogMonitor()">停⽌监控运⾏过程</button>
<button class="btn btn-info btn-sm" οnclick="downLog()">下载运⾏过程明细</button>
</div>
<div id="message"></div>
</body>
<script type="text/javascript">
/*  监控处理逻辑：
开始与停⽌⽇志监控都会与后台websocket保持连同
java修改html文件，停⽌监控时只是  在页⾯不打印 */
var logName = "/"+"<%= Parameter("logName") %>"+ ".log";
var websocket = null;
//websocket 服务器地址
var wsServer = getWsServer();
if ('WebSocket' in window) {
websocket = new WebSocket(wsServer);
} else {
alert('当前浏览器不⽀持 websocket，请使⽤⽀持html5的浏览器');
}
//开始监控与停⽌监控标志
var isMonitor = true;
//连接发⽣错误的回调⽅法
console.log("WebSocket连接发⽣错误");
};
//接收到消息的回调⽅法
if (isMonitor) {
setMessageInnerHTML(event.data);
}
}
//监听窗⼝关闭事件，当窗⼝关闭时，主动去关闭websocket连接，防⽌连接还没断开就关闭窗⼝，server端会抛异常。 beforeunload = function() {
websocket.close();
}

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。