fix bug

server/workerManager.go

@@ -605,7 +605,6 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
 				l.WithFields(log.Fields{
 					"worker-addr": worker.workerAddr,
 				}).Debug("receive registed message")
-				worker.registed = true
 
 				if pubkey, err := utils.HexToPubkey(msg.RegisteMessage.MinerPubkey); err != nil {
 					l.WithFields(log.Fields{
@@ -613,8 +612,15 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
 						"error":       err,
 					}).Error("parse pubkey failed")
 				} else {
-					worker.workerAddr = utils.PubkeyToAddress(pubkey)
+					addr := utils.PubkeyToAddress(pubkey)
+					if wm.GetWorkerByAddr(addr) != nil {
+						l.WithField("worker-addr", worker.workerAddr).Error("worker with the address is existed")
+						worker.quit <- ErrWorkerExist
+						return
+					}
+					worker.workerAddr = addr
 				}
+				worker.registed = true
 				wm.SetWorkerAddr(worker, worker.workerAddr)
 
 				wreg := workerRegistry{