fix: set dht to server mode

Author: yxq

system/p2p/dht/discovery.go

@@ -39,7 +39,7 @@ func InitDhtDiscovery(ctx context.Context, host host.Host, peersInfo []peer.Addr
 	//如果不修改DHTProto 则有可能会连入IPFS网络，dhtproto=/ipfs/kad/1.0.0
 	d := new(Discovery)
 
-	kademliaDHT, err := dht.New(ctx, host, dht.V1ProtocolOverride(protocol.ID(fmt.Sprintf(dhtProtoID, chainCfg.GetTitle(), subCfg.Channel))), dht.BootstrapPeers(peersInfo...), dht.DisableAutoRefresh())
+	kademliaDHT, err := dht.New(ctx, host, dht.V1ProtocolOverride(protocol.ID(fmt.Sprintf(dhtProtoID, chainCfg.GetTitle(), subCfg.Channel))), dht.BootstrapPeers(peersInfo...), dht.RoutingTableRefreshPeriod(time.Minute), dht.Mode(dht.ModeServer))
 	if err != nil {
 		panic(err)
 	}

system/p2p/dht/protocol/p2pstore/refresh.go

@@ -1,12 +1,10 @@
 package p2pstore
 
 import (
-	"context"
 	"encoding/hex"
 	"time"
 
 	"github.com/33cn/chain33/types"
-	"github.com/libp2p/go-libp2p-core/peer"
 	kbt "github.com/libp2p/go-libp2p-kbucket"
 )
 
@@ -105,9 +103,6 @@ func (p *Protocol) updateExtendRoutingTable() {
 				continue
 			}
 			_, _ = tmpRoutingTable.TryAddPeer(cPid, true, true)
-			if len(p.Host.Network().Conns()) < 50 && len(p.Host.Network().ConnsToPeer(cPid)) == 0 {
-				p.connect(cPid)
-			}
 		}
 	}
 
@@ -120,16 +115,3 @@ func (p *Protocol) updateExtendRoutingTable() {
 	_ = tmpRoutingTable.Close()
 	log.Info("updateExtendRoutingTable", "pid", p.Host.ID(), "local peers count", p.RoutingTable.Size(), "extendRoutingTable peer count", p.extendRoutingTable.Size(), "time cost", time.Since(start))
 }
-
-func (p *Protocol) connect(pid peer.ID) {
-	ctx, cancel := context.WithTimeout(p.Ctx, 3*time.Second)
-	defer cancel()
-	info := peer.AddrInfo{
-		ID:    pid,
-		Addrs: p.Host.Peerstore().Addrs(pid),
-	}
-	if err := p.Host.Connect(ctx, info); err != nil {
-		log.Error("Host Connect", "err", err, "peer", info.ID)
-	}
-
-}