Golangで学ぶHot deployの仕組み

Server::Starterの仕組みを学び、Golangでミニマムで
 実装してみた

Transcript

1. !UTVSVCFF
   
   (.0
   1FQBCP
   *OD
   
   ۝भΠϯϑϥަྲྀษڧձ ,JYT
   7PM (PMBOHͰֶͿ
   )PU
   EFQMPZͷ࢓૊Έ
2. (.0ϖύϘɹΠϯϑϥΤϯδχΞ !UTVSVCFF
3. ೥݄(.0ϖύϘೖࣾ
   ΠϯϑϥΤϯδχΞྺϲ݄
4. ໨࣍ w)PU
   EFQMPZͱ͸ʁͳͥඞཁ͔ʁ
   w)PU
   EFQMPZͷ࢓૊Έ
   w(PMBOHͰ࣮૷ͯ͠Έͨ
5. ఻͍͑ͨ͜ͱ wμ΢ϯλΠϜθϩΛࢧ͑Δ)PU
   EFQMPZͷ࢓૊ΈͷҰྫ
   w(PMBOHΛ௨ͯ͡௿ϨΠϠʔͷٕज़ΛֶͿ͜ͱͰɺ

   
   ΤϯδχΞͱͯ͠ͷ෯͕޿͕ΔͷͰ͸ʁ
   wٕज़ॻಡΜͰ;Ή;Ή͢ΔΑΓ࣮૷ͯ͠Έͨํ͕ཧղ

   ͠΍͍͢
6. )PU
   EFQMPZͱ͸ʁ
   ͳͥඞཁ͔ʁ
7. )PU
   EFQMPZͱ͸ʁ wΞϓϦέʔγϣϯʹϩδοΫ΍ઃఆ౳ͷมߋΛՃ͑ͨࡍ ʹɺϦΫΤετͷॲཧΛଓ͚ଓ͚ͳ͕Βɺมߋͷ಺༰Λ൓ ө͢ΔͨΊͷखஈ
8. )PU
   EFQMPZͱ͸ʁ wΞϓϦέʔγϣϯʹϩδοΫ΍ઃఆ౳ͷมߋΛՃ͑ͨࡍ ʹɺϦΫΤετͷॲཧΛଓ͚ଓ͚ͳ͕Βɺมߋͷ಺༰Λ൓ ө͢ΔͨΊͷखஈ ҰൠతͳσϓϩΠʢ/05
   )PU
   EFQMPZʣ 4PVSDF
   DPEF
   DIBOHF (PMBOHͷ৔߹ɺ όΠφϦͷ্ॻ͖
9. )PU
   EFQMPZͱ͸ʁ wΞϓϦέʔγϣϯʹϩδοΫ΍ઃఆ౳ͷมߋΛՃ͑ͨࡍ ʹɺϦΫΤετͷॲཧΛଓ͚ଓ͚ͳ͕Βɺมߋͷ಺༰Λ൓ ө͢ΔͨΊͷखஈ ҰൠతͳσϓϩΠʢ/05
   )PU
   EFQMPZʣ 4PVSDF
   DPEF
   DIBOHF
   "QQMJDBUJPO
   4UPQ (PMBOHͷ৔߹ɺ όΠφϦͷ্ॻ͖
10. )PU
    EFQMPZͱ͸ʁ wΞϓϦέʔγϣϯʹϩδοΫ΍ઃఆ౳ͷมߋΛՃ͑ͨࡍ ʹɺϦΫΤετͷॲཧΛଓ͚ଓ͚ͳ͕Βɺมߋͷ಺༰Λ൓ ө͢ΔͨΊͷखஈ ҰൠతͳσϓϩΠʢ/05
    )PU
    EFQMPZʣ 4PVSDF
    DPEF
    DIBOHF
    "QQMJDBUJPO
    4UPQ "QQMJDBUJPO
    
    4UBSU (PMBOHͷ৔߹ɺ όΠφϦͷ্ॻ͖ ࠶ىಈ
11. )PU
    EFQMPZͱ͸ʁ wΞϓϦέʔγϣϯʹϩδοΫ΍ઃఆ౳ͷมߋΛՃ͑ͨࡍ ʹɺϦΫΤετͷॲཧΛଓ͚ଓ͚ͳ͕Βɺมߋͷ಺༰Λ൓ ө͢ΔͨΊͷखஈ ҰൠతͳσϓϩΠʢ/05
    )PU
    EFQMPZʣ 4PVSDF
    DPEF
    DIBOHF
    "QQMJDBUJPO
    4UPQ "QQMJDBUJPO
    
    4UBSU (PMBOHͷ৔߹ɺ όΠφϦͷ্ॻ͖ ϦΫΤετΛॲཧ
    Ͱ͖ͳ͍͕࣌ؒൃੜ ࠶ىಈ
12. )PU
    EFQMPZ͕ͳͥඞཁ͔ʁ wΘ͔ͣͳؒͰ΋Քಇ͍ͯ͠ΔαʔϏεΛࢭΊͨ͘ͳ͍
    w)PU
    EFQMPZΛಋೖ͢Δ͜ͱͰɺγεςϜӡ༻ʹ͓͚Δ

    อकੑ͕޲্͠ɺਝ଎ͳ։ൃαΠΫϧ͕࣮ݱͰ͖Δ
