PHPer's Guide to Daemon Crafting Taming and Summoning

at: PHPerKaigi 2025
date: 2025/03/22
speaker: uzulla

Transcript

1. PHPer's Guide to Daemon Crafting, Taming and Summoning
2. Re:લઆ
3. ݩؾͰ͔͢ʂ
4. ݩؾ͸͋Ε͹ͳΜͰ΋Ͱ͖Δʂ
5. ͕ʂ PHPͱ͍͑͹ Apache΍Nginx͕͍ͳ͍ͱ͏͔͝ͳ͍ ಠΓཱͪͰ͖ͳ͍ݴޠ (ॾઆ͋Δ)
6. ࢲʮॻ͚Δ΍Ζ(աڈͷτʔΫࢀর)ʯ ʁʮPHPͰhttpdΛॻ͘ is ೉ͦ͠͏ʯ ࢲʮී௨ʹ΍Ε͹Α͍(աڈͷτʔΫࢀর)ʯ ʁʮͦ͏͍͏ͱ͜ΖͰ͢Αʁʁʁʁʯ
7. ! GoogleʮPHPͰσʔϞϯʁ஌Βͳ͍ʂʯ ! Copolotʮ๻͸αϙʔτͳΜͰ…ʯ ! ChatGPTʮ௕͍ͷ͸ແཧͰ͢ʯ
8. …ͦΜͳઈ๬ͷ࣌୅͕ଓ͖·ͨ͠ ʢԶҎ֎͸ͦ͏Ͱ΋ͳ͍͔ʁʁʁʁʣ
9. ͔͠͠ʂ2025೥ʂʂʂʂ ͍ͭʹٹੈओ͕ݱΕͨʂʂ
10. Devin/Claude code:ɹɹ ʮ͑ɺ͓લPHPͰσʔϞϯॻ͚ͳ͍ͷʁ ॻ͍ͯ΍ΔΑʯ
11. ͍ͭʹʮͳʹ΋͔΋Θ͔ΒΜ࣌୅ʯ͕ऴΘͬͨ… ʢ͍΍ɺਓؒ͸ͳʹ΋͔΋Θ͔ͬͯ͸͓ΒΜ͕ɺಈ࡞͢Δαϯϓϧ͕ݟΕΔʂʣ
12. Ͱɺͩɻ
13. ࠓճࢲ͸AIʹίʔυΛॻ͔͍ͤͯ·͕͢ Θ͟ͱͰ͢
14. ෛ͚੯͠ΈͰ͸ͳ͘ʂʂʂ ࢲࣗ਎͕θϩ͔ΒίʔυΛॻ͚ͳ͍Θ͚Ͱ͸ͳ͍ʂʂ(ͬͯ͠ΔͩΖʂ) ෛ͚੯͠ΈͰ͸ͳ͘ʂʂʂ Θ͟ͱͰ͢ʂʂʂʂʂʂ
15. օ͞Μ͕खʹೖΕΒΕΔͱ͍͏ࣄ͕ॏཁͳͷͰ͢ʂ
16. ʁʮPHPͰσʔϞϯʁ͍Έ͋Δͷʁʯ ࢲʮϩϚϯ͕͋Γ·͢ʂʂʂʂʂʂʯ
17. ҰൠతͳΠϝʔδ
18. Apache΋Nginx΋ඞཁ͕ͳ͍ PHP γϯάϧϓϩηε୯ମͰಈ͘ϓϩάϥϜ ڵຯ͕͋Γ·ͤΜ͔ʂʁ(Զ͚͔ͩʁ)
19. ࠓճλΠτϧੌͭ͘·Βͳͦ͏͡Όͳ͍Ͱ͔͢ʂʂʂ Ͱ΋͍ͭʹγάφϧॲཧ΍systemd౳ͷ࿩୊͕໾ཱͭΜͰ͢ʂʂʂ
20. ʮѱ͍ͳɺσʔϞϯ੡࡞͸PHPʹ͸ແཧͳΜͩʯ ΋͏͍ΘͤͶ͑ͧʂʂʂ
21. CMS࡞੒ݴޠͱ͔͍ΘΕ͍ͯͨ PHPͷ͠Ϳͱ͞Λ ͋ΒͨΊͯΈͤͯ΍Γ·͢Αʂʂʂ
22. ؓ࿩ٳ୊
23. ʮԶ͕PHPerKaigiͩʂ(???)ʯ ‣ ͱɺݴ͑Δఔ౓ʹ(ʁ) ॳճ͔Βຖ೥ొஃ(લ໷ࡇؚΉ) ‣ ओʹPHPܥόοΫΤϯυΤϯδχΞ ‣ ʮઓ৔ʹಥવ౤͛ࠐ·ΕΔ༭ฌΛͯ͠ ͍·͢ʯ ‣ ࠷ۙͷ೰Έ ʮҰମԶ͸… ɹͲ͏ࣗݾ঺հΛ͢Ε͹…ʁʯ
24. ݱࡏͷݱ৔(2025-03ݱࡏ) ‣ ༗ݶձࣾΦʔϓϯεϑΟΞ (CTO) ‣ גࣜձࣾΦτόϯΫ (όοΫΤϯυΤϯδχΞ౳) ‣ גࣜձࣾPR TIMES (PHPεϖγϟϦετɺઌഐ໾) ‣ גࣜձࣾϦϯέʔδ (༯ਫ਼) ‣ ଞ֤ࣾ…(ΞʔΩςΫτ΍ίϯαϧ΍PHPer΍ຐআ͚໾ͳͲ)
25. ͦͷଞ൪એ ‣ Youtubeͷ uzulla chͰɺBaanSeenͳͲͷYoutubeͯ͠·͢ νϟϯωϧొ࿥ͯ͠ʂग़ԋͯ͠ʂ ‣ ʮXdebugΛ։࢝͢Δ܅ʯͱ͍͏Chrome֦ுΛͭ͘Γ·ͨ͠ ੋඇ͔ͭͬͯ! ‣ BlueSkyʹɺ଴๬ͷPackagist؂ࢹBotΛ෮׆ͤ͞·ͨ͠ʂ throwable.bsky.social (ݩͷxͷcall_user_func͔Β΋ϦϯΫͯ͋͠Γ·͢)
26. DISCLAIMER ‣ ͜ͷτʔΫ͸ɺ御社ͷαʔϏεʹPHP੡ͷσʔϞϯΛಋೖ͢Δ ͜ͱΛお勧めしませんɻ ‣ (ݸਓαʔϏεͳΒɺԠԉ͠·͢ʂΏ͘Ώ͘͸ޚࣾʹ΋…ʁ) ‣ ࢲ͕ʮࣗ෼͸PHPͰσʔϞϯΛॻ͘ΜͩʂʯͱݴΘΕͨΒɺ· ͣ͸ʮ΄͔ͷݴޠɺ࢖ͬͯΈͨʁʯͱฉ͖·͢ɻ ‣ ΍Δͱͯ͠΋ɺνʔϜͰे෼ͳٞ࿦Λ͓͜ͳ͍·͠ΐ͏ɻ
27. ຊ୊ σʔϞϯ࿉੒ ࣂ͍ͳΒ͠ ঌש ͷɺPHPer޲͚ΨΠυ
28. σʔϞϯͱ͸ʁ ‣ όοΫάϥ΢ϯυͰಈ࡞͢ΔৗறϓϩάϥϜ ‣ ࣗಈతʹىಈ͠ɺಛఆͷαʔϏε΍λεΫΛܧଓతʹ࣮ߦ͠· ͢ ‣ Ϣʔβʔ͕ϩάΞ΢τͯ͠΋ऴྃͤͣɺγεςϜγϟοτμ΢ϯ ·Ͱಈ࡞͠ଓ͚·͢ɻ ‣ ϢʔβʔͷΠϯλϥΫγϣϯͳ͠ʹಈ࡞͚ͭͮ͠Δ ‣ ྫ:Apache, Nginx, MySQL, PostgreSQL, crond, sshd
29. ;ͭ͏ͷPHPͱσʔϞϯͷҧ͍ Start ϒϥ΢β Request Apache PHP script Start(reset) Process PHP Response to ϒϥ΢β PHP script Finish(reset) ‣ ϦΫΤετ͕དྷͯϨεϙϯεΛฦ͢ɺຖճϦηοτ͞ΕΔ ‣ Θ͔Γ΍͍͢ʂ
30. όονͱσʔϞϯͷҧ͍ ‣ όον͸σʔϞϯʹʮࣅ͍ͯ·͢ʯ ‣ όον͸CronͳͲͰఆظతʹىಈͯ͠ऴྃ͢Δ ‣ Ұ౓ͷ࣮ߦͰ׬݁͢Δॲཧɺͱʹ͔͘ʮऴΘΓ͕͋Δʯ ‣ όον͸ຖճऴྃ͢ΔͷͰσʔλετΞʹอଘͯ࣍͠ͷόον ʹඋ͑ΔͨΓ͢Δ
31. Cron։࢝ PHP script Start(reset) Process PHP Cronऴྃ PHP script Finish(reset) Cron Cron
32. Batch(Cron)ͷݶքͱར఺ ‣ ࠷খ࣮ߦִؒ͸CronͳΒ1෼(௨ৗ) ‣ ಉ࣮࣌ߦͷ੍ޚ͕໘౗ɾ೉͍͠(ϩοΫ੍ޚ) ‣ Cronʮ΋ʯద౰Ͱ΋ಈ͘
33. σʔϞϯ - Կ͔Λॲཧ͢Δ΋ͷͰ͸͋Δ͕ɺϦΫΤετͱ͔Ϩεϙϯε͸ඞ ਢͰ͸ͳ͍ɻ - NඵʹҰ౓ूܭͯ͠DBʹॻ͖ࠐΉͱ͔ - ঢ়ଶΛௐ΂͚ͭͮͯ໰୊͕͋Ε͹ΞϥʔτΛSlackʹ͓͘Δͱ͔ - େྔͷσʔλΛʮ஗Ԇॲཧͨ͠Γɾޮ཰తʹɾॱ൪ʹʯॲཧ͢Δ ͱ͔ - ͋ͱɺ(ඞཁ͕ͳ͚Ε͹)ऴྃ͠ͳ͍
34. MainLoop PHP script Start(reset) Systemd(౳) Job౳ ऴྃʁ Main Loop Entry ॲཧA ॲཧN γάφϧ τϥοϓ NO ऴྃ ॲཧ YES killͳͲ γάφϧ ܧଓ ϑϥά ֬ೝ PHP script Finish( reset)
35. ‣ Cron͸ىಈִ͕ؒ͋Δ͕ɺσʔϞϯ͸ىಈִ͕ؒͳ͘ৗʹ࣮ߦ ‣ ىಈ͚ͭͮ͠ΔͷͰɺ࠶઀ଓ΍ɺΩϟογϡΛຖճಡΈࠐΉඞ ཁ͕ͳ͍ ‣ ʮఀࢭִؒʯ͕ͳ͍ͷͰɺଈ࠲ʹ൓ԠՄೳ ‣ ܧଓ͢ΔͷͰɺWebSocketͳͲͷ઀ଓΛҡ࣋Մೳ
36. σʔϞϯͷܽ఺ ‣ ҆ఆͯ͠ಈ࡞͢Δ΋ͷΛ࡞Δͷ͕೉͍͠ ͨͱ͑͹ϝϞϦϦʔΫɺDB࠶઀ଓॲཧͳͲ ‣ (όον͸ී௨ͷWebϓϩάϥϜͱʹͨϊϦ) ‣ ҟৗऴྃͨ͠ͱ͖ʹ࠶ىಈͤͨ͞Γ͕໘౗ ‣ ଟ͘ͷ৔߹ɺόον΍REST APIͰΑ͍΍Μ͚ ‣ ౳ʑ…
37. ͳͥPHPͰσʔϞϯΛʁ(ݴ͍༁) ‣ PHP͸WebΞϓϦʴόονͱ͍͏Πϝʔδ͕ڧ͍ ‣ PHPͷ஌ࣝΛ׆͔͠ɺ༷ʑͳόοΫάϥ΢ϯυॲཧΛॻ͘ࣄ͕ Ͱ͖Ε͹… ‣ ΧοίΠΠ(ओ؍) ‣ ͜ͷลΓͷָ͓͠Έ͸ޙ൒Ͱ…
38. ૉ๿ͳσʔϞϯΛ࡞Δ 1. CLIεΫϦϓτͱͯ͠ىಈ 2. ϝΠϯϧʔϓͰܧଓ࣮ߦ 3. γάφϧϋϯυϦϯάͷ࣮૷
39. #"/usr/bin/env php <?php declare(strict_types=1); $running = true; pcntl_signal(SIGTERM, function () use (&$running) { // γάφϧϋϯυϥͷઃఆ echo "SIGTERMΛ͏͚ͱΓ·ͨ͠ɺऴྃ͠·͢" . PHP_EOL; $running = false; }); echo "σʔϞϯىಈ (PID: ".getmypid().")" . PHP_EOL; while ($running) { // ϝΠϯϧʔϓ pcntl_signal_dispatch(); // γάφϧΛड৴ͨ͠ॲཧ echo "." . PHP_EOL; sleep(5); /% CPUΛ઎༗͠ͳ͍Α͏ʹεϦʔϓ } echo "σʔϞϯऴྃ" . PHP_EOL;
40. $running = true; while ($running) { // ϝΠϯϧʔϓ pcntl_signal_dispatch(); // γάφϧΛड৴ͨ͠ॲཧ echo "." . PHP_EOL; sleep(5); /" CPUΛ઎༗͠ͳ͍Α͏ʹεϦʔϓ } ‣ ແݶϧʔϓ(ϝΠϯϧʔϓ)͕͋Δ ‣ ʮා͍ʂʂʂʯ
41. $running = true; pcntl_signal(SIGTERM, function () use (&$running) { // γάφϧϋϯυϥͷઃఆ echo "SIGTERMΛ͏͚ͱΓ·ͨ͠ɺऴྃ͠·͢" . PHP_EOL; $running = false; }); while ($running) { // ϝΠϯϧʔϓ pcntl_signal_dispatch(); // γάφϧΛड৴ͨ͠ॲཧ }
42. pcntl_signal(SIGTERM, function () use (&$running) { echo "SIGTERMΛ͏͚ͱΓ·ͨ͠ɺऴྃ͠·͢" . PHP_EOL; $running = false; }); pcntl_signal(SIGHUP, function () use (&$running) { echo "SIGHUPΛ͏͚ͱΓ·ͨ͠ɺऴྃ͠·͢" . PHP_EOL; $running = false; }); pcntl_signal(SIGINT, function () use (&$running) { echo "SIGINTΛ͏͚ͱΓ·ͨ͠ɺऴྃ͠·͢" . PHP_EOL; $running = false; }); ‣ ड͚औΔγάφϧ͸ݸผઃఆ͕Ͱ͖·͢ ‣ γάφϧͷॲཧ͸ʮड͚औ͓͍ͬͯͯʯpcntl_signal_dispatch()Λݺͼग़ͯ͠ɺอཹதͷγάφϧΛॲ ཧ͠·͢ɻ͜Ε͸ॏཁͳεςοϓͰɺ͜Ε͕ͳ͍ͱγάφϧϋϯυϥͰ೚ҙͷॲཧΛઃఆͰ͖·ͤΜɻ
43. γάφϧͷૹΓํ ‣ killίϚϯυͰૹ৴Ͱ͖·͢ɺPIDͷࢦఆ͕ඞཁͰ͢ ‣ PID͸psίϚϯυͰ֬ೝͰ͖·͢ $ kill {PID} $ kill -HUP 1234 $ kill -TERM 1234 $ kill -USR1 1234 $ kill -KILL 1234 # ͜Ε͸OS͕ड͚औΓ·͢
44. ओཁͳγάφϧ ‣ SIGTERM (15): ਖ਼ৗऴྃཁٻ ‣ SIGINT (2): ΩʔϘʔυׂΓࠐΈʢCtrl+Cʣ ‣ SIGHUP (1): ୺຤੾அɺ(Α͋͘Δͷ͕ઃఆ࠶ಡΈࠐΈ) ‣ SIGUSR1 (10), SIGUSR2 (12): Ϣʔβʔఆٛ ‣ SIGKILL (9): ڧ੍ऴྃʢัଊෆՄʣ
45. খ࿩ ‣ γάφϧͷҙຯ͸ʮࡉ͔͖͘·͍ͬͯ·ͤΜʯ ‣ Apache͕γάφϧͨΓͶ͍͑ͬͯͬͯɺWINCHΛѱ༻ͯ͠Δ͜ͱ͸ Ұ෦Ͱ͸༗໊Ͱ͢Ͷ ‣ (WINCH͸΢Οϯυ΢αΠζมߋͷγάφϧͰ͢) ‣ ࠷ѱɺεΫϩʔϧόʔ͕ͰΔ͚ͩͰɺApache͕ऴྃ͢ΔΜͰ͢ΑͶ… ‣ (ݹདྷɺCLIͰApacheΛىಈ͢Δਓ͕ؒ͏·ΕΔͱ͸ࢥͬͯͳ͔ͬͨ ΜͩΖ͏…)
47. খ࿩:ద੾ͳऴྃॲཧ ‣ άϨʔεϑϧγϟοτμ΢ϯ ‣ ৽نॲཧΛఀࢭ͢Δ ‣ ਐߦதͷॲཧͷ׬ྃ͠ ‣ Ϧιʔεͷద੾ͳղ์͠ ‣ ঢ়ଶͷอଘ͢Δ ‣ ऴྃεςʔλεͷ௨஌
48. pcntl_signal(SIGTERM, function () { echo "ऴྃॲཧΛ࣮ߦத..""; /$ ਐߦதͷδϣϒΛอଘ saveCurrentState(); /$ DBίωΫγϣϯΛΫϩʔζ DB:&getConn-(close(); echo "ਖ਼ৗʹऴྃ͠·ͨ͠ɻ"; exit 0; /$ TODO ·ͱ΋ʹ࣮૷ͤΑ }); ‣ ଞʹ΋ɺSIGTERMͳΒ register_shutdown_function Λ׆༻͢Δख΋͋Δ
49. σʔϞϯͷঌשํ๏ $ php daemon.php ‣ CLI ϓϩάϥϜͷΑ͏ʹͯ͠ঌש(ىಈ)͕Ͱ͖·͢ɻ ‣ ໰୊఺͸λʔϛφϧΛด͡Δͱऴྃͯ͠͠·͏͜ͱͰ͢ ‣ ։ൃʹ͸ศར͕ͩɺσʔϞϯΛࣂ͏ͱͯ͠͸ඍົ
50. ྫ: nohupΛ࢖͏ํ๏ $ nohup php daemon.php & ‣ nohup: ϋϯάΞοϓγάφϧʢSIGHUPʣΛແࢹ͠·͢ ‣ &: όοΫάϥ΢ϯυͰ࣮ߦ
51. ྫ: screen(tmux)ͳͲΛ࢖͏ํ๏ # screenىಈ $ screen # σʔϞϯͳͲىಈ (screenͷதͰͷγΣϧ)$ php daemon.php # Ctrl+A, DͰɺγΣϧΛ੾Γ཭ͯ͠(σλον)ɺϓϩάϥϜΛऴྃͤͣʹϩάΞ΢τͰ͖Δ # ޙͰ·ͨϩάΠϯͯ͠ɺ࠶։(Ξλον)Ͱ͖Δ $ screen -r ‣ ίωΫγϣϯ͕͖Εͯ΋shell͕ऴྃͤͣɺ࠶઀ଓ͕Մೳ ‣ ։ൃ࣌ʹศར (௕࣮࣌ؒߦ͢ΔόονͰ΋͔ͭ͏ΑͶ) ‣ αʔόʔىಈ࣌ʹࣗಈىಈ͢ΔΑ͏ͳ΋ͷͰ͸ͳ͍
52. ίϯςφ؀ڥ FROM php:8.3-cli RUN docker-php-ext-install pcntl COPY -#from=composer /usr/bin/composer /usr/bin/composer COPY . /keira WORKDIR /keira RUN composer install CMD /keira/bin/keira.php ‣ ͋ͱ͸ docker run -it keira Ͱىಈ; ‣ ஫ҙ: -it ͸Φϓγϣϯ͕ͩɺ͠ͳ͍ͱγΣϧ͕ͳ͘ɺHUP͕Ͱ͖ͳ͍ͷͰऴ ྃ͸ผ్΍Δ͜ͱ
53. ຊ໋: systemdʹΑΔঌש ‣ Systemd͸LinuxͷαʔϏε؅ཧσʔϞϯ [Unit] Description=PHP Sample Daemon After=network.target [Service] Type=simple User=ww"-data ExecStart=/path/to/daemon.php Restart=on-failure RestartSec=5s Envfile=/etc/environment [Install] WantedBy=multi-user.target
54. systemctlʹΑΔૢ࡞ # αʔϏεͷొ࿥ $ systemctl enable php-daemon.service # αʔϏεͷ։࢝ $ systemctl start php-daemon.service # ঢ়ଶ֬ೝ $ systemctl status php-daemon.service # ఀࢭ $ systemctl stop php-daemon.service
55. Journalctl͍ͭͯ ‣ ϩάϑΝΠϧͷ؅ཧ͕ෆཁʂʢϩʔςʔγϣϯɺύʔϛογϣϯઃఆͳ Ͳʣ ‣ ߏ଄Խσʔλͱͯ͠อଘ͞Εɺݕࡧ͕༰қ ‣ λΠϜελϯϓɺϗετ໊ɺϓϩηεIDͳͲͷϝλσʔλ͕ࣗಈతʹ෇ ༩ ‣ γεςϜશମͷϩάͱ౷߹͞Εɺ໰୊ͷ૬ؔؔ܎Λ೺Ѳ͠΍͍͢ ‣ ϩάϨϕϧʹΑΔϑΟϧλϦϯά͕؆୯ ‣ ϩάग़ྗ͸ɺjournalctlίϚϯυͰ֬ೝͰ͖·͢ɻ
56. journalctlྫ # αʔϏεͷϩάΛදࣔ $ journalctl -u php-daemon.service # ࠷৽ͷϩάΛϑΥϩʔ $ journalctl -u php-daemon.service -f # ࠓ೔ͷϩάͷΈදࣔ $ journalctl -u php-daemon.service -#since today $ journalctl -u php-daemon.service -#since "2023-03-20 21:30:08" -#until "2023-03-20 22:30:08" # ΤϥʔϨϕϧͷϩάͷΈදࣔ $ journalctl -u php-daemon.service -p err # JSONܗࣜͰग़ྗ $ journalctl -u php-daemon.service -#output=json
57. ؂ࢹͱ݈શੑ֬อ ‣ ϩά͸JournalctlͰ؂ࢹͰ͖Δ ‣ ʁʮͱ͸͍͑ɺҟৗऴྃͨ͠ΒͲ͏͢ΔͷʁPHP͸৴༻ͳ͍ ͠…ʯ ‣ ϔϧενΣοΫΛఆظతʹ࣮ߦͯ͠…ͱ͔͋Γ·͕͢ ‣ ͳΜͱɺҟৗऴྃͳΒSystemd͕࠶ىಈΛ΍ͬͯ͘Ε· ͢ʂʂʂ ศརʂʂʂʂ
58. ༨ஊɿsystemdʹΑΔεέδϡʔϧ࣮ߦ ‣ ͱ͸͍͑ɺσʔϞϯϓϩάϥϜͳΜͯ࡞Γͨ͘ͳ͍ਓͷͨΊͷ systemd͓໾ཱͪ৘ใ ‣ Systemd͸σʔϞϯͷىಈऴྃΛ͢Δ͚ͩͱ͓΋͍͖΍ɺεέ δϡʔϧ࣮ߦ΋Ͱ͖ΔʹCronͷ୅ΘΓʹ࢖͑Δ ‣ Cronͱ͕ͪͬͯϑΝΠϧΛઃஔͯ͠؅ཧ͢ΔͷͰɺIaCͱ૬ੑ͕ ྑ͍Ͱ͢ ‣ Ұ࣌ఀࢭͱ͔΋ႈ౳ʹͰ͖·͢
59. systemdλΠϚʔϢχοτ # /etc/systemd/system/php-daemon.timer [Unit] Description=Run PHP daemon daily [Timer] OnCalendar=*-*-* 03:00:00 # ຖ೔ޕલ3࣌ʹ࣮ߦ AccuracySec=1s # ਫ਼౓Λ1ඵʹઃఆ [Install] WantedBy=timers.target
60. 1෼Ҏ಺ʹυϯυϯ࣮ߦ͍ͨ͠৔߹ɺ͜ͷΑ͏ͳ͜ͱ΋Ͱ͖·͢ [Unit] Description=My Job Service After=network.target [Service] Type=oneshot ExecStart=/path/to/your/script.sh [Unit] Description=Run My Job every 10 seconds [Timer] OnUnitActiveSec=10s #લճͷ࣮ߦ͔Β10ඵޙʹ࠶࣮ߦ AccuracySec=1s [Install] WantedBy=timers.target
61. ·ͱΊ ‣ Craft ‣ PHPͰ΋σʔϞϯϓϩάϥϜ͕࡞੒Մೳ ‣ Taim ‣ γάφϧॲཧ͕ॏཁ ‣ summon ‣ systemdͳͲͷπʔϧΛ׆༻͠·͠ΐ͏
62. ࣭໰λΠϜͦͷ1 ࣭͝໰͕͋Ε͹Ͳ͏ͧʂ
63. ͋Γ͕ͱ͏͍͟͝·ͨ͠ʂ PHPͰσʔϞϯΛʮࣂ͍ͳΒ͠ʯɺ࣮༻తʹӡ༻͠·͠ΐ͏ʂ (͔͖ͣ͞Μ https://x.com/i999rri τʔΫϨϏϡʔ͋Γ͕ͱ͏ʂ)
64. ͬͯɺ͜ΕͰऴΘΔΘ͚ͳ͍΍Ζ͕͍ʂʂʂ ͏ͣΒͪΌΜ͸τʔΫΛ΍Ί΁ΜͰʔʂʂʂ
65. ͔͜͜Βָ͓͠ΈλΠϜ ‣ ʮPHPͰͭ͘ΒΕͨσʔϞϯͬͯ΍ͭΛΈͤͯ͋͛·͢Α…ʂʯ ‣ ʮ͑͑ͬPHPͰʂʁʯʮ͸͍ʂʂʯ ‣ ʮDemon(ѱຐ)Ͱͳ͘ʂʁʯʮ͸͍ʁʁʯ
66. Keira
68. ‣ Keira͸ɺPHPͱamphpͰߏங͞ΕͨWebϞχλϦϯάΞϓϦ Ͱ͢ɻෳ਺Λಉ࣌؂ࢹ͠ɺ໰୊͕ൃੜͨ͠ࡍʹϦΞϧλΠϜͰ௨ ஌͠·͢ɻ ‣ ϦΞϧλΠϜ௨஌ɿো֐ൃੜ࣌ʹଈ࠲ʹSlack௨஌(※) ‣ WebSocketରԠɿϦΞϧλΠϜߋ৽ΛWebSocketͰఏڙ ‣ RESTful APIɿγϯϓϧͳAPIͰ؂ࢹσʔλʹΞΫηε ‣ γάφϧ੍ޚɿUNIXγάφϧͰΞϓϦΛૢ࡞ ‣ ֤छΧελϚΠζ؂ࢹઃఆ
70. ࢲʮͲ͏Ͱ͢ʁʯ ʁʮJS Chart͓͔͘͠Ͷʁʯ ࢲʮຊ࣭Ͱ͸ͳ͍ʯ
71. ʢσʔϞϯͳΒͰ͸ͷʣӡ༻ʹ࢖͑ΔϙΠϯτ ‣ Ұ࣌ఀࢭ͕ USR1,2 γάφϧͰͰ͖Δ ‣ ઃఆϑΝΠϧͷϦϩʔυΛHUPͰͰ͖Δ ‣ ؂ࢹઌͷ௥Ճɺ࡟আɺҰ࣌ఀࢭͳͲΛαϙʔτ ‣ ͜ͷ࣌ʹWebSocket͕੾அ͞ΕͨΓ͸͠·ͤΜ ‣ ౷ܭ৘ใ΋͖͑·ͤΜ ‣ ͳͥͳΒσʔϞϯͳͷͰ(ʁʁʁ)
73. Slack௨஌΋αϙʔτ͍ͯ͠Δʂ ‣ ͭ΋Γ͕ͩͬͨɺࠓ೔όάͬͯ·ͨ͠wwww ‣ ͳͷͰಈը͕ͳ͍ʂʂʂ ‣ ·͋ɺ͏͍ͨ͝ΜͩΑʂʂʂʂ৴ͯ͘͡Εʂʂʂʂ
74. Keiraͷίʔυ͸ͪ͜Β ‣ https://github.com/uzulla/Keira ‣ ஫ҙ఺: ։ൃதͰ͢w ຊ෺ͷ؂ࢹʹ͸·ͩ࢖Θͳ͍Ͱ͍ͩ͘͞w
75. ͩ͜ΘΓϙΠϯτ ‣ WebsocketΛॲཧ͠ͳ͕Βɺ؂ࢹ΋ܧଓ͍ͯ͠Δ͠ɺREST API ΋໪࿦͏͖͝·͢ʂ ‣ σʔϞϯͳͷͰɺDBͱ͔ෆཁʂ(σʔλ͸ม਺ʹ΋͍ͬͯ·͢) ‣ 1ϓϩηεͳͷͰɺDockerίϯςφͱ͔Ͱಈ͔͢ͷ΋ָʑʂ (Systemdͷ࿩͸Ͳ͜ʹ…ʁ)
76. ίʔυ͓΋͠ΖϙΠϯτ ‣ amphpͳͷͰɺPure PHPͰ͢ (C֦ுෆཁ) ‣ ݁ߏಡΈ΍͔͍ͯ͋͘͢Γ·͢(ݸਓࠩ͸͋Δ) ‣ ApiServer.phpͱ͔ΈͯΈ͍ͯͩ͘͞ ‣ γάφϧॲཧ͸ɺUtil/SignalHandler.phpʹॻ͍ͯ͋Γ·͢ ‣ Application.php ͰɺػೳΛϚ΢ϯτ͍ͯ͘͠ͷ͕͓΋͠Ζ͍ ‣ Asyncͱ͔ɺCancelͱ͔͕͋Δ (ଞͷݴޠ஌ͬͯΔͻͱͳΒ͓΋͠Ζ͍Ͱ͠ΐ)
77. ## Keira/src/Keira/Application.php /$ Create signal handler $this-&signalHandler = new SignalHandler($this-&configLoader, $this-&monitorManager, $this-&appLogger); $this-&signalHandler-&register(); /$ Create data retention manager $this-&dataRetention = new DataRetention($this-&monitorManager, $this-&appLogger); $this-&dataRetention-&start(); /$ Create API server $this-&apiServer = new ApiServer('0.0.0.0', 8080, $this-&monitorManager, $this-&appLogger); $this-&apiServer-&start(); /$ Start monitoring $this-&monitorManager-&start();
78. ## KKeira/src/Keira/WebSocket/WebSocketHandler.php public function handleClient( ): void { $this-%gateway-%addClient($client); try { foreach ($client as $message) { $payload = $message; $this-%logger-%info("[INFO][APP] Received WebSocket message: {$payload}"); } } catch (\Throwable $e) { $this-%logger-%error("[ERROR][APP] WebSocket error: {$e-%getMessage()}"); } finally { $this-%logger-%info("[INFO][APP] WebSocket client disconnected"); } } /** * Broadcast monitor result to all connected clients *( private function broadcastResult(MonitorResult $result): void { $payload = json_encode($result-%toArray()); if ($payload) { $this-%gateway-%broadcastText($payload); } }
79. ## Keira/src/Keira/Api/ApiServer.php private function registerRoutes(): void { /% GET /monitors - List all monitors $this-'router-'addRoute('GET', '/monitors', new ClosureRequestHandler( function ($request) { $handler = new MonitorsHandler($this-'monitorManager); return $handler($request); } )); /% GET /ws-test - WebSocket test page $this-'router-'addRoute('GET', '/ws-test', new ClosureRequestHandler( function ($request) { $templatePath = '/websocket-test.html'; if (!file_exists($templatePath)) { return new \Amp\Http\Server\Response( status: 500, headers: ['Content-Type' =+ 'text/plain'], body: 'Template file not found' ); } $html = file_get_contents($templatePath); return new \Amp\Http\Server\Response( status: 200, headers: ['Content-Type' =+ 'text/html'], body: $html ); } ));
80. ## Keira/src/Keira/Util/SignalHandler.php public function register(): void { /% SIGHUP: Reload configuration async(function () { while (true) { try { trapSignal(\SIGHUP); $this-(handleSighup(); } catch (SignalException $e) { /% Signal handler was cancelled break; } } });
81. ·ͱΊ2 ‣ PHPͰɺ࣮༻తͳσʔϞϯ͕࡞ΕΔʂ ‣ ͔͠΋ɺҊ֎ಡΊΔʂ(ݸਓࠩ͋Γ·͢) ‣ νϡʔχϯά(CPUෛՙ)ͱ͔͸·ͩ·ͩͰ͢ɻ Ͱ΋ɺಈ͘͜ͱ͕Θ͔ΔɺͦΕ͕࢝·ΓͰ͢ʂʂʂ
82. ʮΦϨͨͪ͸·ͩ૸Γ࢝Ίͨ͹͔Γ͔ͩΒͳɻ ͜ͷ͸ͯ͠ͳ͘ԕ͍σʔϞϯ࿉੒ΛΑ…!ʯ
83. One more thing...
84. DB-monitor ‣ https://github.com/uzulla/db-monitor ‣ ʮՔಇதͷσʔλϕʔεͷ౷ܭ৘ใ౳ΛϦΞϧλΠϜʹදࣔ͠ɺվળʹ ໾ཱͯΔ৘ใΛऔಘ͢ΔπʔϧͰ͢ʯ ‣ DBʹৗ࣌઀ଓͯ͠ɺΫΤϦΛϞχλʔ͢ΔπʔϧΛͭ͘Γ͔ͨͬͨ ‣ ʮPHPͰʂʂʂʂʂʂʂʂʂʯ ‣ ͳͥͳΒPHPͳΒɺ৭ʑͳਖ਼نදݱͱָ͔͕ʹ࢖͑Δ͠ɺίʔυ͕ಡΈ ΍͍͔͢Β(ݸਓࠩ͸͋Δ) ‣ ͜Ε΋amphpͰॻ͍ͯ·͢
87. ͓ΘΓ ‣ ࣭໰͋Γ·͔͢ʁ ‣ ͳ͍ͳΒɺthrowable.bsky.social ͷσϞͰ΋͢Δ