ການໂອນ backend PHP ກັບ Redis streams bus ແລະເລືອກຫ້ອງສະຫມຸດ framework-ເອກະລາດ

ຄໍາອະທິຖານ

ເວັບໄຊທ໌ຂອງຂ້ອຍ, ທີ່ຂ້ອຍດໍາເນີນການເປັນວຽກອະດິເລກ, ຖືກອອກແບບມາເພື່ອເປັນເຈົ້າພາບຫນ້າທໍາອິດທີ່ຫນ້າສົນໃຈແລະສະຖານທີ່ສ່ວນບຸກຄົນ. ຫົວຂໍ້ນີ້ເລີ່ມສົນໃຈຂ້ອຍໃນຕອນເລີ່ມຕົ້ນຂອງການເດີນທາງການຂຽນໂປຼແກຼມຂອງຂ້ອຍ; ໃນຂະນະນັ້ນຂ້ອຍຮູ້ສຶກປະທັບໃຈກັບການຊອກຫາຜູ້ຊ່ຽວຊານທີ່ດີທີ່ຂຽນກ່ຽວກັບຕົວເອງ, ວຽກອະດິເລກແລະໂຄງການຂອງພວກເຂົາ. ນິໄສການຄົ້ນພົບພວກມັນສໍາລັບຕົວເອງຍັງຄົງຢູ່ຈົນເຖິງທຸກວັນນີ້: ໃນເກືອບທຸກເວັບໄຊທ໌ການຄ້າແລະບໍ່ແມ່ນການຄ້າຫຼາຍ, ຂ້ອຍສືບຕໍ່ຊອກຫາຢູ່ໃນສ່ວນທ້າຍເພື່ອຊອກຫາການເຊື່ອມຕໍ່ກັບຜູ້ຂຽນ.

ການຈັດຕັ້ງປະຕິບັດແນວຄວາມຄິດ

ສະບັບທໍາອິດແມ່ນພຽງແຕ່ຫນ້າ html ຢູ່ໃນເວັບໄຊທ໌ສ່ວນຕົວຂອງຂ້ອຍ, ບ່ອນທີ່ຂ້ອຍໃສ່ການເຊື່ອມຕໍ່ທີ່ມີລາຍເຊັນເຂົ້າໄປໃນບັນຊີລາຍຊື່ ul. ມີການພິມ 20 ຫນ້າໃນໄລຍະເວລາ, ຂ້ອຍເລີ່ມຄິດວ່ານີ້ບໍ່ມີປະສິດທິພາບຫຼາຍແລະຕັດສິນໃຈພະຍາຍາມອັດຕະໂນມັດຂະບວນການ. ໃນ stackoverflow, ຂ້າພະເຈົ້າສັງເກດເຫັນວ່າປະຊາຊົນຈໍານວນຫຼາຍຊີ້ໃຫ້ເຫັນສະຖານທີ່ໃນໂປຣໄຟລ໌ຂອງເຂົາເຈົ້າ, ສະນັ້ນຂ້າພະເຈົ້າຂຽນ parser ໃນ php, ເຊິ່ງພຽງແຕ່ໄປໂດຍຜ່ານໂປຣໄຟລ໌, ເລີ່ມຕົ້ນດ້ວຍທໍາອິດ (ທີ່ຢູ່ SO ຈົນເຖິງທຸກມື້ນີ້ເປັນແບບນີ້: `/users/1`. ), ສະກັດການເຊື່ອມຕໍ່ຈາກແທັກທີ່ຕ້ອງການແລະເພີ່ມມັນໃນ SQLite.

ນີ້ສາມາດເອີ້ນວ່າສະບັບທີສອງ: ການລວບລວມຫລາຍສິບພັນ URL ໃນຕາຕະລາງ SQLite, ເຊິ່ງແທນທີ່ບັນຊີລາຍຊື່ຄົງທີ່ໃນ HTML. ຂ້າພະເຈົ້າໄດ້ຄົ້ນຫາແບບງ່າຍໆໃນບັນຊີລາຍຊື່ນີ້. ເນື່ອງຈາກວ່າ ມີພຽງແຕ່ URLs, ຫຼັງຈາກນັ້ນການຄົ້ນຫາແມ່ນພຽງແຕ່ອີງໃສ່ພວກມັນ.