13. )PU
    EFQMPZͷ࢓૊Έ
14. 4FSWFS4UBSUFS w؆୯ʹ)PU
    EFQMPZͰ͖ΔΑ͏ʹ͢ΔͨΊͷDQBO
    NPEVMF
    w1FSMͰ࣮૷͞Ε͍ͯΔ͕ɺγάφϧͱ؀ڥม਺Λ࢖ͬͨ

    ൚༻ੑͷߴ͍࢓૊ΈͷͨΊɺ͞·͟·ͳݴޠͰར༻Մೳ
15. 4FSWFS4UBSUFS w؆୯ʹ)PU
    EFQMPZͰ͖ΔΑ͏ʹ͢ΔͨΊͷDQBO
    NPEVMF
    w1FSMͰ࣮૷͞Ε͍ͯΔ͕ɺγάφϧͱ؀ڥม਺Λ࢖ͬͨ

    ൚༻ੑͷߴ͍࢓૊ΈͷͨΊɺ͞·͟·ͳݴޠͰར༻Մೳ ಈ࡞Λݴ༿Ͱઆ໌͢Δͱɾɾ ʮ৽͍͠ϓϩηεΛىಈͯ͠৽͍͠ϦΫΤετΛͦͪΒʹ ྲྀͭͭ͠ɺݹ͍ϓϩηεͷϦΫΤετ͕׬ྃͨ͠Βਖ਼͘͠ ऴྃͤ͞Δʯ
