From 95f37beb6669ff4c233b1b99f27dbc02423d91d2 Mon Sep 17 00:00:00 2001
From: bwcx_jzy <bwcx_jzy@163.com>
Date: Thu, 28 Dec 2023 22:29:52 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=20=E6=96=87=E4=BB=B6?=
 =?UTF-8?q?=E7=9B=91=E5=90=AC=20WatchServer=20=E6=96=B0=E5=A2=9E=E9=80=9A?=
 =?UTF-8?q?=E8=BF=87=20Path=20=E8=8E=B7=E5=8F=96=20WatchKey=20=E6=96=B9?=
 =?UTF-8?q?=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/hutool/core/io/watch/WatchServer.java  | 20 +++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

diff --git a/hutool-core/src/main/java/cn/hutool/core/io/watch/WatchServer.java b/hutool-core/src/main/java/cn/hutool/core/io/watch/WatchServer.java
index f76bdadbc..e9477cf63 100755
--- a/hutool-core/src/main/java/cn/hutool/core/io/watch/WatchServer.java
+++ b/hutool-core/src/main/java/cn/hutool/core/io/watch/WatchServer.java
@@ -3,6 +3,7 @@ package cn.hutool.core.io.watch;
 import cn.hutool.core.io.IoUtil;
 import cn.hutool.core.lang.Filter;
 import cn.hutool.core.util.ArrayUtil;
+import cn.hutool.core.util.ObjectUtil;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -128,7 +129,7 @@ public class WatchServer extends Thread implements Closeable, Serializable {
 	/**
 	 * 执行事件获取并处理
 	 *
-	 * @param action     监听回调函数，实现此函数接口用于处理WatchEvent事件
+	 * @param action      监听回调函数，实现此函数接口用于处理WatchEvent事件
 	 * @param watchFilter 监听过滤接口，通过实现此接口过滤掉不需要监听的情况，null表示不过滤
 	 * @since 5.4.0
 	 */
@@ -163,7 +164,7 @@ public class WatchServer extends Thread implements Closeable, Serializable {
 	 * @param watchFilter 监听过滤接口，通过实现此接口过滤掉不需要监听的情况，null表示不过滤
 	 */
 	public void watch(Watcher watcher, Filter<WatchEvent<?>> watchFilter) {
-		watch((event, currentPath)->{
+		watch((event, currentPath) -> {
 			final WatchEvent.Kind<?> kind = event.kind();
 
 			if (kind == WatchKind.CREATE.getValue()) {
@@ -178,6 +179,21 @@ public class WatchServer extends Thread implements Closeable, Serializable {
 		}, watchFilter);
 	}
 
+	/**
+	 * 通过 path 获取 watchKey
+	 *
+	 * @param path path
+	 * @return 如果不存在则返回 null
+	 */
+	public WatchKey getWatchKey(Path path) {
+		for (Map.Entry<WatchKey, Path> entry : watchKeyPathMap.entrySet()) {
+			if (ObjectUtil.equals(path, entry.getValue())) {
+				return entry.getKey();
+			}
+		}
+		return null;
+	}
+
 	/**
 	 * 关闭监听
 	 */