Разбирање на брокери за пораки. Учење на механиката на пораки со ActiveMQ и Кафка. Поглавје 1

Здраво на сите!

Почнав да преведувам мала книга:
«Разбирање на брокери за пораки«
автор: Јакуб Кораб, издавач: O'Reilly Media, Inc., датум на објавување: јуни 2017 година, ISBN: 9781492049296.

Од воведот на книгата:
"... Оваа книга ќе ве научи како да размислувате за системите за испраќање пораки со посредување со споредување и контрастирање на две популарни технологии за посредување: Apache ActiveMQ и Apache Kafka. Ќе ги наведе случаите на употреба и развојните стимулации кои ги наведоа нивните програмери да преземат многу различни пристапи кон истата област на пораки со посредување помеѓу системите. Ќе ги разгледаме овие технологии од основата и ќе го истакнеме влијанието на различниот избор на дизајн на патот. Ќе стекнете длабоко разбирање за двата производи, разбирање за тоа како тие треба и не треба да се користат и разбирање на што да внимавате кога размислувате за други технологии за пораки во иднина. … »

Досега преведени делови:
Поглавје 1 Вовед
Поглавје 3. Кафка

Ќе постирам завршени поглавја како што се преведени.

ПОГЛАВЈЕ 1

Вовед

Интерсистемските пораки се една од најмалку разбраните области на ИТ. Како развивач или архитект, можеби сте многу запознаени со различни рамки и бази на податоци. Сепак, веројатно е дека имате само увид како функционираат технологиите за пораки базирани на брокер. Ако така се чувствувате, не грижете се, вие сте во добро друштво.

Луѓето обично имаат многу ограничен контакт со инфраструктурата за пораки. Честопати тие се поврзуваат со систем создаден одамна, или преземаат комплет за дистрибуција од Интернет, го инсталираат во PROM и почнуваат да пишуваат код за него. По извршувањето на инфраструктурата во PROM, резултатите може да се мешаат: пораките се губат при падови, испраќањата не функционираат како што очекувате или брокерите ги обесуваат вашите производители или не испраќаат пораки до вашите потрошувачи.

Звучи познато?

Вообичаено сценарио каде што вашиот код за пораки работи добро, засега. Се додека не престане да работи. Овој период ја затишува будноста и дава лажно чувство на сигурност, што доведува до уште повеќе код заснован на лажни идеи за фундаменталното однесување на технологијата. Кога работите почнуваат да одат наопаку, се соочувате со непријатна вистина: дека навистина не сте го разбрале основното однесување на производот, или компромисите избрани од авторите, како што се перформансите наспроти робусноста или трансакциските наспроти хоризонталните приспособливост.

Без длабоко разбирање за тоа како работат брокерите, луѓето прават навидум разумни тврдења за нивните системи за пораки, како што се:

• Системот никогаш нема да губи пораки
• Пораките ќе се обработуваат последователно
• Додавањето потрошувачи ќе го направи системот побрз
• Пораките ќе бидат испорачани само еднаш

За жал, некои од овие изјави се засноваат на претпоставки кои се применуваат само под одредени околности, додека други едноставно не се вистинити.

Оваа книга ќе ве научи како да размислувате за системите за испраќање пораки со посредување со споредување и контрастирање на две популарни технологии за посредување: Apache ActiveMQ и Apache Kafka. Ќе ги наведе случаите на употреба и развојните стимулации кои ги наведоа нивните програмери да преземат многу различни пристапи кон истата област на пораки со посредување помеѓу системите. Ќе ги разгледаме овие технологии од основата и ќе го истакнеме влијанието на различниот избор на дизајн на патот. Ќе стекнете длабоко разбирање за двата производи, разбирање за тоа како тие треба и не треба да се користат и разбирање на што да внимавате кога размислувате за други технологии за пораки во иднина.

Пред да започнеме, да ги разгледаме основите.

Што е систем за пораки и зошто е потребен

За да можат две апликации да комуницираат една со друга, прво мора да дефинираат интерфејс. Дефиницијата на овој интерфејс вклучува избор на транспорт или протокол како што се HTTP, MQTT или SMTP и преговарање за форматите на пораки што ќе ги разменат системите. Ова може да биде строг процес, како што е дефинирање на XML шема со барања за трошоците за носивост за порака, или може да биде многу помалку формален, како што е договор меѓу двајца програмери дека некој дел од барањето HTTP ќе содржи идентификатор на клиентот.

Сè додека форматот на пораките и редоследот по кој се испраќаат се конзистентни помеѓу системите, тие ќе можат да комуницираат меѓу себе без да се грижат за имплементацијата на другиот систем. Внатрешноста на овие системи, како што се програмскиот јазик или рамката што се користи, може да се менуваат со текот на времето. Сè додека самиот договор се одржува, интеракцијата може да продолжи непроменета на другата страна. Двата системи се ефективно одвоени (одвоени) со овој интерфејс.

Системите за пораки обично вклучуваат посредник помеѓу два системи кои комуницираат за дополнително да го раздвојат (одвојуваат) испраќачот од примачот или примачите. Во овој случај, системот за пораки му овозможува на испраќачот да испрати порака без да знае каде се наоѓа примачот, дали е активен или колку од нивните примери.

Ајде да погледнеме неколку аналогии за видовите проблеми што ги решава системот за пораки и да воведеме некои основни термини.

Точка-до-точка