ໃນຂັ້ນຕອນນີ້ຂ້າພະເຈົ້າໄດ້ປະຖິ້ມໂຄງການແລະກັບຄືນໄປຫາມັນຫຼັງຈາກເວລາດົນນານ. ໃນຂັ້ນຕອນນີ້, ປະສົບການການເຮັດວຽກຂອງຂ້ອຍແມ່ນຫຼາຍກວ່າສາມປີແລ້ວແລະຂ້ອຍຮູ້ສຶກວ່າຂ້ອຍສາມາດເຮັດບາງສິ່ງບາງຢ່າງທີ່ຮ້າຍແຮງກວ່າເກົ່າ. ນອກຈາກນັ້ນ, ມີຄວາມປາຖະໜາອັນໃຫຍ່ຫຼວງທີ່ຈະເປັນເຈົ້າຂອງເຕັກໂນໂລຢີທີ່ຂ້ອນຂ້າງໃຫມ່.

ສະບັບທີ່ທັນສະໄຫມ

ໂຄງການ deployed ໃນ Docker, ຖານຂໍ້ມູນໄດ້ຖືກໂອນໄປ mongoDb, ແລະບໍ່ດົນມານີ້, radish ໄດ້ຖືກເພີ່ມ, ເຊິ່ງໃນຕອນທໍາອິດແມ່ນພຽງແຕ່ສໍາລັບການເກັບຮັກສາໄວ້. ຫນຶ່ງໃນ microframeworks PHP ຖືກນໍາໃຊ້ເປັນພື້ນຖານ.

ບັນຫາ

ເວັບໄຊທ໌ໃຫມ່ຖືກເພີ່ມໂດຍຄໍາສັ່ງ console ທີ່ synchronously ເຮັດດັ່ງຕໍ່ໄປນີ້:

• ດາວໂຫຼດເນື້ອຫາໂດຍ URL
• ຕັ້ງທຸງຊີ້ບອກວ່າ HTTPS ມີຢູ່ຫຼືບໍ່
• ຮັກສາຄວາມສໍາຄັນຂອງເວັບໄຊທ໌
• ແຫຼ່ງ HTML ແລະສ່ວນຫົວຖືກບັນທຶກໄວ້ໃນປະຫວັດສາດ "ດັດສະນີ".
• ວິເຄາະເນື້ອຫາ, ແຍກຊື່ ແລະຄຳອະທິບາຍ
• ບັນທຶກຂໍ້ມູນໃສ່ຄໍເລັກຊັນແຍກຕ່າງຫາກ

ນີ້ແມ່ນພຽງພໍທີ່ຈະພຽງແຕ່ເກັບຮັກສາເວັບໄຊທ໌ແລະສະແດງໃຫ້ພວກເຂົາຢູ່ໃນບັນຊີລາຍຊື່:

ແຕ່ແນວຄວາມຄິດຂອງການຈັດລໍາດັບອັດຕະໂນມັດ, ການຈັດປະເພດແລະການຈັດລໍາດັບທຸກສິ່ງທຸກຢ່າງ, ຮັກສາທຸກສິ່ງທຸກຢ່າງໃຫ້ທັນສະໄຫມ, ບໍ່ໄດ້ເຫມາະກັບ paradigm ນີ້. ເຖິງແມ່ນວ່າພຽງແຕ່ເພີ່ມວິທີການເວັບໄຊຕ໌ເພື່ອເພີ່ມຫນ້າທີ່ຊ້ໍາກັນລະຫັດແລະການຂັດຂວາງເພື່ອຫຼີກເວັ້ນການ DDoS ທີ່ເປັນໄປໄດ້.

