成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專(zhuān)欄INFORMATION COLUMN

Docker Issue Network Delay(自定義網(wǎng)絡(luò)啟動(dòng)會(huì)延遲大概40秒?。?

microcosm1994 / 3878人閱讀

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

Docker Issue Network Delay

在用自定義Docker網(wǎng)絡(luò)跑容器的時(shí)候發(fā)現(xiàn)一個(gè)問(wèn)題:Docker的自定義網(wǎng)絡(luò)啟動(dòng)會(huì)延遲大概40秒!

換句話(huà)說(shuō)就是:

如果你使用自定義網(wǎng)絡(luò)在一個(gè)容器啟動(dòng)時(shí)想訪(fǎng)問(wèn)另外一個(gè)容器會(huì)失?。〉侨绻阆鹊却?0秒再訪(fǎng)問(wèn)的話(huà)就一切正常!

如果你使用自定義網(wǎng)絡(luò)在一個(gè)容器啟動(dòng)時(shí)ping另外一個(gè)容器會(huì)卡住一段時(shí)間。

解決:加上啟動(dòng)腳本檢測(cè)網(wǎng)絡(luò)是否就緒!

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

until nc -z zk 2181; do echo "waiting for zk to be ready"; sleep 0.5; done
現(xiàn)象

在用自定義Docker網(wǎng)絡(luò)跑Kafka的時(shí)候發(fā)現(xiàn)一個(gè)現(xiàn)象:zk服務(wù)正常,但是 Kafka始終報(bào)告連接不上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)行后始終報(bào)錯(cuò):

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ò)的話(huà)則一切正常!

$ 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
分析

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

[ 1077.847733] docker1: topology change detected, propagating
解決

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

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

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

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

$ 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)

另外:

這個(gè)方法也適用于啟動(dòng)時(shí)需要依賴(lài)其他服務(wù)就緒的情況,比如等待數(shù)據(jù)庫(kù)就緒等

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

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

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

轉(zhuǎn)載請(qǐng)注明本文地址:http://systransis.cn/yun/27164.html

相關(guān)文章

  • 一次網(wǎng)站的性能優(yōu)化之路 -- 天下武功,唯快不破

    摘要:百度搜索資源平臺(tái)有閃電算法的支持,為了能夠保障用戶(hù)體驗(yàn),給予優(yōu)秀站點(diǎn)更多面向用戶(hù)的機(jī)會(huì),閃電算法在年月初上線(xiàn)。下欄是每一個(gè)指標(biāo)的細(xì)化性能評(píng)估。最后優(yōu)化之路漫漫,永無(wú)止境,天下武功,唯快不破。 showImg(https://segmentfault.com/img/remote/1460000018537491); 首屏作為直面用戶(hù)的第一屏,其重要性不言而喻,如何加快加載的速度是非常重...

    mudiyouyou 評(píng)論0 收藏0
  • Spring Cloud Stream 使用延遲消息實(shí)現(xiàn)定時(shí)任務(wù)(RabbitMQ)

    摘要:然而實(shí)際業(yè)務(wù)中還存在另外一種定時(shí)任務(wù),它可能需要一些觸發(fā)條件才開(kāi)始定時(shí),比如編寫(xiě)博文時(shí)候,設(shè)置小時(shí)之后發(fā)送。在消息監(jiān)聽(tīng)類(lèi)中,對(duì)通道定義了,這里會(huì)對(duì)延遲消息做具體的邏輯。由于消息的消費(fèi)是延遲的,從而變相實(shí)現(xiàn)了從消息發(fā)送那一刻起開(kāi)始的定時(shí)任務(wù)。 應(yīng)用場(chǎng)景 我們?cè)谑褂靡恍╅_(kāi)源調(diào)度系統(tǒng)(比如:elastic-job等)的時(shí)候,對(duì)于任務(wù)的執(zhí)行時(shí)間通常都是有規(guī)律性的,可能是每隔半小時(shí)執(zhí)行一次,或者...

    honhon 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

microcosm1994

|高級(jí)講師

TA的文章

閱讀更多
最新活動(dòng)
閱讀需要支付1元查看
<