{"id":33075,"date":"2019-10-31T21:50:35","date_gmt":"2019-10-31T18:50:35","guid":{"rendered":"https:\/\/prohoster.info\/blog\/besprostojnaya-migratsiya-rabbitmq-v-kubernetes\/"},"modified":"2019-10-31T21:50:35","modified_gmt":"2019-10-31T18:50:35","slug":"besprostojnaya-migratsiya-rabbitmq-v-kubernetes","status":"publish","type":"post","link":"https:\/\/prohoster.info\/hu\/blog\/administrirovanie\/besprostojnaya-migratsiya-rabbitmq-v-kubernetes","title":{"rendered":"Meghib\u00e1sod\u00e1smentes RabbitMQ migr\u00e1ci\u00f3 a Kubernetesben","gt_translate_keys":[{"key":"rendered","format":"text"}]},"content":{"rendered":"

\"Meghib\u00e1sod\u00e1smentes
\n
\nA RabbitMQ egy Erlang nyelven \u00edrt \u00fczenetbr\u00f3ker, amely lehet\u0151v\u00e9 teszi a hibat\u0171r\u0151 klaszterek l\u00e9trehoz\u00e1s\u00e1t, teljes adatreplik\u00e1ci\u00f3val t\u00f6bb csom\u00f3ponton, ahol minden csom\u00f3pont k\u00e9pes olvas\u00e1si \u00e9s \u00edr\u00e1si k\u00e9r\u00e9sek kiszolg\u00e1l\u00e1s\u00e1ra. Sz\u00e1mos Kubernetes klasztert \u00fczemeltetve a gyakorlatban, nagy sz\u00e1m\u00fa RabbitMQ telep\u00edt\u00e9st t\u00e1mogatunk, \u00e9s szembes\u00fclt\u00fcnk a sz\u00fcks\u00e9ggel, hogy adatokat migr\u00e1ljunk az egyik klaszterb\u0151l a m\u00e1sikba le\u00e1ll\u00e1s n\u00e9lk\u00fcl.<\/a><\/noindex><\/p>\n

Ez a m\u0171velet legal\u00e1bb k\u00e9t esetben volt sz\u00fcks\u00e9ges:<\/p>\n

    \n
  1. Adatok \u00e1tvitele egy RabbitMQ klaszterb\u0151l, amely nem Kubernetes k\u00f6rnyezetben van, egy \u00faj, 'kuberneteses\u00edtett' (azaz K8s podokban m\u0171k\u00f6d\u0151) klaszterbe.<\/li>\n
  2. RabbitMQ migr\u00e1ci\u00f3ja Kubernetesen bel\u00fcl egyik namespace-b\u0151l a m\u00e1sikba (p\u00e9ld\u00e1ul, ha a hat\u00e1rok n\u00e9vtereken kereszt\u00fcl vannak elhat\u00e1rolva, akkor az infrastrukt\u00fara \u00e1tvitel\u00e9hez az egyik hat\u00e1rb\u00f3l a m\u00e1sikba).<\/li>\n<\/ol>\n

    \nA cikkben javasolt recept olyan helyzetekre ir\u00e1nyul (de nem korl\u00e1toz\u00f3dik ezekre), ahol van egy r\u00e9gi RabbitMQ klaszter (p\u00e9ld\u00e1ul 3 csom\u00f3pontb\u00f3l \u00e1ll\u00f3), amely m\u00e1r K8s alatt van, vagy r\u00e9gi szervereken m\u0171k\u00f6dik. Ezzel egy Kubernetesen telep\u00edtett alkalmaz\u00e1s dolgozik (jelenleg ott vagy a j\u00f6v\u0151ben):<\/p>\n

    \"Meghib\u00e1sod\u00e1smentes
    \n
    \n\u2026 \u00e9s el\u0151tt\u00fcnk \u00e1ll a feladat, hogy ezt migr\u00e1ljuk az \u00faj produkci\u00f3s k\u00f6rnyezetbe Kubernetes alatt.<\/p>\n

    El\u0151sz\u00f6r az \u00e1ltal\u00e1nos megk\u00f6zel\u00edt\u00e9st \u00edrjuk le a migr\u00e1ci\u00f3hoz, majd ezt k\u00f6vet\u0151en a technikai r\u00e9szletek a megval\u00f3s\u00edt\u00e1s\u00e1r\u00f3l.<\/p>\n

    A migr\u00e1ci\u00f3s algoritmus<\/h2>\n

    \nAz els\u0151, el\u0151zetes l\u00e9p\u00e9s b\u00e1rmely cselekedet el\u0151tt \u2014 ellen\u0151rizni, hogy a r\u00e9gi RabbitMQ telep\u00edt\u00e9sen a magas rendelkez\u00e9sre \u00e1ll\u00e1s \u00fczemm\u00f3d be van kapcsolva (HA<\/a><\/noindex>). Az ok nyilv\u00e1nval\u00f3 \u2014 nem akarunk elvesz\u00edteni adatokat. Ezt az ellen\u0151rz\u00e9st a RabbitMQ adminisztr\u00e1tori fel\u00fclet\u00e9n tehetj\u00fck meg, az Admin \u2192 Policies f\u00fcl alatt megbizonyosodva arr\u00f3l, hogy az \u00e9rt\u00e9k be van \u00e1ll\u00edtva ha-mode: all<\/code>:<\/p>\n

    \"Meghib\u00e1sod\u00e1smentes
    \n
    \nA k\u00f6vetkez\u0151 l\u00e9p\u00e9s \u2014 \u00faj RabbitMQ klaszter ind\u00edt\u00e1sa K8s podokban (ebben az esetben, p\u00e9ld\u00e1ul, 3 csom\u00f3pontb\u00f3l \u00e1ll\u00f3, de a sz\u00e1muk m\u00e1s is lehet).<\/p>\n

    Ezut\u00e1n \u00f6sszekapcsoljuk a r\u00e9gi \u00e9s az \u00faj RabbitMQ klasztert, \u00edgy egy egyes\u00edtett klasztert kapunk (6 csom\u00f3pontb\u00f3l \u00e1ll\u00f3):<\/p>\n

    \"Meghib\u00e1sod\u00e1smentes
    \n
    \nMegkezd\u0151dik az adatok szinkroniz\u00e1l\u00e1sa a r\u00e9gi \u00e9s az \u00faj RabbitMQ klaszterek k\u00f6z\u00f6tt. Miut\u00e1n minden adat szinkroniz\u00e1lva lett az \u00f6sszes csom\u00f3ponton a klaszterben, \u00e1tkapcsolhatjuk az alkalmaz\u00e1st az \u00faj klaszter haszn\u00e1lat\u00e1ra:<\/p>\n

    \"Meghib\u00e1sod\u00e1smentes
    \n
    \nEzek ut\u00e1n elegend\u0151, ha elt\u00e1vol\u00edtjuk a r\u00e9gi csom\u00f3pontokat a RabbitMQ klaszterb\u0151l, \u00e9s a k\u00f6lt\u00f6z\u00e9st befejezettnek nyilv\u00e1n\u00edthatjuk:<\/p>\n

    \"Meghib\u00e1sod\u00e1smentes
    \n
    \nEzt a s\u00e9m\u00e1t t\u00f6bbsz\u00f6r is alkalmaztuk a production k\u00f6rnyezet\u00fcnkben. Azonban a saj\u00e1t k\u00e9nyelm\u00fcnk \u00e9rdek\u00e9ben megval\u00f3s\u00edtottuk egy speci\u00e1lis rendszer keretein bel\u00fcl, amely standard RMQ konfigur\u00e1ci\u00f3kat terjeszt Kubernetes klaszterek t\u00f6megein. (azoknak, akiket \u00e9rdekel: a     addon-operator<\/a><\/noindex>sz\u00f3l, amir\u0151l nemr\u00e9giben mes\u00e9lt\u00fcnk.<\/a><\/noindex>)<\/i>Al\u00e1bb k\u00fcl\u00f6n\u00e1ll\u00f3 utas\u00edt\u00e1sokat mutatunk be, amelyeket mindenki alkalmazhat a saj\u00e1t telep\u00edt\u00e9sein, hogy kipr\u00f3b\u00e1lja a javasolt megold\u00e1st a gyakorlatban.<\/p>\n

    Pr\u00f3b\u00e1ljuk ki a gyakorlatban.<\/h2>\n

    <\/p>\n

    K\u00f6vetelm\u00e9nyek<\/h3>\n

    \nA k\u00f6vetelm\u00e9nyek nagyon egyszer\u0171ek:<\/p>\n

      \n
    1. Kubernetes klaszter (a minikube is megfelel\u0151);<\/li>\n
    2. RabbitMQ klaszter (telep\u00edthet\u0151 bare metal-on is, vagy hagyom\u00e1nyos Kubernetes klaszterk\u00e9nt az hivatalos Helm-chartb\u00f3l).<\/li>\n<\/ol>\n

      \nA lent le\u00edrt p\u00e9lda kedv\u00e9\u00e9rt RMQ-t telep\u00edtettem Kubernetes-be, \u00e9s elneveztem rmq-old<\/code>.<\/p>\n

      A k\u00f6rnyezet el\u0151k\u00e9sz\u00edt\u00e9se<\/h3>\n

      \n1. Let\u00f6ltj\u00fck a Helm-chartot, \u00e9s egy kicsit m\u00f3dos\u00edtjuk:<\/p>\n

      helm fetch --untar stable\/rabbitmq-ha<\/code><\/pre>\n
      \nA k\u00e9nyelem kedv\u00e9\u00e9rt be\u00e1ll\u00edtjuk a jelsz\u00f3t, ErlangCookie<\/code> \u00e9s k\u00e9sz\u00edt\u00fcnk egy politik\u00e1t ha-all<\/code>, hogy alap\u00e9rtelmezettk\u00e9nt a sorok szinkroniz\u00e1l\u00f3djanak az RMQ klaszter minden csom\u00f3pontja k\u00f6z\u00f6tt:<\/p>\n
      rabbitmqPassword: guest\nrabbitmqErlangCookie: mae9joopaol7aiVu3eechei2waiGa2we\ndefinitions:\npolicies: |-\n  {\n    \"name\": \"ha-all\",\n    \"pattern\": \".*\",\n    \"vhost\": \"\\\/\",\n    \"definition\": {\n      \"ha-mode\": \"all\",\n      \"ha-sync-mode\": \"automatic\",\n      \"ha-sync-batch-size\": 81920\n    }\n  }<\/code><\/pre>\n
      \n2. Telep\u00edtj\u00fck a chartot:<\/p>\n
      helm install . --name rmq-old --namespace rmq-old<\/code><\/pre>\n
      \n3. Bel\u00e9p\u00fcnk a RabbitMQ admin fel\u00fclet\u00e9re, l\u00e9trehozunk egy \u00faj sort, \u00e9s hozz\u00e1adunk n\u00e9h\u00e1ny \u00fczenetet. Ezek sz\u00fcks\u00e9gesek lesznek ahhoz, hogy a migr\u00e1ci\u00f3 ut\u00e1n megbizonyosodjunk arr\u00f3l, hogy minden adat megmaradt \u00e9s nem vesztett\u00fcnk el semmit:<\/p>\n
      \"Meghib\u00e1sod\u00e1smentes
      \n
      \nA tesztk\u00f6rnyezet k\u00e9szen \u00e1ll: van egy 'r\u00e9gi' RabbitMQ-nk az adatokkal, amelyeket \u00e1t kell vinni.<\/p>\n
      RabbitMQ klaszter migr\u00e1l\u00e1sa<\/h3>\n
      \n1. El\u0151sz\u00f6r telep\u00edtj\u00fck az \u00faj RabbitMQ-t a egy bar\u00e1tommal<\/b> n\u00e9vt\u00e9rben, ugyanazzal<\/b> ErlangCookie<\/code> \u00e9s a felhaszn\u00e1l\u00f3 jelszav\u00e1val. Ehhez hajtsuk v\u00e9gre a fent le\u00edrt m\u0171veleteket, \u00e9s m\u00f3dos\u00edtsuk az RMQ telep\u00edt\u00e9s v\u00e9gs\u0151 parancs\u00e1t a k\u00f6vetkez\u0151re:<\/p>\n
      helm install . --name rmq-new --namespace rmq-new<\/code><\/pre>\n
      \n2. Most sz\u00fcks\u00e9g van arra, hogy \u00f6sszekapcsoljuk az \u00faj klasztert a r\u00e9givel. Ehhez bel\u00e9p\u00fcnk az egyes pod-okba \u00faj<\/b> RabbitMQ \u00e9s v\u00e9grehajtjuk a parancsokat:<\/p>\n
      export OLD_RMQ=rabbit@rmq-old-rabbitmq-ha-0.rmq-old-rabbitmq-ha-discovery.rmq-old.svc.cluster.local && \n  rabbitmqctl stop_app && \n  rabbitmqctl join_cluster $OLD_RMQ && \n  rabbitmqctl start_app<\/code><\/pre>\n
      \nAz OLD_RMQ<\/code> v\u00e1ltoz\u00f3 tartalmazza egy r\u00e9gi RMQ klaszter csom\u00f3pontnak a c\u00edm\u00e9t.<\/b> Ezek a parancsok le\u00e1ll\u00edtj\u00e1k a jelenlegi csom\u00f3pontot<\/p>\n
      az RMQ klaszterb\u0151l, csatlakoztatj\u00e1k a r\u00e9gi klaszterhez, \u00e9s \u00fajraind\u00edtj\u00e1k. \u00faj<\/b> 3. A 6 csom\u00f3pontb\u00f3l \u00e1ll\u00f3 RMQ klaszter k\u00e9sz:<\/p>\n
      3. Az 6 csom\u00f3pontos RMQ klaszter k\u00e9szen \u00e1ll:<\/p>\n
      \"Meghib\u00e1sod\u00e1smentes
      \n
      \nV\u00e1rni kell, am\u00edg az \u00fczenetek szinkroniz\u00e1l\u00f3dnak az \u00f6sszes csom\u00f3pont k\u00f6z\u00f6tt. Nem neh\u00e9z kital\u00e1lni, hogy az \u00fczenetek szinkroniz\u00e1l\u00e1s\u00e1nak ideje a haszn\u00e1lt hardver teljes\u00edtm\u00e9ny\u00e9t\u0151l \u00e9s az \u00fczenetek sz\u00e1m\u00e1t\u00f3l f\u00fcgg. A le\u00edrt forgat\u00f3k\u00f6nyvben mind\u00f6ssze 10 \u00fczenetr\u0151l van sz\u00f3, ez\u00e9rt az adatok azonnal szinkroniz\u00e1l\u00f3dtak, de elegend\u0151 sz\u00e1m\u00fa \u00fczenet eset\u00e9n a szinkroniz\u00e1l\u00e1s \u00f3r\u00e1kig is tarthat.<\/p>\n
      Teh\u00e1t a szinkroniz\u00e1l\u00e1s st\u00e1tusza:<\/p>\n
      \"Meghib\u00e1sod\u00e1smentes
      \n
      \nItt +5<\/code> azt jelenti, hogy az \u00fczenetek m\u00e1r m\u00e9g<\/b> 5 csom\u00f3ponton vannak (azon k\u00edv\u00fcl, amely a mez\u0151ben van Node<\/code>). \u00cdgy a szinkroniz\u00e1l\u00e1s sikeresen lezajlott.<\/p>\n
      4. Csak annyit kell tenni, hogy az alkalmaz\u00e1sban az RMQ c\u00edm\u00e9t az \u00faj klaszterre \u00e1ll\u00edtjuk (a konkr\u00e9t l\u00e9p\u00e9sek itt a haszn\u00e1lt technol\u00f3giai stackt\u0151l \u00e9s az alkalmaz\u00e1s egy\u00e9b saj\u00e1toss\u00e1gait\u00f3l f\u00fcggnek), majd b\u00facs\u00fat mondhatunk a r\u00e9ginek.<\/p>\n
      Az utols\u00f3 m\u0171velethez (azaz m\u00e1r a jelenlegi k\u00f6rnyezet parancsai ut\u00e1n<\/b> az alkalmaz\u00e1s \u00faj klaszterre v\u00e1lt\u00e1s\u00e1hoz) l\u00e9pj\u00fcnk be minden csom\u00f3pontba RMQ klaszter csom\u00f3pontnak a c\u00edm\u00e9t.<\/b> a klaszterb\u0151l, \u00e9s hajtsuk v\u00e9gre a parancsokat:<\/p>\n
      rabbitmqctl stop_app\nrabbitmqctl reset<\/code><\/pre>\n
      \nA klaszter \"elfelejtette\" a r\u00e9gi csom\u00f3pontokat: elt\u00e1vol\u00edthatjuk a r\u00e9gi RMQ-t, amivel a k\u00f6lt\u00f6z\u00e9s befejez\u0151dik.<\/p>\n
      Megjegyz\u00e9s<\/b>: Ha RMQ-t tan\u00fas\u00edtv\u00e1nyokkal haszn\u00e1l, akkor l\u00e9nyeg\u00e9ben semmi nem v\u00e1ltozik \u2014 a k\u00f6lt\u00f6z\u00e9si folyamat pontosan ugyan\u00fagy fog zajlani.<\/i><\/p>\n
      K\u00f6vetkeztet\u00e9sek<\/h2>\n
      \nA le\u00edrt s\u00e9ma gyakorlatilag minden esetben alkalmazhat\u00f3, amikor a RabbitMQ-t kell \u00e1thelyezn\u00fcnk vagy egyszer\u0171en \u00faj klaszterre kell k\u00f6lt\u00f6zn\u00fcnk.<\/p>\n
      A mi eset\u00fcnkben csak egyszer akadtak neh\u00e9zs\u00e9geink, amikor az RMQ-t t\u00f6bb helyr\u0151l h\u00edvt\u00e1k meg, \u00e9s nem volt m\u00f3dunk az \u00f6sszes helyen megv\u00e1ltoztatni az RMQ c\u00edm\u00e9t az \u00faj\u00e1ra. Ilyenkor \u00faj RMQ-t ind\u00edtottunk ugyanabban a n\u00e9vt\u00e9rben, azonos c\u00edmk\u00e9kkel, hogy beleessen a m\u00e1r megl\u00e9v\u0151 szolg\u00e1ltat\u00e1sokba \u00e9s Ingress-ekbe, a pod ind\u00edt\u00e1sakor pedig manu\u00e1lisan manipul\u00e1ltuk a c\u00edmk\u00e9ket, el\u0151sz\u00f6r elt\u00e1vol\u00edtva azokat, hogy a \u00fcres RMQ-ra ne \u00e9rkezzenek k\u00e9r\u00e9sek, majd a szinkroniz\u00e1l\u00e1s ut\u00e1n visszaadva \u0151ket.<\/p>\n
      Ugyanezt a strat\u00e9gi\u00e1t alkalmaztuk, amikor a RabbitMQ-t \u00faj verzi\u00f3ra friss\u00edtett\u00fck m\u00f3dos\u00edtott konfigur\u00e1ci\u00f3val \u2014 minden probl\u00e9mamentesen m\u0171k\u00f6d\u00f6tt.<\/p>\n
      P.S.<\/h2>\n
      \nE t\u00e9ma logikai folytat\u00e1sak\u00e9nt cikkeket k\u00e9sz\u00edt\u00fcnk a MongoDB-r\u0151l (migr\u00e1l\u00e1s egy fizikai szerverr\u0151l Kubernetesbe) \u00e9s a MySQL-r\u0151l (hogyan k\u00e9sz\u00edtj\u00fck el\u0151 ezt az adatb\u00e1zis-kezel\u0151t Kubernetesben). Ezek a k\u00f6vetkez\u0151 h\u00f3napokban fognak megjelenni.<\/p>\n
      P.P.S.<\/h2>\n
      \nOlvasson tov\u00e1bbi inform\u00e1ci\u00f3kat a blogunkban:<\/p>\n