ໂດຍທົ່ວໄປ, ແນ່ນອນ, ທຸກສິ່ງທຸກຢ່າງສາມາດເຮັດໄດ້ synchronously, ແລະໃນວິທີການເວັບໄຊຕ໌ທີ່ທ່ານພຽງແຕ່ສາມາດບັນທຶກ URL ເພື່ອໃຫ້ daemon monstrous ປະຕິບັດວຽກງານທັງຫມົດສໍາລັບ URLs ຈາກບັນຊີລາຍຊື່. ຢ່າງໃດກໍຕາມ, ເຖິງແມ່ນວ່າໃນທີ່ນີ້ຄໍາວ່າ "ແຖວ" ຊີ້ໃຫ້ເຫັນຕົວຂອງມັນເອງ. ແລະຖ້າຄິວຖືກປະຕິບັດ, ວຽກງານທັງຫມົດສາມາດແບ່ງອອກແລະປະຕິບັດຢ່າງຫນ້ອຍ asynchronously.

ການຕັດສິນໃຈ

ປະຕິບັດຄິວແລະສ້າງລະບົບເຫດການທີ່ຂັບເຄື່ອນສໍາລັບການປຸງແຕ່ງວຽກງານທັງຫມົດ. ແລະຂ້ອຍຢາກລອງ Redis Stream ມາເປັນເວລາດົນນານແລ້ວ.

ການນໍາໃຊ້ Redis streams ໃນ PHP

ເນື່ອງຈາກວ່າ ເນື່ອງຈາກກອບຂອງຂ້ອຍບໍ່ແມ່ນຫນຶ່ງໃນສາມຍັກໃຫຍ່ Symfony, Laravel, Yii, ຂ້ອຍຢາກຊອກຫາຫ້ອງສະຫມຸດເອກະລາດ. ແຕ່, ຍ້ອນວ່າມັນຫັນອອກ (ໃນການກວດສອບຄັ້ງທໍາອິດ), ມັນເປັນໄປບໍ່ໄດ້ທີ່ຈະຊອກຫາຫ້ອງສະຫມຸດທີ່ຮ້າຍແຮງຂອງບຸກຄົນ. ທຸກສິ່ງທຸກຢ່າງທີ່ກ່ຽວຂ້ອງກັບຄິວແມ່ນເປັນໂຄງການຈາກ 3 commits ຫ້າປີທີ່ຜ່ານມາ, ຫຼືຖືກຜູກມັດກັບກອບ.

ຂ້ອຍໄດ້ຍິນຫຼາຍກ່ຽວກັບ Symfony ເປັນຜູ້ສະຫນອງສ່ວນປະກອບທີ່ເປັນປະໂຫຍດສ່ວນບຸກຄົນ, ແລະຂ້ອຍໃຊ້ບາງສ່ວນຂອງພວກມັນແລ້ວ. ແລະບາງສິ່ງທີ່ຈາກ Laravel ຍັງສາມາດຖືກນໍາໃຊ້, ສໍາລັບການຍົກຕົວຢ່າງ ORM ຂອງເຂົາເຈົ້າ, ໂດຍບໍ່ມີການມີກອບຕົວຂອງມັນເອງ.

symfony/messenger

ຜູ້ສະຫມັກທໍາອິດທັນທີເບິ່ງຄືວ່າເຫມາະສົມແລະໂດຍບໍ່ມີການສົງໃສໃດໆຂ້າພະເຈົ້າຕິດຕັ້ງມັນ. ແຕ່ມັນໄດ້ກາຍເປັນຄວາມຫຍຸ້ງຍາກຫຼາຍຕໍ່ກັບ google ຕົວຢ່າງຂອງການນໍາໃຊ້ນອກ Symfony. ວິທີການລວບລວມຈາກກຸ່ມຂອງຫ້ອງຮຽນທີ່ມີຊື່ທົ່ວໄປ, ບໍ່ມີຄວາມຫມາຍ, ລົດເມສໍາລັບຂໍ້ຄວາມ, ແລະແມ້ກະທັ້ງ Redis?

