摘要：在用自定義網(wǎng)絡(luò)跑容器的時候發(fā)現(xiàn)一個問題的自定義網(wǎng)絡(luò)啟動會延遲大概秒換句話說就是如果你使用自定義網(wǎng)絡(luò)在一個容器啟動時想訪問另外一個容器會失敗但是如果你先等待秒再訪問的話就一切正常如果你使用自定義網(wǎng)絡(luò)在一個容器啟動時另外一個容器會卡住一段時間。

在用自定義Docker網(wǎng)絡(luò)跑容器的時候發(fā)現(xiàn)一個問題：Docker的自定義網(wǎng)絡(luò)啟動會延遲大概40秒！

換句話說就是：

如果你使用自定義網(wǎng)絡(luò)在一個容器啟動時想訪問另外一個容器會失敗！但是如果你先等待40秒再訪問的話就一切正常！
如果你使用自定義網(wǎng)絡(luò)在一個容器啟動時ping另外一個容器會卡住一段時間。

解決：加上啟動腳本檢測網(wǎng)絡(luò)是否就緒！

可以用類似下面的腳本檢測服務(wù)是否就緒，或者干脆檢查dmesg消息也可以

until nc -z zk 2181; do echo "waiting for zk to be ready"; sleep 0.5; done

在用自定義Docker網(wǎng)絡(luò)跑Kafka的時候發(fā)現(xiàn)一個現(xiàn)象：zk服務(wù)正常，但是 Kafka始終報告連接不上zk

$ docker run --net=br --ip=192.168.33.88 --name=zk -h=zk -d wurstmeister/zookeeper
$ docker run --net=br --ip=192.168.33.91 --name=kf1 -h=kf1 
 -e KAFKA_ZOOKEEPER_CONNECT=zk 
 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kf1:9092 
 -e KAFKA_BROKER_ID=1 
 --link zk:zk 
 -it wurstmeister/kafka

運(yùn)行后始終報錯：

java.net.NoRouteToHostException: No route to host
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)

而如果你不用自定義網(wǎng)絡(luò)的話則一切正常！

$ docker run --name=zk -h=zk -d wurstmeister/zookeeper
$ docker run --name=kf1 -h=kf1 
 -e KAFKA_ZOOKEEPER_CONNECT=zk 
 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kf1:9092 
 -e KAFKA_BROKER_ID=1 
 --link zk:zk 
 -it wurstmeister/kafka

那么問題在哪里呢？經(jīng)過跟蹤后終于發(fā)現(xiàn)問題在于Docker的自定義網(wǎng)絡(luò)啟動會延遲大概40秒！需要等容器實(shí)例dmesg中出現(xiàn)下列消息的時才能正常訪問網(wǎng)絡(luò)中的其他容器實(shí)例，這個等待時間大概是40秒

[ 1077.847733] docker1: topology change detected, propagating

問題找到了，搜索了一圈也沒有找到怎么讓這個延遲時間消失的解決方法，好吧，用土辦法：既然是因?yàn)榫W(wǎng)絡(luò)還沒準(zhǔn)備好，那就等它準(zhǔn)備好！

可以用類似下面的腳本檢測服務(wù)是否就緒，或者干脆檢查dmesg消息也可以

until nc -z zk 2181; do echo "waiting for zk to be ready"; sleep 0.5; done

那么只要在Docker容器真正開始運(yùn)行之前先運(yùn)行上面的腳本檢測網(wǎng)絡(luò)是否就緒就可以了，查了一下wurstmeister/zookeeper正好有一個CUSTOM_INIT_SCRIPT參數(shù)可以干這個事，妥了！

$ docker run --net=br --ip=192.168.33.88 --name=zk -h=zk -d wurstmeister/zookeeper
$ docker run --net=br --ip=192.168.33.91 --name=kf1 -h=kf1 
 -e KAFKA_ZOOKEEPER_CONNECT=zk 
 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kf1:9092 
 -e KAFKA_BROKER_ID=1 
 -e CUSTOM_INIT_SCRIPT="until nc -z zk 2181; do echo "waiting for zk to be ready"; sleep 1; done" 
 --link zk:zk 
 -it wurstmeister/kafka

waiting for kafka to be ready
waiting for zk service ready
......
[2017-12-11 09:04:51,046] INFO [Partition user_events-0 broker=1] No checkpointed highwatermark is found for partition user_events-0 (kafka.cluster.Partition)
[2017-12-11 09:04:51,047] INFO Replica loaded for partition user_events-0 with initial high watermark 0 (kafka.cluster.Replica)
[2017-12-11 09:04:51,050] INFO [Partition user_events-0 broker=1] user_events-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition)
[2017-12-11 09:04:51,087] INFO [ReplicaFetcherManager on broker 1] Removed fetcher for partitions user_events-0 (kafka.server.ReplicaFetcherManager)
[2017-12-11 09:04:51,087] INFO [Partition user_events-0 broker=1] user_events-0 starts at Leader Epoch 1 from offset 0. Previous Leader Epoch was: 0 (kafka.cluster.Partition)

另外：

這個方法也適用于啟動時需要依賴其他服務(wù)就緒的情況，比如等待數(shù)據(jù)庫就緒等

或者某些容器服務(wù)初始化時間較長，另外的容器需要等它就緒等

https://github.com/SixQuant/e...