我需要做一个插件运行在windows系统上。 需求描述:主要的作用是监控访问我分享的共享文件夹的用户在共享文件夹上的操作,比如访问了什么文件和目录,对这个文件和目录做了什么操作。 并在每天12点生成每天的操作日志,根据用户的名字生成不同的文件夹并存放每个人的日志文件。 需要技术:jcifs2.1.32,springboot。 代码要求:不要把全部方法都写到启动类。需要显示全部代码,从pom,到propreties文件,启动类的代码等
时间: 2023-12-14 15:36:58 浏览: 129
共享监控,可以监控用户访问的共享文件夹操作信息
4星 · 用户满意度95%
好的,以下是一个示例代码,供您参考:
1. pom.xml
```xml
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-tomcat</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>jcifs</groupId>
<artifactId>jcifs</artifactId>
<version>2.1.32</version>
</dependency>
</dependencies>
```
2. application.properties
```properties
# JCIFS
jcifs.smb.client.username=your_username
jcifs.smb.client.password=your_password
jcifs.smb.client.domain=your_domain
# Log files directory
log.files.directory=D:\logs
```
3. 日志处理类
```java
import jcifs.smb.NtlmPasswordAuthentication;
import jcifs.smb.SmbException;
import jcifs.smb.SmbFile;
import jcifs.smb.SmbFileFilter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
@Component
public class LogFileProcessor {
@Value("${jcifs.smb.client.username}")
private String smbUsername;
@Value("${jcifs.smb.client.password}")
private String smbPassword;
@Value("${jcifs.smb.client.domain}")
private String smbDomain;
@Value("${log.files.directory}")
private String logFilesDirectory;
private final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
// Map<用户名, Map<文件路径, 操作类型>>
private final Map<String, Map<String, String>> userOperationsMap = new HashMap<>();
public void processLogFile(String filePath, String username) {
Map<String, String> fileOperationsMap = userOperationsMap.computeIfAbsent(username, k -> new HashMap<>());
// 获取文件名和操作类型
String fileName = filePath.substring(filePath.lastIndexOf("\\") + 1);
String operationType = getOperationType(fileName);
// 添加或更新操作记录
fileOperationsMap.put(filePath, operationType);
}
private String getOperationType(String fileName) {
if (fileName.endsWith(".txt")) {
return "读取";
} else {
return "其他操作";
}
}
@Scheduled(cron = "0 0 12 * * ?")
public void generateLogFiles() throws IOException {
// 创建日志目录
File logDirectory = new File(logFilesDirectory);
if (!logDirectory.exists() && !logDirectory.mkdirs()) {
throw new IOException("Failed to create log directory");
}
// 遍历用户操作记录,生成日志文件
for (Map.Entry<String, Map<String, String>> userEntry : userOperationsMap.entrySet()) {
String username = userEntry.getKey();
Map<String, String> fileOperationsMap = userEntry.getValue();
// 创建用户日志目录
File userLogDirectory = new File(logDirectory, username);
if (!userLogDirectory.exists() && !userLogDirectory.mkdirs()) {
throw new IOException("Failed to create user log directory");
}
// 生成日志文件
String logFilePath = userLogDirectory.getAbsolutePath() + "\\" + dateFormat.format(new Date()) + ".log";
File logFile = new File(logFilePath);
if (!logFile.exists() && !logFile.createNewFile()) {
throw new IOException("Failed to create log file");
}
// 写入日志内容
try (BufferedWriter writer = new BufferedWriter(new FileWriter(logFile))) {
for (Map.Entry<String, String> fileEntry : fileOperationsMap.entrySet()) {
String filePath = fileEntry.getKey();
String operationType = fileEntry.getValue();
writer.write(filePath + " - " + operationType);
writer.newLine();
}
}
// 清空用户操作记录
fileOperationsMap.clear();
}
}
public void monitorSharedFolder(String sharedFolder) throws SmbException {
// 认证信息
NtlmPasswordAuthentication auth = new NtlmPasswordAuthentication(smbDomain, smbUsername, smbPassword);
// 共享文件夹
SmbFile sharedFolderFile = new SmbFile(sharedFolder, auth);
// 文件过滤器
SmbFileFilter filter = file -> {
String name = file.getName();
return !name.equals(".") && !name.equals("..") && !file.isDirectory() && !name.endsWith(".lnk");
};
// 监视共享文件夹
while (true) {
SmbFile[] files = sharedFolderFile.listFiles(filter);
for (SmbFile file : files) {
String filePath = file.getPath();
String username = file.getPrincipal().getName();
processLogFile(filePath, username);
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
}
}
}
}
```
4. 启动类
```java
import jcifs.smb.SmbException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application implements CommandLineRunner {
@Autowired
private LogFileProcessor logFileProcessor;
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Override
public void run(String... args) throws Exception {
if (args.length < 1) {
System.err.println("Usage: java -jar log-monitor.jar shared_folder_path");
System.exit(1);
}
String sharedFolder = args[0];
try {
logFileProcessor.monitorSharedFolder(sharedFolder);
} catch (SmbException e) {
System.err.println("Failed to monitor shared folder: " + e.getMessage());
System.exit(1);
}
}
}
```
以上代码实现了对共享文件夹的监控,并在每天12点生成每个用户的操作日志文件。需要注意的是,为了防止将所有方法都写在启动类中,我们使用了组件扫描和依赖注入的方式来处理日志文件。
阅读全文