ເອກະສານຢູ່ໃນເວັບໄຊທ໌ທາງການແມ່ນຂ້ອນຂ້າງລະອຽດ, ແຕ່ວ່າການເລີ່ມຕົ້ນພຽງແຕ່ໄດ້ຖືກອະທິບາຍສໍາລັບ Symfony ໂດຍໃຊ້ YML ທີ່ພວກເຂົາມັກແລະວິທີການ magic ອື່ນໆສໍາລັບນັກດົນຕີທີ່ບໍ່ແມ່ນ symphonist. ຂ້າພະເຈົ້າບໍ່ມີຄວາມສົນໃຈໃນຂະບວນການຕິດຕັ້ງຕົວມັນເອງ, ໂດຍສະເພາະໃນຊ່ວງວັນພັກປີໃຫມ່. ແຕ່ຂ້ອຍຕ້ອງເຮັດສິ່ງນີ້ເປັນເວລາດົນນານທີ່ບໍ່ຄາດຄິດ.

ການພະຍາຍາມຫາວິທີເຮັດໃຫ້ລະບົບທັນທີທັນໃດໂດຍໃຊ້ແຫຼ່ງ Symfony ບໍ່ແມ່ນວຽກທີ່ຫຍຸ້ງຍາກທີ່ສຸດສໍາລັບເສັ້ນຕາຍທີ່ເຄັ່ງຄັດ:

ຫຼັງຈາກ delving ເຂົ້າໄປໃນທັງຫມົດນີ້ແລະພະຍາຍາມເຮັດບາງສິ່ງບາງຢ່າງດ້ວຍມືຂອງຂ້າພະເຈົ້າ, ຂ້າພະເຈົ້າມາສະຫລຸບວ່າຂ້າພະເຈົ້າເຮັດບາງປະເພດຂອງ crutches ແລະຕັດສິນໃຈທີ່ຈະພະຍາຍາມອັນອື່ນ.

illuminated/ຄິວ

ມັນໄດ້ຫັນອອກວ່າຫ້ອງສະຫມຸດນີ້ຕິດແຫນ້ນກັບໂຄງສ້າງພື້ນຖານຂອງ Laravel ແລະຄວາມເພິ່ງພາອາໄສອື່ນໆ, ດັ່ງນັ້ນຂ້ອຍບໍ່ໄດ້ໃຊ້ເວລາຫຼາຍກັບມັນ: ຂ້ອຍຕິດຕັ້ງມັນ, ເບິ່ງມັນ, ເຫັນຄວາມເພິ່ງພາອາໄສແລະລຶບມັນອອກ.

yiisoft/yii2-queue

ດີ, ໃນທີ່ນີ້ມັນໄດ້ຖືກສົມມຸດທັນທີຈາກຊື່, ອີກເທື່ອຫນຶ່ງ, ການເຊື່ອມຕໍ່ທີ່ເຄັ່ງຄັດກັບ Yii2. ຂ້ອຍຕ້ອງໃຊ້ຫ້ອງສະຫມຸດນີ້ແລະມັນບໍ່ແມ່ນສິ່ງທີ່ບໍ່ດີ, ແຕ່ຂ້ອຍບໍ່ໄດ້ຄິດກ່ຽວກັບຄວາມຈິງທີ່ວ່າມັນຂຶ້ນກັບ Yii2 ຢ່າງສົມບູນ.

ສ່ວນທີ່ເຫຼືອ

ທຸກສິ່ງທຸກຢ່າງອື່ນທີ່ຂ້ອຍພົບໃນ GitHub ແມ່ນໂຄງການທີ່ບໍ່ຫນ້າເຊື່ອຖື, ລ້າສະໄຫມແລະຖືກປະຖິ້ມໄວ້ໂດຍບໍ່ມີຮູບດາວ, ສ້ອມແລະຄໍາຫມັ້ນສັນຍາຈໍານວນຫລາຍ.

