一次排查多線程引發(fā)Java DNS緩存的Bug

cocopeak 發(fā)布于2019-08-16 11:09 / 3031人閱讀

摘要：問題描述最近通知應(yīng)用在近三個月內(nèi)出現(xiàn)過次緩存的問題，第一次在重啟之后一直沒有出現(xiàn)過問題，所以也沒有去重視，但是最近又出現(xiàn)過一次，看來很有必要徹底排查一次具體的錯誤日志如下具體表現(xiàn)就是出現(xiàn)此異常之后連續(xù)的出現(xiàn)大量此異常

問題描述
最近通知應(yīng)用在近三個月內(nèi)出現(xiàn)過2次DNS緩存的問題，第一次在重啟之后一直沒有出現(xiàn)過問題，所以也沒有去重視，但是最近又出現(xiàn)過一次，看來很有必要徹底排查一次；具體的錯誤日志如下：

</>復(fù)制代碼 
2018-03-16 18:53:59,501 ERROR [DefaultMessageListenerContainer-1] (com.bill99.asap.service.CryptoClient.seal(CryptoClient.java:34))- null
java.lang.NullPointerException
    at java.net.InetAddress$Cache.put(InetAddress.java:779) ~[?:1.7.0_79]
    at java.net.InetAddress.cacheAddresses(InetAddress.java:858) ~[?:1.7.0_79]
    at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1334) ~[?:1.7.0_79]
    at java.net.InetAddress.getAllByName0(InetAddress.java:1248) ~[?:1.7.0_79]
    at java.net.InetAddress.getAllByName(InetAddress.java:1164) ~[?:1.7.0_79]
    at java.net.InetAddress.getAllByName(InetAddress.java:1098) ~[?:1.7.0_79]
    at java.net.InetAddress.getByName(InetAddress.java:1048) ~[?:1.7.0_79]
    at java.net.InetSocketAddress.(InetSocketAddress.java:220) ~[?:1.7.0_79]
    at sun.net.NetworkClient.doConnect(NetworkClient.java:180) ~[?:1.7.0_79]
    at sun.net.www.http.HttpClient.openServer(HttpClient.java:432) ~[?:1.7.0_79]
    at sun.net.www.http.HttpClient.openServer(HttpClient.java:527) ~[?:1.7.0_79]
    at sun.net.www.http.HttpClient.(HttpClient.java:211) ~[?:1.7.0_79]
    at sun.net.www.http.HttpClient.New(HttpClient.java:308) ~[?:1.7.0_79]
    at sun.net.www.http.HttpClient.New(HttpClient.java:326) ~[?:1.7.0_79]
    at sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:997) ~[?:1.7.0_79]
    at sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:933) ~[?:1.7.0_79]
    at sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:851) ~[?:1.7.0_79]
    at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1092) ~[?:1.7.0_79]
    at org.springframework.ws.transport.http.HttpUrlConnection.getRequestOutputStream(HttpUrlConnection.java:81) ~[spring-ws-core.jar:1.5.6]
    at org.springframework.ws.transport.AbstractSenderConnection$RequestTransportOutputStream.createOutputStream(AbstractSenderConnection.java:101) ~[spring-ws-core.jar:1.5.6]
    at org.springframework.ws.transport.TransportOutputStream.getOutputStream(TransportOutputStream.java:41) ~[spring-ws-core.jar:1.5.6]
    at org.springframework.ws.transport.TransportOutputStream.write(TransportOutputStream.java:60) ~[spring-ws-core.jar:1.5.6]

具體表現(xiàn)就是出現(xiàn)此異常之后連續(xù)的出現(xiàn)大量此異常，同時系統(tǒng)節(jié)點不可用；

問題分析
1.既然InetAddress$Cache.put報空指針，那就具體看一下源代碼：

</>復(fù)制代碼 
if (policy != InetAddressCachePolicy.FOREVER) {
     // As we iterate in insertion order we can
     // terminate when a non-expired entry is found.
     LinkedList expired = new LinkedList<>();
     long now = System.currentTimeMillis();
     for (String key :  ) {
            CacheEntry entry = cache.get(key);
 
            if (entry.expiration >= 0 && entry.expiration < now) {
                    expired.add(key);
            } else {
                    break;
            }
     }
 
     for (String key : expired) {
            cache.remove(key);
     }
}