16. 4FSWFS4UBSUFS w؆୯ʹ)PU
    EFQMPZͰ͖ΔΑ͏ʹ͢ΔͨΊͷDQBO
    NPEVMF
    w1FSMͰ࣮૷͞Ε͍ͯΔ͕ɺγάφϧͱ؀ڥม਺Λ࢖ͬͨ

    ൚༻ੑͷߴ͍࢓૊ΈͷͨΊɺ͞·͟·ͳݴޠͰར༻Մೳ ಈ࡞Λݴ༿Ͱઆ໌͢Δͱɾɾ ʮ৽͍͠ϓϩηεΛىಈͯ͠৽͍͠ϦΫΤετΛͦͪΒʹ ྲྀͭͭ͠ɺݹ͍ϓϩηεͷϦΫΤετ͕׬ྃͨ͠Βਖ਼͘͠ ऴྃͤ͞Δʯ (SBDFGVM
    3FTUBSUʢ༏խͳ࠶ىಈʣ
17. )PU
    EFQMPZͷ࢓૊Έʢ؆қ൛ʣ TUBSU@TFSWFS
    1BSFOU start_server —-port 8888 —- ./server TFSWFS
    $IJME TPDLFU GPSL
    
    FYFD TPDLFUΛڞ༗ BDDFQU TUBSU@TFSWFSɿ(SBDFGVM
    SFTUBSUͷͨΊͷϓϩάϥϜ
    TFSWFS
    
    
    
    
    
    
    
    
    ɿ࣮ߦ͍ͨ͠ϓϩάϥϜ
18. )PU
    EFQMPZͷ࢓૊Έʢ؆қ൛ʣ TUBSU@TFSWFS
    1BSFOU start_server —-port 8888 —- ./server TFSWFS
    $IJME TPDLFU GPSL
    
    FYFD TPDLFUΛڞ༗ BDDFQU TUBSU@TFSWFSɿ(SBDFGVM
    SFTUBSUͷͨΊͷϓϩάϥϜ
    TFSWFS
    
    
    
    
    
    
    
    
    ɿ࣮ߦ͍ͨ͠ϓϩάϥϜ ᶃ
    ϓϩάϥϜʹมߋʂ
19. )PU
    EFQMPZͷ࢓૊Έʢ؆қ൛ʣ kill -HUP <master pid> TPDLFU BDDFQU TUBSU@TFSWFS
    1BSFOU TFSWFS
    $IJME TUBSU@TFSWFSɿ(SBDFGVM
    SFTUBSUͷͨΊͷϓϩάϥϜ
    TFSWFS
    
    
    
    
    
    
    
    
    ɿ࣮ߦ͍ͨ͠ϓϩάϥϜ ᶄ
    4*()61 ᶃ
    ϓϩάϥϜʹมߋʂ
20. )PU
    EFQMPZͷ࢓૊Έʢ؆қ൛ʣ kill -HUP <master pid> TPDLFU GPSL
    
    FYFD TFSWFS
    $IJME ᶄ
    4*()61 BDDFQU BDDFQU TUBSU@TFSWFS
    1BSFOU TFSWFS
    $IJME ᶅ
    ৽ϓϩάϥϜͰىಈ ᶃ
    ϓϩάϥϜʹมߋʂ