ກັບໄປທີ່ symfony/messenger, ລາຍລະອຽດດ້ານວິຊາການ

ຂ້າ​ພະ​ເຈົ້າ​ຕ້ອງ​ຄິດ​ອອກ​ຫ້ອງ​ສະ​ຫມຸດ​ນີ້​ແລະ​, ຫຼັງ​ຈາກ​ທີ່​ໃຊ້​ເວ​ລາ​ຫຼາຍ​ກວ່າ​, ຂ້າ​ພະ​ເຈົ້າ​ສາ​ມາດ​ເຮັດ​ໄດ້​. ມັນໄດ້ຫັນອອກວ່າທຸກສິ່ງທຸກຢ່າງແມ່ນຂ້ອນຂ້າງ concise ແລະງ່າຍດາຍ. ເພື່ອເຮັດໃຫ້ລົດເມທັນທີ, ຂ້າພະເຈົ້າໄດ້ສ້າງໂຮງງານຂະຫນາດນ້ອຍ, ເນື່ອງຈາກວ່າ ... ຂ້າ​ພະ​ເຈົ້າ​ຄວນ​ຈະ​ມີ​ຢາງ​ລົດ​ຫຼາຍ​ແລະ​ມີ handlers ທີ່​ແຕກ​ຕ່າງ​ກັນ.

ພຽງແຕ່ສອງສາມຂັ້ນຕອນ:

• ພວກເຮົາສ້າງຕົວຈັດການຂໍ້ຄວາມທີ່ຄວນຈະສາມາດໂທຫາໄດ້ງ່າຍໆ
• ພວກເຮົາຫໍ່ພວກມັນໄວ້ໃນ HandlerDscriptor (ຫ້ອງຮຽນຈາກຫ້ອງສະຫມຸດ)
• ພວກເຮົາຫໍ່ "ຕົວອະທິບາຍ" ເຫຼົ່ານີ້ຢູ່ໃນຕົວຢ່າງ HandlersLocator
• ການເພີ່ມ HandlersLocator ໃສ່ຕົວຢ່າງ MessageBus
• ພວກເຮົາຜ່ານຊຸດຂອງ 'SenderInterface' ໃຫ້ກັບ SenderLocator, ໃນກໍລະນີຂອງຂ້ອຍໃນຫ້ອງຮຽນ 'RedisTransport', ເຊິ່ງຖືກຕັ້ງຄ່າໃນທາງທີ່ຊັດເຈນ.
• ການເພີ່ມ SenderLocator ໃສ່ຕົວຢ່າງ MessageBus

MessageBus ມີວິທີການ `-> dispatch()` ທີ່ຊອກຫາຕົວຈັດການທີ່ເຫມາະສົມໃນ HandlersLocator ແລະສົ່ງຂໍ້ຄວາມໃຫ້ພວກເຂົາ, ໂດຍໃຊ້ `SenderInterface` ທີ່ສອດຄ້ອງກັນເພື່ອສົ່ງຜ່ານລົດເມ (ສາຍ Redis).