Александра оди во пошта да му испрати пакет на Адам. Таа оди до прозорецот и ја дава пакетот на вработениот. Вработената го зема пакетот и и дава на Александра потврда. Адам нема потреба да биде дома кога ќе се испрати пакетот. Александра е уверена дека пакетот ќе му биде доставен на Адам во одреден момент во иднина и може да продолжи да се занимава со својата работа. Подоцна, во одреден момент, Адам добива пакет.

Ова е пример за модел на пораки точка до точка. Поштата овде делува како механизам за дистрибуција на пакети, осигурувајќи дека секој пакет е испорачан еднаш. Користењето на поштата го одделува чинот на испраќање на парцелата од испораката на парцелата.
Во класичните системи за пораки, моделот од точка до точка се имплементира преку редици. Редот делува како FIFO (прв влегува, прв излезе) бафер на кој може да се претплатат еден или повеќе потрошувачи. Секоја порака се доставува само еден од претплатените потрошувачи. Редиците обично се обидуваат да ги дистрибуираат пораките праведно меѓу потрошувачите. Само еден потрошувач ќе ја добие оваа порака.

Терминот „издржлив“ се применува на редици. Сигурност е својство на услуга што гарантира дека системот за пораки ќе ги чува пораките во отсуство на активни претплатници додека потрошувачот не се претплати на редот за испорака на пораки.

Доверливоста често се меша со упорност и, иако двата поима се заменливи, тие извршуваат различни функции. Упорноста одредува дали пораката е напишана од системот за пораки во некој вид складиште помеѓу нејзиното примање и испраќањето до потрошувачот. Пораките испратени на редот може или не мора да бидат постојани.
Пораки од точка до точка се користи кога случајот за употреба бара едно дејство на пораката. Примерите вклучуваат депонирање средства на сметка или исполнување на нарачка за испорака. Подоцна ќе разговараме зошто системот за пораки сам по себе не е способен да обезбеди еднократна испорака и зошто редиците во најдобар случај можат да обезбедат гаранција за испорака. барем еднаш.

Издавач-Претплатник

Габриела го бира бројот на конференцијата. Додека е поврзана со конференцијата, таа слуша сè што кажува говорникот, заедно со останатите учесници во повикот. Кога ќе се зацрни, ѝ недостига кажаното. Кога повторно се поврзува, таа продолжува да слуша што се зборува.

Ова е пример за модел на пораки објавува-претплати. Конференцискиот повик делува како механизам за емитување. На лицето што зборува не му е грижа колку луѓе моментално се на повик - системот гарантира дека секој што е поврзан во моментот ќе слушне што се зборува.
Во класичните системи за испраќање пораки, моделот за испраќање пораки објавување-претплати се имплементира преку врвови. Темата го обезбедува истиот метод на емитување како механизмот за конференции. Кога пораката е објавена на тема, таа се дистрибуира за сите претплатени корисници.

Темите обично несигурен (неиздржлив). Како слушател кој не може да слушне што се зборува на конференциски повик, кога слушателот оди офлајн, претплатниците на темата ги пропуштаат сите пораки што се испраќаат додека се офлајн. Поради оваа причина, можеме да кажеме дека врвовите обезбедуваат гаранција за испорака. не повеќе од еднаш за секој потрошувач.

Пораки Publish-Subscribe обично се користат кога пораките се од информативен карактер и кога загубата на една порака не е особено значајна. На пример, една тема може да пренесува температурни отчитувања од група сензори еднаш во секунда. Систем кој е заинтересиран за моменталната температура и кој се претплати на тема нема да се грижи ако пропушти порака - наскоро ќе пристигне друга.

хибридни модели

Веб-страницата на продавницата ги става пораките за нарачка во „редица за пораки“. Главниот потрошувач на овие пораки е извршниот систем. Дополнително, системот за ревизија мора да има копии од овие пораки за нарачка за подоцна следење. И двата системи не можат да пропуштат пораки, дури и ако самите системи се недостапни некое време. Веб-страницата не треба да биде свесна за други системи.

Случаите на употреба често бараат мешавина од модели за објавување-претплати и испраќање пораки од точка до точка, како на пример кога на повеќе системи им е потребна копија од пораката и потребна е и сигурност и упорност за да се спречи губењето на пораката.

Во овие случаи, потребна е дестинација (општ термин за редици и теми), која ги дистрибуира пораките во основа како тема, така што секоја порака се испраќа до посебен систем заинтересиран за овие пораки, но и во кој секој систем може да дефинира неколку потрошувачи. кои примаат дојдовни пораки, што е повеќе како редица. Типот за читање во овој случај е − еднаш за секоја заинтересирана страна. Овие хибридни дестинации често бараат издржливост, така што ако потрошувачот се исклучи, пораките што се испраќаат во тоа време се прифаќаат кога потрошувачот повторно ќе се поврзе.

Хибридните модели не се нови и може да се применат на повеќето системи за пораки, вклучувајќи ги и ActiveMQ (преку виртуелни или композитни дестинации кои комбинираат теми и редици) и Kafka (имплицитно, како основна карактеристика на дизајнот на неговата дестинација).

Сега, кога имаме основна терминологија и разбираме за што може да биде корисен системот за пораки, ајде да навлеземе во деталите.

Преводот е направен: tele.gg/middle_java

Следен преведен дел: Поглавје 3. Кафка

Да се ​​продолжи ...

Извор: www.habr.com