21. )PU
    EFQMPZͷ࢓૊Έʢ؆қ൛ʣ kill -HUP <master pid> TPDLFU
    ऴྃ͢Δલʹʜ
    
    
    ᶃ৽نϦΫΤεड෇
    ɹ
    ͷఀࢭ
    
    ᶄݱࡏॲཧதͷ
    
    
    
    
    ϦΫΤετͷ׬ྃ GPSL
    
    FYFD (SBDFGVM
    4IVUEPXO BDDFQU BDDFQU TUBSU@TFSWFS
    1BSFOU TFSWFS
    $IJME ᶅ
    ৽ϓϩάϥϜͰىಈ ᶄ
    4*()61 ᶆ
    4*(5&3. TFSWFS
    $IJME ᶃ
    ϓϩάϥϜʹมߋʂ
22. )PU
    EFQMPZͷ࢓૊Έʢ؆қ൛ʣ TUBSU@TFSWFS
    1BSFOU kill -HUP <master pid> TPDLFU GPSL
    
    FYFD TFSWFS
    $IJME BDDFQU ᶆ
    4*(5&3. ᶅ
    ৽ϓϩάϥϜͰىಈ ᶄ
    4*()61 TFSWFS
    $IJME ᶃ
    ϓϩάϥϜʹมߋʂ
    ऴྃ͢Δલʹʜ
    
    
    ᶃ৽نϦΫΤεड෇
    ɹ
    ͷఀࢭ
    
    ᶄݱࡏॲཧதͷ
    
    
    
    
    ϦΫΤετͷ׬ྃ (SBDFGVM
    4IVUEPXO
23. ࣮૷ͯ͠Έͨ
24. ϛχϚϜͰ࣮૷ͯ͠Έͨ IUUQTHJUIVCDPNUTVSVCFFHSBDFGVMSFTUBSUHP
25. ࣮૷ϙΠϯτ̍
    ʙγάφϧϋϯυϥ func waitSignal(l net.Listener) { c := make(chan os.Signal, 1) signal.Notify(c, syscall.SIGTERM) go func() { sig := <-c switch sig { case syscall.SIGTERM: signal.Stop(c) l.Close() } }() } γάφϧͱ͸ϓϩηεؒ௨৴ͷҰछ
    ϓϩηεʹγάφϧΛૹ৴͢Δͱɺͦͷϓϩηεͷਖ਼ৗॲཧʹׂΓࠐΜͰɺ γάφϧݻ༗ͷॲཧΛ࣮ߦͰ͖Δ ͓खܰʹγάφϧͷϋϯυϦϯά͕ Ͱ͖Δ
26. ࣮૷ϙΠϯτ̍
    ʙγάφϧϋϯυϥ func waitSignal(l net.Listener) { c := make(chan os.Signal, 1) signal.Notify(c, syscall.SIGTERM) go func() { sig := <-c switch sig { case syscall.SIGTERM: signal.Stop(c) l.Close() } }() } γάφϧͱ͸ϓϩηεؒ௨৴ͷҰछ
    ϓϩηεʹγάφϧΛૹ৴͢Δͱɺͦͷϓϩηεͷਖ਼ৗॲཧʹׂΓࠐΜͰɺ γάφϧݻ༗ͷॲཧΛ࣮ߦͰ͖Δ HPSPVUJOFͰγάφϧΛ଴ͪड͚Δ ͓खܰʹγάφϧͷϋϯυϦϯά͕ Ͱ͖Δ
27. ࣮૷ϙΠϯτ̎
    ʙ
    ϑΝΠϧσΟεΫϦϓλ func forkExec(l *net.TCPListener) (*os.Process, error) { progName, _ := exec.LookPath(os.Args[0]) pwd, _ := os.Getwd() f, _ := l.File() defer f.Close() files := []*os.File{os.Stdin, os.Stdout, os.Stderr, f} fdEnv := fmt.Sprintf("%s=%d", "FD_KEY", len(files)-1) return os.StartProcess(progName, os.Args, &os.ProcAttr{ Dir: pwd, Env: append(os.Environ(), fdEnv), Files: files, }) } ϑΝΠϧσΟεΫϓϦΫλ͸ɺϑΝΠϧ΍ιέοτͳͲΛந৅Խͨ͠࢓૊Έ
    ϓϩηεΛGPSLͨ͠ࡍ͸ɺ਌ϓϩηεͷϑΝΠϧσΟεΫϦϓλΛҾ͖ܧ͙
28. ·ͱΊ w4FSWFS4UBSUFSͷ࢓૊ΈΛֶͼɺ(PMBOHͰϛχϚϜͰ

    ࣮૷ͯ͠Έͨ
    wγάφϧ΍ϑΝΠϧσΟεΫϦϓλͱ͍ͬͨ֓೦͸ٕज़ॻΛಡ ΜͰ;Ή;Ή͢ΔΑΓɺ࣮૷ͯ͠Έͨ΄͏͕ཧղ͠΍͔ͬͨ͢
    w(PMBOH͸ଟ͘ͷ04ͷػೳΛ؆ܿͳίʔυͰѻ͑ΔͨΊɺ

    ࣗ෼ͷؔ৺ྖҬΛΑΓ௿͍ϨΠϠʔʹ޿͍͛ͯͨ͘Ίʹ

    దͨ͠ݴޠͩ
29. ͋Γ͕ͱ͏͍͟͝·ͨ͠ʂʂ