ໃນການຕັ້ງຄ່າຕູ້ຄອນເທນເນີ (ໃນກໍລະນີນີ້ php-di), ມັດທັງຫມົດນີ້ສາມາດຖືກຕັ້ງຄ່າເຊັ່ນນີ້:

        CONTAINER_REDIS_TRANSPORT_SECRET => function (ContainerInterface $c) {
            return new RedisTransport(
                $c->get(CONTAINER_REDIS_STREAM_CONNECTION_SECRET),
                $c->get(CONTAINER_SERIALIZER))
            ;
        },
        CONTAINER_REDIS_TRANSPORT_LOG => function (ContainerInterface $c) {
            return new RedisTransport(
                $c->get(CONTAINER_REDIS_STREAM_CONNECTION_LOG),
                $c->get(CONTAINER_SERIALIZER))
            ;
        },
        CONTAINER_REDIS_STREAM_RECEIVER_SECRET => function (ContainerInterface $c) {
            return new RedisReceiver(
                $c->get(CONTAINER_REDIS_STREAM_CONNECTION_SECRET),
                $c->get(CONTAINER_SERIALIZER)
            );
        },
        CONTAINER_REDIS_STREAM_RECEIVER_LOG => function (ContainerInterface $c) {
            return new RedisReceiver(
                $c->get(CONTAINER_REDIS_STREAM_CONNECTION_LOG),
                $c->get(CONTAINER_SERIALIZER)
            );
        },
        CONTAINER_REDIS_STREAM_BUS => function (ContainerInterface $c) {
            $sendersLocator = new SendersLocator([
                AppMessagesSecretJsonMessages::class => [CONTAINER_REDIS_TRANSPORT_SECRET],
                AppMessagesDaemonLogMessage::class => [CONTAINER_REDIS_TRANSPORT_LOG],
            ], $c);
            $middleware[] = new SendMessageMiddleware($sendersLocator);

            return new MessageBus($middleware);
        },
        CONTAINER_REDIS_STREAM_CONNECTION_SECRET => function (ContainerInterface $c) {
            $host = 'bu-02-redis';
            $port = 6379;
            $dsn = "redis://$host:$port";
            $options = [
                'stream' => 'secret',
                'group' => 'default',
                'consumer' => 'default',
            ];

            return Connection::fromDsn($dsn, $options);
        },
        CONTAINER_REDIS_STREAM_CONNECTION_LOG => function (ContainerInterface $c) {
            $host = 'bu-02-redis';
            $port = 6379;
            $dsn = "redis://$host:$port";
            $options = [
                'stream' => 'log',
                'group' => 'default',
                'consumer' => 'default',
            ];

            return Connection::fromDsn($dsn, $options);
        },

ທີ່ນີ້ເຈົ້າສາມາດເຫັນໄດ້ວ່າໃນ SenderLocator ພວກເຮົາໄດ້ມອບຫມາຍ "ການຂົນສົ່ງ" ທີ່ແຕກຕ່າງກັນສໍາລັບສອງຂໍ້ຄວາມທີ່ແຕກຕ່າງກັນ, ແຕ່ລະຄົນມີການເຊື່ອມຕໍ່ຂອງຕົນເອງກັບສາຍນ້ໍາທີ່ສອດຄ້ອງກັນ.

ຂ້າພະເຈົ້າໄດ້ສ້າງໂຄງການ demo ແຍກຕ່າງຫາກສະແດງໃຫ້ເຫັນຄໍາຮ້ອງສະຫມັກຂອງສາມ daemons ສື່ສານກັບກັນແລະກັນໂດຍໃຊ້ລົດເມຕໍ່ໄປນີ້: https://github.com/backend-university/products/tree/master/products/02-redis-streams-bus.

ແຕ່ຂ້ອຍຈະສະແດງໃຫ້ເຈົ້າຮູ້ວ່າຜູ້ບໍລິໂພກສາມາດຈັດໂຄງສ້າງໄດ້ແນວໃດ:

use AppMessagesDaemonLogMessage;
use SymfonyComponentMessengerHandlerHandlerDescriptor;
use SymfonyComponentMessengerHandlerHandlersLocator;
use SymfonyComponentMessengerMessageBus;
use SymfonyComponentMessengerMiddlewareHandleMessageMiddleware;
use SymfonyComponentMessengerMiddlewareSendMessageMiddleware;
use SymfonyComponentMessengerTransportSenderSendersLocator;

require_once __DIR__ . '/../vendor/autoload.php';
/** @var PsrContainerContainerInterface $container */
$container = require_once('config/container.php');

