add subscribe for task update

cachedata/cache.go

@@ -51,5 +51,6 @@ func NewCacheData(ctx context.Context, options RedisConnParam, mysqlConfig model
 	for i := 0; i < cache.maxRoutine; i++ {
 		go cache.queryRoutine()
 	}
+	go cache.SubscribeTaskUpdate()
 	return cache
 }

cachedata/task.go

 package cachedata
 
 import (
+	"context"
 	"encoding/json"
 	"github.com/odysseus/payment/model"
 	"strconv"
@@ -108,3 +109,21 @@ func (c *CacheData) SetTaskDataToRedis(task *model.TaskType) error {
 		return err
 	}
 }
+
+const (
+	TASKUPDATECHANNEL = "task-update"
+)
+
+func (c *CacheData) SubscribeTaskUpdate() {
+	ch := TASKUPDATECHANNEL
+	sub := c.rdb.Subscribe(context.Background(), ch)
+	defer sub.Close()
+	for msg := range sub.Channel() {
+		taskPath := msg.Payload
+		c.pathLru.Remove(taskPath)
+	}
+}
+
+func (c *CacheData) PublichTaskUpdate(path string) error {
+	return c.rdb.Publish(c.ctx, TASKUPDATECHANNEL, path).Err()
+}