重新测试最快线路时清空之前的缓存记录。

errconn.go

@@ -59,7 +59,7 @@ type ErrConnDomain struct {
 // 异常连接 相关服务
 type ErrConnService struct {
 	lru *lru.Cache // key domainAddr value *ErrConnDomain
-	rwm sync.RWMutex
+	m   sync.Mutex
 }
 
 func NewErrConnService() *ErrConnService {
@@ -86,8 +86,8 @@ func (ec*ErrConnService)set(domain *ErrConnDomain) {
 
 // 增加异常记录
 func (ec*ErrConnService)AddErrLog(dialName, domainAddr, ipAddr string, errType ErrConnType) {
-	ec.rwm.Lock()
-	defer ec.rwm.Unlock()
+	ec.m.Lock()
+	defer ec.m.Unlock()
 
 	d := ec.get(domainAddr)
 	if d == nil {
@@ -107,8 +107,8 @@ func (ec*ErrConnService)AddErrLog(dialName, domainAddr, ipAddr string, errType E
 // 如果启用了全球解析，那么需要挂掉很多ip。
 // 返回值： true 表示安全 false 表示不建议使用
 func (ec*ErrConnService)Check(dialName, domainAddr, ipAddr string) bool {
-	ec.rwm.Lock()
-	defer ec.rwm.Unlock()
+	ec.m.Lock()
+	defer ec.m.Unlock()
 
 	d := ec.get(domainAddr)
 	if d == nil {

upstream_cache.go

@@ -135,3 +135,12 @@ func (c*upStreamConnCache)GetOptimal(domainAddr string) (upStreamConnCacheAddrIt
 	}
 	return upStreamConnCacheAddrItem{}, fmt.Errorf("全部连接有异常。")
 }
+
+// 删除某个域的缓存记录
+// 在每次进行全部连接重试时将会清空旧的缓存内容。
+func (c*upStreamConnCache)Del(domainAddr string) {
+	c.rwm.Lock()
+	defer c.rwm.Unlock()
+
+	c.domains.Remove(domainAddr)
+}

upstream_tcpping.go

@@ -122,6 +122,7 @@ func (su*tcppingUpStream)DialTimeout(network, address string, timeout time.Durat
 	}
 
 	// 缓存未命中时同时使用多个线路尝试连接。
+	su.connCache.Del(address)
 
 	resChan := make(chan dialTimeoutRes, 1)
 	connChan := make(chan netchan.ConnRes, 10)