$handlers = [
    DaemonLogMessage::class => [
        new HandlerDescriptor(
            function (DaemonLogMessage $m) {
                error_log('DaemonLogHandler: message handled: / ' . $m->getMessage());
            },
            ['from_transport' => CONTAINER_REDIS_TRANSPORT_LOG]
        )
    ],
];
$middleware = [];
$middleware[] = new HandleMessageMiddleware(new HandlersLocator($handlers));
$sendersLocator = new SendersLocator(['*' => [CONTAINER_REDIS_TRANSPORT_LOG]], $container);
$middleware[] = new SendMessageMiddleware($sendersLocator);

$bus = new MessageBus($middleware);
$receivers = [
    CONTAINER_REDIS_TRANSPORT_LOG => $container->get(CONTAINER_REDIS_STREAM_RECEIVER_LOG),
];
$w = new SymfonyComponentMessengerWorker($receivers, $bus, $container->get(CONTAINER_EVENT_DISPATCHER));
$w->run();

ການນໍາໃຊ້ໂຄງສ້າງພື້ນຖານນີ້ໃນແອັບພລິເຄຊັນ

ໂດຍໄດ້ປະຕິບັດລົດເມໃນ backend ຂອງຂ້ອຍ, ຂ້ອຍແຍກຂັ້ນຕອນຂອງບຸກຄົນອອກຈາກຄໍາສັ່ງ synchronous ເກົ່າແລະສ້າງຕົວຈັດການແຍກຕ່າງຫາກ, ແຕ່ລະຄົນເຮັດສິ່ງຂອງຕົນເອງ.

ທໍ່ສໍາລັບການເພີ່ມເວັບໄຊທ໌ໃຫມ່ໃນຖານຂໍ້ມູນເບິ່ງຄືວ່ານີ້:

ແລະທັນທີຫຼັງຈາກນັ້ນ, ມັນໄດ້ກາຍເປັນງ່າຍຂຶ້ນຫຼາຍສໍາລັບຂ້ອຍທີ່ຈະເພີ່ມຫນ້າທີ່ໃຫມ່, ສໍາລັບການຍົກຕົວຢ່າງ, ການສະກັດແລະແຍກ Rss. ເນື່ອງຈາກວ່າ ຂະບວນການນີ້ຍັງຕ້ອງການເນື້ອຫາຕົ້ນສະບັບ, ຫຼັງຈາກນັ້ນ RSS link extractor handler, ເຊັ່ນ WebsiteIndexHistoryPersistor, ຈອງຂໍ້ຄວາມ "Content/HtmlContent", ປະມວນຜົນມັນແລະສົ່ງຂໍ້ຄວາມທີ່ຕ້ອງການຕາມທໍ່ຂອງມັນຕື່ມອີກ.

ໃນທີ່ສຸດ, ພວກເຮົາສິ້ນສຸດລົງດ້ວຍ daemon ຫຼາຍ, ແຕ່ລະຄົນຮັກສາການເຊື່ອມຕໍ່ພຽງແຕ່ກັບຊັບພະຍາກອນທີ່ຈໍາເປັນ. ສໍາລັບຕົວຢ່າງ, ຜີປີສາດ ຕົວກວາດເວັບ ປະກອບມີຕົວຈັດການທັງຫມົດທີ່ຮຽກຮ້ອງໃຫ້ໄປຫາອິນເຕີເນັດສໍາລັບເນື້ອຫາ, ແລະ daemon ຄົງຢູ່ ຖືການເຊື່ອມຕໍ່ກັບຖານຂໍ້ມູນ.

ໃນປັດຈຸບັນ, ແທນທີ່ຈະເລືອກຈາກຖານຂໍ້ມູນ, ids ທີ່ຕ້ອງການຫຼັງຈາກການໃສ່ໂດຍ persister ແມ່ນພຽງແຕ່ສົ່ງຜ່ານລົດເມໄປຫາຜູ້ຈັດການທີ່ສົນໃຈທັງຫມົດ.

ແຫຼ່ງຂໍ້ມູນ: www.habr.com