報空指針的的地方就是entry.expiration，也就是說從cache取出來的entry為null，可以查看cache寫入的地方：

</>復(fù)制代碼 
CacheEntry entry = new CacheEntry(addresses, expiration);
cache.put(host, entry);

每次都是new一個CacheEntry然后再put到cache中，不會寫入null進(jìn)去；此時猜測是多線程引發(fā)的問題，cache.keySet()在遍歷的時候同時也進(jìn)行了remove操作，導(dǎo)致cache.get(key)到一個空值，查看源代碼可以發(fā)現(xiàn)一共有兩次對cache進(jìn)行remove的地方，分別是put方法和get方法，put方法代碼如上，每次在遍歷的時候檢測是否過期，然后統(tǒng)一進(jìn)行remove操作；還有一處就是get方法，代碼如下：

</>復(fù)制代碼 
public CacheEntry get(String host) {
       int policy = getPolicy();
       if (policy == InetAddressCachePolicy.NEVER) {
             return null;
       }
       CacheEntry entry = cache.get(host);
 
       // check if entry has expired
       if (entry != null && policy != InetAddressCachePolicy.FOREVER) {
             if (entry.expiration >= 0 && entry.expiration < System.currentTimeMillis()) {
                    cache.remove(host);
                    entry = null;
              }
       }
       return entry;
 }

類似put方法也是每次在get的時候進(jìn)行有效期檢測，然后進(jìn)行remove操作；
所以如果出現(xiàn)多線程問題大概就是：1.同時調(diào)用put，get方法，2.多個線程都調(diào)用put方法；繼續(xù)查看源碼調(diào)用put和get的地方，一共有三處分別是：

</>復(fù)制代碼 
private static void cacheInitIfNeeded() {
        assert Thread.holdsLock(addressCache);
        if (addressCacheInit) {
            return;
        }
        unknown_array = new InetAddress[1];
        unknown_array[0] = impl.anyLocalAddress();
 
        addressCache.put(impl.anyLocalAddress().getHostName(),
                         unknown_array);
 
        addressCacheInit = true;
    }
 
    /*
     * Cache the given hostname and addresses.
     */
    private static void cacheAddresses(String hostname,
                                       InetAddress[] addresses,
                                       boolean success) {
        hostname = hostname.toLowerCase();
        synchronized (addressCache) {
            cacheInitIfNeeded();
            if (success) {
                addressCache.put(hostname, addresses);
            } else {
                negativeCache.put(hostname, addresses);
            }
        }
    }
 
    /*
     * Lookup hostname in cache (positive & negative cache). If
     * found return addresses, null if not found.
     */
    private static InetAddress[] getCachedAddresses(String hostname) {
        hostname = hostname.toLowerCase();
 
        // search both positive & negative caches
 
        synchronized (addressCache) {
            cacheInitIfNeeded();
 
            CacheEntry entry = addressCache.get(hostname);
            if (entry == null) {
                entry = negativeCache.get(hostname);
            }
 
            if (entry != null) {
                return entry.addresses;
            }
        }
 
        // not found
        return null;
    }

cacheInitIfNeeded只在cacheAddresses和getCachedAddresses方法中被調(diào)用，用來檢測cache是否已經(jīng)被初始化了；而另外兩個方法都加了對象鎖addressCache，所以不會多線程問題；

2.猜測外部直接調(diào)用了addressCache，沒有使用內(nèi)部提供的方法
查看源碼可以發(fā)現(xiàn)addressCache本身是私有屬性，也不存在對外的訪問方法

</>復(fù)制代碼 
private static Cache addressCache = new Cache(Cache.Type.Positive);

那業(yè)務(wù)代碼中應(yīng)該也不能直接使用，除非使用反射的方式，隨手搜了一下全局代碼查看關(guān)鍵字”addressCache”，搜到了類似如下代碼：

