1.modify the record method of the number of clients accessing the ser…

database/persistence.go

@@ -25,7 +25,7 @@ func (server *Server) loadRdbFile() error {
 	defer func() {
 		_ = rdbFile.Close()
 	}()
-	decoder := rdb.NewDecoder(rdbFile)
+	decoder := rdb.NewDecoder(rdbFile) // 创建一个新的RDB解码器
 	err = server.LoadRDB(decoder)
 	if err != nil {
 		return fmt.Errorf("load rdb file failed " + err.Error())

database/server.go

@@ -62,12 +62,14 @@ func NewStandaloneServer() *Server {
 		singleDB := makeDB()
 		singleDB.index = i
 		holder := &atomic.Value{}
+		// set init value
 		holder.Store(singleDB)
 		server.dbSet[i] = holder
 	}
 	server.hub = pubsub.MakeHub()
 	// record aof
 	validAof := false
+	// default value is false
 	if config.Properties.AppendOnly {
 		validAof = fileExists(config.Properties.AppendFilename)
 		aofHandler, err := NewPersister(server,
@@ -77,6 +79,7 @@ func NewStandaloneServer() *Server {
 		}
 		server.bindPersister(aofHandler)
 	}
+	// dbfilename value is test.rdb
 	if config.Properties.RDBFilename != "" && !validAof {
 		// load rdb
 		err := server.loadRdbFile()

redis/server/server.go

@@ -60,6 +60,7 @@ func (h *Handler) Handle(ctx context.Context, conn net.Conn) {
 		return
 	}
 
+	// reuse link object in sync.Pool
 	client := connection.NewConn(conn)
 	h.activeConn.Store(client, struct{}{})
 

tcp/server.go

@@ -27,6 +27,7 @@ type Config struct {
 
 // ClientCounter Record the number of clients in the current Godis server
 var ClientCounter int
+var mu sync.Mutex
 
 // ListenAndServeWithSignal binds port and handle requests, blocking until receive stop signal
 func ListenAndServeWithSignal(cfg *Config, handler tcp.Handler) error {
@@ -66,7 +67,11 @@ func ListenAndServe(listener net.Listener, handler tcp.Handler, closeChan <-chan
 		_ = listener.Close() // listener.Accept() will return err immediately
 		_ = handler.Close()  // close connections
 	}()
-
+	increment := func() {
+		mu.Lock()
+		defer mu.Unlock()
+		ClientCounter--
+	}
 	ctx := context.Background()
 	var waitDone sync.WaitGroup
 	for {
@@ -87,8 +92,8 @@ func ListenAndServe(listener net.Listener, handler tcp.Handler, closeChan <-chan
 		waitDone.Add(1)
 		go func() {
 			defer func() {
+				increment()
 				waitDone.Done()
-				ClientCounter--
 			}()
 			handler.Handle(ctx, conn)
 		}()