add fsnotify

go.mod

@@ -10,10 +10,12 @@ require (
 require (
 	github.com/PuerkitoBio/goquery v1.8.0 // indirect
 	github.com/andybalholm/cascadia v1.3.1 // indirect
+	github.com/fsnotify/fsnotify v1.6.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/mmcdole/goxpp v1.1.0 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	golang.org/x/net v0.4.0 // indirect
+	golang.org/x/sys v0.3.0 // indirect
 	golang.org/x/text v0.5.0 // indirect
 )

go.sum

@@ -5,6 +5,8 @@ github.com/andybalholm/cascadia v1.3.1/go.mod h1:R4bJ1UQfqADjvDa4P6HZHLh/3OxWWEq
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/fsnotify/fsnotify v1.6.0 h1:n+5WquG0fcWoWp6xPWfHdbskMCQaFnG6PfBrh1Ky4HY=
+github.com/fsnotify/fsnotify v1.6.0/go.mod h1:sl3t1tCWJFWoRz9R8WJCbQihKKwmorjAbSClcnxKAGw=
 github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
 github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
 github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
@@ -29,6 +31,9 @@ golang.org/x/net v0.4.0 h1:Q5QPcMlvfxFTAPV0+07Xz/MpK9NTXu2VDUuy0FeMfaU=
 golang.org/x/net v0.4.0/go.mod h1:MBQ8lrhLObU/6UmLb4fmbmk5OcyYmqtbGd/9yIeKjEE=
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20220908164124-27713097b956/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.3.0 h1:w8ZOecv6NaNa/zC8944JTU3vz4u6Lagfk4RPQxv92NQ=
+golang.org/x/sys v0.3.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.5.0 h1:OLmvp0KP+FVG99Ct/qFiL/Fhk4zp4QQnZ7b2U+5piUM=

utils/feed.go

@@ -2,10 +2,11 @@ package utils
 
 import (
 	"log"
-	"os"
 	"rss-reader/globals"
 	"rss-reader/models"
 	"time"
+
+	"github.com/fsnotify/fsnotify"
 )
 
 func UpdateFeeds() {
@@ -70,33 +71,47 @@ func GetFeeds() []models.Feed {
 }
 
 func WatchConfigFileChanges(filePath string) {
-	// 获取初始文件信息
+	// 创建一个新的监控器
-	initialFileInfo, err := os.Stat(filePath)
+	watcher, err := fsnotify.NewWatcher()
 	if err != nil {
-		log.Println("无法获取文件信息:", err)
+		log.Fatal(err)
-		return
+	}
+	defer watcher.Close()
+
+	// 添加要监控的文件
+	err = watcher.Add(filePath)
+	if err != nil {
+		log.Fatal(err)
 	}
 
-	for {
+	// 启动一个 goroutine 来处理文件变化事件
-		// 每隔一段时间检查文件是否有变化
+	go func() {
-		time.Sleep(7 * time.Second)
+		for {
-
+			time.Sleep(7 * time.Second)
-		// 获取最新的文件信息
+			select {
-		currentFileInfo, err := os.Stat(filePath)
+			case event, ok := <-watcher.Events:
-		if err != nil {
+				if !ok {
-			log.Println("无法获取文件信息:", err)
+					log.Println("通道关闭1")
-			return
+					return
-		}
+				}
-
+				if event.Op&fsnotify.Write == fsnotify.Write {
-		// 检查文件的修改时间是否有变化
+					log.Println("文件已修改")
-		if currentFileInfo.ModTime() != initialFileInfo.ModTime() {
+					globals.Init()
-			log.Println("文件已修改")
+					formattedTime := time.Now().Format("2006-01-02 15:04:05")
-			initialFileInfo = currentFileInfo
+					for _, url := range globals.RssUrls.Values {
-			globals.Init()
+						go UpdateFeed(url, formattedTime)
-			formattedTime := time.Now().Format("2006-01-02 15:04:05")
+					}
-			for _, url := range globals.RssUrls.Values {
+				}
-				go UpdateFeed(url, formattedTime)
+			case err, ok := <-watcher.Errors:
+				if !ok {
+					log.Println("通道关闭2")
+					return
+				}
+				log.Println("错误:", err)
+				return
 			}
 		}
-	}
+	}()
+
+	select {}
 }