</>復(fù)制代碼 
static{
      Class clazz = java.net.InetAddress.class;  
      final Field cacheField = clazz.getDeclaredField("addressCache");  
      cacheField.setAccessible(true);  
      final Object o = cacheField.get(clazz);  
      Class clazz2 = o.getClass();  
      final Field cacheMapField = clazz2.getDeclaredField("cache");  
      cacheMapField.setAccessible(true);  
      final Map cacheMap = (Map)cacheMapField.get(o); 
}

通過反射的方式獲取了addressCache對象，然后又獲取了cache對象（cache是一個LinkedHashMap）,同時提供了一個類似如下的方法：

</>復(fù)制代碼 
    public class TEst {
 
    public static void main(String[] args) throws IOException, InterruptedException {
        final LinkedHashMap map = new LinkedHashMap<>();
        new Thread(new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < 2000; i++) {
                    map.put(new Random().nextInt(1000), new HH(new Random(100).nextInt()));
                }
            }
        }).start();
        for (int i = 0; i < 100; i++) {
            new Thread(new Runnable() {
 
                @Override
                public void run() {
                    for (int i = 0; i < 500; i++) {
                        map.remove(new Random().nextInt(1000));
                    }
                }
            }).start();
        }
        Thread.sleep(2000);
        System.out.println("size=" + map.keySet().size() + "," + map.keySet());
        for (Integer s : map.keySet()) {
            System.out.println(map.get(s));
        }
    }
}
 
class HH {
    private int k;
 
    public HH(int k) {
        this.k = k;
    }
 
    public int getK() {
        return k;
    }
 
    public void setK(int k) {
        this.k = k;
    }
}

模擬單線程put操作，業(yè)務(wù)端會有多條線程同時remove操作，執(zhí)行看輸出結(jié)果(可以執(zhí)行多次看結(jié)果)：

</>復(fù)制代碼 
size=0,[121, 517, 208]
null
null
null

可以發(fā)現(xiàn)會出現(xiàn)猜測的情況，HashMap中的size屬性本身不是線程安全的，所以多線程的情況下有可能出現(xiàn)0，這樣導(dǎo)致get方法獲取都為null，當(dāng)然HashMap還有很多其他的多線程問題，因為HashMap也不是為多線程準(zhǔn)備的，至此大概了解了原因。

問題解決
給反射獲取的cache對象加上和cacheAddresses方法同樣的鎖，或者直接不在業(yè)務(wù)代碼中處理cache對象；可以借鑒一下阿里在github開源的操作dns緩存的項目：https://github.com/alibaba/ja...

總結(jié)
本次排查問題花了一些時間在排查是不是jdk提供的類是不是有bug，這其實是有些浪費時間的；還有就是在排查問題中不要放過任何一種可能往往問題就發(fā)生在那些理所當(dāng)然的地方。

云服務(wù)器 GPU云服務(wù)器 java線程運行一次多線程緩存 java多線程多線程調(diào)試 java

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://specialneedsforspecialkids.com/yun/71053.html

發(fā)表評論

登陸后可評論

0條評論

cocopeak

男|高級講師

我要關(guān)注我要私信

TA的文章

優(yōu)點知識Kubernetes網(wǎng)絡(luò)訓(xùn)練營

閱讀 2829·2021-11-22 15:11
LiCloud：香港CMI/香港CN2+BGP/華為云香港服務(wù)器;E3-1230v2/16GB內(nèi)存/

閱讀 3548·2021-09-28 09:43
AngularJS自定義表單驗證

閱讀 2896·2019-08-30 13:05
如何把一個項目從Git本地倉庫上傳到github上

閱讀 3436·2019-08-30 11:18
HTML與CSS中的,鏈接與圖像個人分享

閱讀 1453·2019-08-29 16:34
微信小程序過長文本折疊效果的探索

閱讀 1308·2019-08-29 13:53
巧用CSS遮罩

閱讀 2915·2019-08-29 11:03
CSS中的負(fù)邊距

閱讀 1667·2019-08-29 10:57

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

一次排查多線程引發(fā)Java DNS緩存的Bug

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼

</>復(fù)制代碼