Az XXL-JOB egy elosztott feladatütemezési platform, amelynek alapvető tervezési céljai a gyors fejlesztés, egyszerű tanulás, könnyűség és könnyen skálázható. Most már nyílt forráskódú, és számos cég online termékvonalához kapcsolódik, és már dobozból is használatra kész.
Szemle:
GitHub cím:A hiperlink bejelentkezés látható.
Hivatalos dokumentum címe:A hiperlink bejelentkezés látható.
Először töltsd le a forráskódot, címet:A hiperlink bejelentkezés látható.(Letöltés a hazai gitee-n keresztül)
Adatbázis- és táblastruktúrák létrehozása
Szkriptfájl címe:/xxl-job/doc/db/tables_xxl_job.sql, importálja a szkriptet, és a szkript automatikusan meghatározza, hogy van-e xxl_job adatbázis, automatikusan létrehoz egy xxl_job adatbázist, létrehozza a megfelelő táblastruktúrát és beilleszti az eredeti adatokat. Ahogy az alábbiakban látható:
Nyisd meg a projektet
Használd az Eclipse-t a Maven projekt importálásához, és fordítsd le a Mavennel.
A forráskód szerkezete a következő:
xxl-job-admin: Dispatch központ
xxl-job-core: Gyakori függőségek
xxl-job-executor-samples: Executor Sample példa (válaszd ki a végrehajtó megfelelő verzióját, közvetlenül használhatod, vagy hivatkozhatsz rá, és átalakíthatod a meglévő projektet végrehajtóvá)
:xxl-job-executor-sample-springboot:Springboot verzió, a Springboot management executor segítségével ezt a módszert ajánljuk;
:xxl-job-executor-sample-frameless: keret nélküli verzió;
Indítsd el az xxl-job-admin ütemezési központot
xxl-job-admin a mySQL adatbázis-kapcsolat konfigurálásához：
Nyisd meg a /xxl-job/xxl-job-admin/src/main/resources/application.properties konfigurációs fájlt, és konfiguráld a következőként:
Nyisd meg a XxlJobAdminApplication.java fájlt, és indítsd el a projektet.
A webkezelő felülethez az alábbi címen érheti el a látogatókat:http://127.0.0.1:8080/xxl-job-admin, ahogy az alábbi ábrán látható:
Alapértelmezett bejelentkezési fiók "admin/123456”
Indítsd el az aktuátor projektet
Keresd meg az xxl-job-executor-sample-springboot projektet, és módosítsd az application.properties konfigurációs fájlt az alábbiakban:
Az aktuátor konfigurációjának hivatalos részletes magyarázata:
### Disszpécser központ telepítése és címezése [opcionális]: Ha a diszpécser központ klaszterében több cím van, vesszővel vannak elválasztva. A végrehajtó ezt a címet használja a "Végrehajtó szívverése" és a "Visszahívás a feladat eredményének" regisztrálásához. Ha üres, az automatikus regisztráció ki van kapcsolva.
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
### Aktuátor kommunikációs TOKEN [opcionális]: engedélyezve, ha nem üres;
xxl.job.accessToken=
### Actuator AppName [opcionális]: Az aktuátor szívverésének regisztrációjának csoportosítási alapja; Ha üres, kapcsold ki az automatikus beiratkozást
xxl.job.executor.appname=xxl-job-executor-sample
### Végrehajtó regisztráció [opcionális]: Először ezt a konfigurációt használd regisztrációs címként, és a beágyazott "IP:PORT" szolgáltatást használd regisztrációs címként, amikor az üres. Ez rugalmasabb támogatást nyújt konténer típusú végrehajtók, dinamikus IP és dinamikus leképezési portproblémák esetén.
xxl.job.executor.address=
### Végrehajtó IP [opcionális]: Az alapértelmezett IP üres az IP automatikus megszerzéséhez, és a megadott IP manuálisan is beállítható, ha a NIC többkártyás, ami nem lesz kötve a hosztolóhoz, és csak kommunikációra használható. Címinformációk a "Végrehajtó regisztráció" és a "Diszpécserközpont kérése és trigger feladata" címadatok;
xxl.job.executor.ip=
### Aktuátor portszáma [opcionális]: Ha a 0-nál kisebb vagy egyenlő, automatikusan megkapjuk; Az alapértelmezett port 9999, ezért amikor több aktuátort telepítel egyetlen gépen, figyelj a különböző aktuátor portok konfigurálására.
xxl.job.executor.port=9999
### Executor Run Log File Storage Disk Path [opcionális]: Olvasási és írási jogokkal kell rendelkezned ezen az úton; Ha üres, akkor az alapértelmezett útvonalat használják;
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
### Napok száma a trigger log fájl mentésére [opcionális]: A lejárt naplókat automatikusan tisztítják, és a limit érték nagyobb, mint 3. egyébként, például -1, kapcsolják ki az automatikus tisztítási funkciót;
xxl.job.executor.logretentiondays=30
Nyisd meg a Dispatch Center menedzsment platformot, kattints az Időzítő Menedzsment menüre, adj hozzá egy ütemezőt, és töltsd ki az appname-et: xxl-job-executor-itsvse
Nyisd meg a XxlJobExecutorApplication.java fájlt, és próbáld meg elindítani az végrehajtót az alábbiak szerint:
Az xxl-job-executor-sample-springboot projekt két portot nyit meg: a 8081-es port külső interfész szolgáltatásokhoz, a 9999-es port pedig xxl-job-admin hívásokhoz (amelyeket az ütemezési platformdal való kommunikációhoz használnak).
Hozz létre új ütemezési feladatot
Executor Válaszd ki az imént létrehozott aktuátort, Cron 10 másodpercenként egyszer fut (*/10 * * * * ?), válaszd a futó módban a "BEAN" opciót, töltsd ki a JobHandler: demoJobHandler-t, és a többi opciót is kitöltsd tetszés szerint, csak mentsd el.
Indítsd el a feladatot a lista jobb szélén, majd kattints a Lekérdezési naplóra, ahogy az alábbi ábrán látható:
A diszpécserközpont platform és az executor naplóiban látható, hogy a feladat sikeresen végrehajtott, és a feladatot 10 másodpercenként egyszer hajtják végre.
(Vége)
|
Közzétéve 2021. 09. 07. 16:35:50
|
|
|
|
