സന്ദേശ ബ്രോക്കർമാരെ മനസ്സിലാക്കുന്നു. ActiveMQ, Kafka എന്നിവ ഉപയോഗിച്ച് സന്ദേശമയയ്‌ക്കുന്നതിനുള്ള മെക്കാനിക്‌സ് പഠിക്കുന്നു. അധ്യായം 1

ഹലോ എല്ലാവർക്കും!

ഞാൻ ഒരു ചെറിയ പുസ്തകം വിവർത്തനം ചെയ്യാൻ തുടങ്ങി:
«സന്ദേശ ബ്രോക്കർമാരെ മനസ്സിലാക്കുന്നു",
രചയിതാവ്: Jakub Korab, പ്രസാധകൻ: O'Reilly Media, Inc., പ്രസിദ്ധീകരിച്ച തീയതി: ജൂൺ 2017, ISBN: 9781492049296.

പുസ്തകത്തിന്റെ ആമുഖത്തിൽ നിന്ന്:
"... അപ്പാച്ചെ ആക്റ്റീവ് എംക്യു, അപ്പാച്ചെ കാഫ്ക എന്നീ രണ്ട് ജനപ്രിയ ബ്രോക്കർ സാങ്കേതികവിദ്യകളെ താരതമ്യം ചെയ്ത് ബ്രോക്കർ സന്ദേശമയയ്ക്കൽ സംവിധാനങ്ങളെക്കുറിച്ച് എങ്ങനെ ചിന്തിക്കാമെന്ന് ഈ പുസ്തകം നിങ്ങളെ പഠിപ്പിക്കും. ഒരു ഇന്റർമീഡിയറ്റ് ബ്രോക്കറുള്ള സിസ്റ്റങ്ങൾക്കിടയിൽ സന്ദേശമയയ്‌ക്കൽ, ഒരേ മേഖലയിലേക്ക് വളരെ വ്യത്യസ്തമായ സമീപനങ്ങൾ സ്വീകരിക്കാൻ അവരുടെ ഡവലപ്പർമാരെ പ്രേരിപ്പിച്ച ഉപയോഗ കേസുകളുടെയും വികസന പ്രോത്സാഹനങ്ങളുടെയും രൂപരേഖ ഇത് നൽകും. ഞങ്ങൾ ഈ സാങ്കേതികവിദ്യകളെ അടിസ്ഥാനപരമായി നോക്കുകയും വഴിയിൽ വിവിധ ഡിസൈൻ ചോയ്‌സുകളുടെ സ്വാധീനം എടുത്തുകാണിക്കുകയും ചെയ്യും. രണ്ട് ഉൽപ്പന്നങ്ങളെക്കുറിച്ചും നിങ്ങൾക്ക് ആഴത്തിലുള്ള ധാരണ ലഭിക്കും, അവ എങ്ങനെ ഉപയോഗിക്കണം, ഉപയോഗിക്കരുത് എന്നതിനെക്കുറിച്ചുള്ള ധാരണ, ഭാവിയിൽ മറ്റ് സന്ദേശമയയ്‌ക്കൽ സാങ്കേതികവിദ്യകൾ പരിഗണിക്കുമ്പോൾ എന്താണ് ശ്രദ്ധിക്കേണ്ടതെന്ന് മനസ്സിലാക്കുക. … ”

ഇതുവരെ വിവർത്തനം ചെയ്ത ഭാഗങ്ങൾ:
അധ്യായം 1. ആമുഖം
അധ്യായം 3. കാഫ്ക

പൂർത്തിയാക്കിയ അധ്യായങ്ങൾ വിവർത്തനം ചെയ്യുമ്പോൾ ഞാൻ പോസ്റ്റ് ചെയ്യും.

അധ്യായം 1

ആമുഖം

സിസ്റ്റം-ടു-സിസ്റ്റം സന്ദേശമയയ്ക്കൽ എന്നത് ഐടിയുടെ ഏറ്റവും കുറച്ച് മനസ്സിലാക്കാവുന്ന മേഖലകളിൽ ഒന്നാണ്. ഒരു ഡെവലപ്പർ അല്ലെങ്കിൽ ആർക്കിടെക്റ്റ് എന്ന നിലയിൽ, നിങ്ങൾക്ക് വിവിധ ചട്ടക്കൂടുകളും ഡാറ്റാബേസുകളും വളരെ പരിചിതമായിരിക്കാം. എന്നിരുന്നാലും, ബ്രോക്കർ അധിഷ്‌ഠിത സന്ദേശമയയ്‌ക്കൽ സാങ്കേതികവിദ്യകൾ എങ്ങനെ പ്രവർത്തിക്കുന്നു എന്നതിനെക്കുറിച്ച് നിങ്ങൾക്ക് പരിചയം മാത്രമേ ഉണ്ടാകൂ. നിങ്ങൾക്ക് അങ്ങനെ തോന്നുന്നുവെങ്കിൽ, വിഷമിക്കേണ്ട, നിങ്ങൾ നല്ല കമ്പനിയിലാണ്.

ആളുകൾക്ക് സാധാരണയായി സന്ദേശമയയ്‌ക്കൽ ഇൻഫ്രാസ്ട്രക്ചറുമായി വളരെ പരിമിതമായ സമ്പർക്കമേ ഉള്ളൂ. അവർ പലപ്പോഴും വളരെക്കാലം മുമ്പ് സൃഷ്ടിച്ച ഒരു സിസ്റ്റത്തിലേക്ക് കണക്റ്റുചെയ്യുന്നു, അല്ലെങ്കിൽ ഇന്റർനെറ്റിൽ നിന്ന് ഒരു വിതരണം ഡൌൺലോഡ് ചെയ്യുക, അത് PROM-ൽ ഇൻസ്റ്റാൾ ചെയ്യുകയും അതിനായി കോഡ് എഴുതാൻ തുടങ്ങുകയും ചെയ്യുന്നു. PROM-ൽ ഇൻഫ്രാസ്ട്രക്ചർ പ്രവർത്തിപ്പിച്ചതിന് ശേഷം, ഫലങ്ങൾ സമ്മിശ്രമാകാം: പരാജയങ്ങൾ കാരണം സന്ദേശങ്ങൾ നഷ്‌ടപ്പെടും, അയയ്‌ക്കുന്നത് നിങ്ങൾ പ്രതീക്ഷിച്ചതുപോലെ പ്രവർത്തിക്കുന്നില്ല, അല്ലെങ്കിൽ ബ്രോക്കർമാർ നിങ്ങളുടെ നിർമ്മാതാക്കളെ "തൂങ്ങിക്കിടക്കുക" അല്ലെങ്കിൽ നിങ്ങളുടെ ഉപഭോക്താക്കൾക്ക് സന്ദേശങ്ങൾ അയയ്‌ക്കരുത്.

പരിചിതമാണെന്ന് തോന്നുന്നു?

നിങ്ങളുടെ സന്ദേശമയയ്‌ക്കൽ കോഡ് തൽക്കാലം മികച്ച രീതിയിൽ പ്രവർത്തിക്കുന്നതാണ് ഒരു പൊതു സാഹചര്യം. പ്രവർത്തനം നിർത്തുന്നത് വരെ. ഈ കാലഘട്ടം ഒരാളുടെ കാവൽക്കാരനെ തെറ്റായ സുരക്ഷാ ബോധത്തിലേക്ക് ആകർഷിക്കുന്നു, ഇത് സാങ്കേതികവിദ്യയുടെ അടിസ്ഥാന സ്വഭാവത്തെക്കുറിച്ചുള്ള തെറ്റായ വിശ്വാസങ്ങളെ അടിസ്ഥാനമാക്കിയുള്ള കൂടുതൽ കോഡുകളിലേക്ക് നയിക്കുന്നു. കാര്യങ്ങൾ തെറ്റായി പോകാൻ തുടങ്ങുമ്പോൾ, നിങ്ങൾക്ക് അസുഖകരമായ ഒരു സത്യത്തെ അഭിമുഖീകരിക്കേണ്ടിവരുന്നു: ഉൽപ്പന്നത്തിന്റെ അടിസ്ഥാന സ്വഭാവം അല്ലെങ്കിൽ രചയിതാക്കൾ തിരഞ്ഞെടുത്ത വ്യാപാര-ഓഫുകൾ, പ്രകടനവും വിശ്വാസ്യതയും അല്ലെങ്കിൽ ഇടപാട്, തിരശ്ചീന സ്കേലബിലിറ്റി എന്നിവയും നിങ്ങൾക്ക് ശരിക്കും മനസ്സിലായിട്ടില്ല. .

ബ്രോക്കർമാർ എങ്ങനെ പ്രവർത്തിക്കുന്നു എന്നതിനെക്കുറിച്ച് ആഴത്തിലുള്ള ധാരണയില്ലാതെ, ആളുകൾ അവരുടെ സന്ദേശമയയ്‌ക്കൽ സംവിധാനങ്ങളെക്കുറിച്ച് ന്യായമായ പ്രസ്‌താവനകൾ നടത്തുന്നു:

• സിസ്റ്റത്തിന് ഒരിക്കലും സന്ദേശങ്ങൾ നഷ്‌ടമാകില്ല
• സന്ദേശങ്ങൾ തുടർച്ചയായി പ്രോസസ്സ് ചെയ്യും
• ഉപഭോക്താക്കളെ ചേർക്കുന്നത് സിസ്റ്റം വേഗത്തിലാക്കും
• ഒരു തവണ മാത്രമേ സന്ദേശങ്ങൾ കൈമാറുകയുള്ളൂ

നിർഭാഗ്യവശാൽ, ഈ പ്രസ്താവനകളിൽ ചിലത് ചില പ്രത്യേക സാഹചര്യങ്ങളിൽ മാത്രം ബാധകമായ അനുമാനങ്ങളെ അടിസ്ഥാനമാക്കിയുള്ളതാണ്, മറ്റുള്ളവ കേവലം തെറ്റാണ്.

രണ്ട് ജനപ്രിയ ബ്രോക്കർ സാങ്കേതികവിദ്യകളെ താരതമ്യം ചെയ്തും താരതമ്യം ചെയ്തും ബ്രോക്കർ അടിസ്ഥാനമാക്കിയുള്ള സന്ദേശമയയ്‌ക്കൽ സംവിധാനങ്ങളെക്കുറിച്ച് എങ്ങനെ ചിന്തിക്കാമെന്ന് ഈ പുസ്തകം നിങ്ങളെ പഠിപ്പിക്കും: അപ്പാച്ചെ ആക്റ്റീവ് എംക്യു, അപ്പാച്ചെ കാഫ്ക. ഒരു ഇന്റർമീഡിയറ്റ് ബ്രോക്കറുമൊത്തുള്ള സിസ്റ്റങ്ങൾക്കിടയിൽ സന്ദേശമയയ്‌ക്കൽ, ഒരേ മേഖലയിലേക്ക് വളരെ വ്യത്യസ്തമായ സമീപനങ്ങൾ സ്വീകരിക്കാൻ അവരുടെ ഡവലപ്പർമാരെ പ്രേരിപ്പിച്ച ഉപയോഗ കേസുകളും വികസന പ്രോത്സാഹനങ്ങളും ഇത് രൂപപ്പെടുത്തും. ഞങ്ങൾ ഈ സാങ്കേതികവിദ്യകളെ അടിസ്ഥാനപരമായി നോക്കുകയും വഴിയിൽ വിവിധ ഡിസൈൻ ചോയ്‌സുകളുടെ സ്വാധീനം എടുത്തുകാണിക്കുകയും ചെയ്യും. രണ്ട് ഉൽപ്പന്നങ്ങളെക്കുറിച്ചും നിങ്ങൾക്ക് ആഴത്തിലുള്ള ധാരണ ലഭിക്കും, അവ എങ്ങനെ ഉപയോഗിക്കണം, ഉപയോഗിക്കരുത് എന്നതിനെക്കുറിച്ചുള്ള ധാരണ, ഭാവിയിൽ മറ്റ് സന്ദേശമയയ്‌ക്കൽ സാങ്കേതികവിദ്യകൾ പരിഗണിക്കുമ്പോൾ എന്താണ് ശ്രദ്ധിക്കേണ്ടതെന്ന് മനസ്സിലാക്കുക.

ആരംഭിക്കുന്നതിന് മുമ്പ്, നമുക്ക് അടിസ്ഥാനകാര്യങ്ങളിലേക്ക് പോകാം.

എന്താണ് ഒരു സന്ദേശമയയ്‌ക്കൽ സംവിധാനം, എന്തുകൊണ്ട് അത് ആവശ്യമാണ്?

രണ്ട് ആപ്ലിക്കേഷനുകൾ പരസ്പരം ആശയവിനിമയം നടത്തുന്നതിന്, അവ ആദ്യം ഒരു ഇന്റർഫേസ് നിർവചിക്കേണ്ടതുണ്ട്. ഈ ഇന്റർഫേസ് നിർവചിക്കുന്നതിൽ HTTP, MQTT അല്ലെങ്കിൽ SMTP പോലുള്ള ഒരു ട്രാൻസ്പോർട്ട് അല്ലെങ്കിൽ പ്രോട്ടോക്കോൾ തിരഞ്ഞെടുക്കുന്നതും സിസ്റ്റങ്ങൾക്കിടയിൽ കൈമാറ്റം ചെയ്യപ്പെടുന്ന സന്ദേശ ഫോർമാറ്റുകൾ ചർച്ച ചെയ്യുന്നതും ഉൾപ്പെടുന്നു. സന്ദേശ പേലോഡ് ചെലവ് ആവശ്യകതകളുള്ള ഒരു XML സ്കീമ നിർവചിക്കുന്നത് പോലെയുള്ള ഒരു കർശനമായ പ്രക്രിയയായിരിക്കാം ഇത്, അല്ലെങ്കിൽ HTTP അഭ്യർത്ഥനയുടെ ചില ഭാഗങ്ങളിൽ ക്ലയന്റ് ഐഡന്റിഫയർ അടങ്ങിയിരിക്കുമെന്ന രണ്ട് ഡെവലപ്പർമാർ തമ്മിലുള്ള കരാർ പോലെ ഇത് വളരെ കുറച്ച് ഔപചാരികമായിരിക്കാം.

സന്ദേശങ്ങളുടെ ഫോർമാറ്റും അവ അയയ്‌ക്കുന്ന ക്രമവും സിസ്റ്റങ്ങൾക്കിടയിൽ സ്ഥിരത പുലർത്തുന്നിടത്തോളം, മറ്റ് സിസ്റ്റത്തിന്റെ നിർവ്വഹണത്തെക്കുറിച്ച് ആകുലപ്പെടാതെ അവർക്ക് പരസ്പരം ആശയവിനിമയം നടത്താൻ കഴിയും. ഈ സിസ്റ്റങ്ങളുടെ ഇന്റേണലുകൾ, അതായത് പ്രോഗ്രാമിംഗ് ഭാഷ അല്ലെങ്കിൽ ഉപയോഗിച്ച ചട്ടക്കൂട്, കാലക്രമേണ മാറിയേക്കാം. കരാർ നിലനിൽക്കുന്നിടത്തോളം, മറുവശത്ത് നിന്ന് മാറ്റങ്ങളില്ലാതെ ഇടപെടൽ തുടരാം. ഈ ഇന്റർഫേസ് വഴി രണ്ട് സിസ്റ്റങ്ങളും ഫലപ്രദമായി വിഘടിപ്പിക്കപ്പെടുന്നു (വേർതിരിക്കപ്പെട്ടിരിക്കുന്നു).

സന്ദേശമയയ്‌ക്കൽ സംവിധാനങ്ങളിൽ സാധാരണയായി രണ്ട് സിസ്റ്റങ്ങൾക്കിടയിലുള്ള ഒരു ഇടനിലക്കാരൻ ഉൾപ്പെടുന്നു, അത് സ്വീകർത്താവിൽ നിന്നോ സ്വീകർത്താവിൽ നിന്നോ അയച്ചയാളെ കൂടുതൽ വേർപെടുത്താൻ (വേർതിരിക്കാൻ) ഇടപെടുന്നു. ഈ സാഹചര്യത്തിൽ, സ്വീകർത്താവ് എവിടെയാണ്, അവൻ സജീവമാണോ, എത്ര സംഭവങ്ങൾ ഉണ്ടെന്നോ അറിയാതെ അയയ്ക്കുന്നയാളെ സന്ദേശമയയ്‌ക്കൽ സംവിധാനം അനുവദിക്കുന്നു.

ഒരു സന്ദേശമയയ്‌ക്കൽ സംവിധാനം പരിഹരിക്കുന്ന തരത്തിലുള്ള പ്രശ്‌നങ്ങൾക്കായുള്ള രണ്ട് സമാനതകൾ നോക്കാം, കൂടാതെ ചില അടിസ്ഥാന നിബന്ധനകൾ അവതരിപ്പിക്കുകയും ചെയ്യാം.

പോയിന്റ്-ടു-പോയിന്റ്

ആദാമിന് ഒരു പാക്കേജ് അയയ്ക്കാൻ അലക്‌സാന്ദ്ര പോസ്റ്റ് ഓഫീസിലേക്ക് പോകുന്നു. അവൾ ജനാലയ്ക്കരികിലേക്ക് പോയി, പൊതി ജീവനക്കാരന് നൽകുന്നു. ജീവനക്കാരൻ പാക്കേജ് എടുത്ത് അലക്സാണ്ട്രയ്ക്ക് ഒരു രസീത് നൽകുന്നു. പാക്കേജ് അയയ്‌ക്കുമ്പോൾ ആദം വീട്ടിലിരിക്കേണ്ട ആവശ്യമില്ല. ഭാവിയിൽ ഏതെങ്കിലുമൊരു ഘട്ടത്തിൽ പാക്കേജ് ആദാമിന് കൈമാറുമെന്നും തന്റെ ബിസിനസ്സിൽ തുടരാമെന്നും അലക്‌സാന്ദ്രയ്ക്ക് ഉറപ്പുണ്ട്. പിന്നീട് ചില സമയങ്ങളിൽ ആദാമിന് ഒരു പാക്കേജ് ലഭിക്കുന്നു.

ഇത് ഒരു സന്ദേശമയയ്‌ക്കൽ മോഡലിന്റെ ഒരു ഉദാഹരണമാണ് പോയിന്റ്-ടു-പോയിന്റ്. ഇവിടെയുള്ള തപാൽ ഓഫീസ് ഒരു പാഴ്സൽ വിതരണ സംവിധാനമായി പ്രവർത്തിക്കുന്നു, ഓരോ പാഴ്സലും ഒരിക്കൽ ഡെലിവർ ചെയ്യപ്പെടുന്നുവെന്ന് ഉറപ്പാക്കുന്നു. ഒരു പോസ്റ്റ് ഓഫീസ് ഉപയോഗിക്കുന്നത് പാക്കേജ് ഡെലിവറിയിൽ നിന്ന് ഒരു പാക്കേജ് അയയ്ക്കുന്ന പ്രവർത്തനത്തെ വേർതിരിക്കുന്നു.
ക്ലാസിക് മെസേജിംഗ് സിസ്റ്റങ്ങളിൽ, പോയിന്റ്-ടു-പോയിന്റ് മോഡൽ നടപ്പിലാക്കുന്നത് വഴിയാണ് ക്യൂകൾ. ഒന്നോ അതിലധികമോ ഉപഭോക്താക്കൾക്ക് സബ്‌സ്‌ക്രൈബുചെയ്യാൻ കഴിയുന്ന ഒരു FIFO (ആദ്യത്തെ, ആദ്യം പുറത്തേക്ക്) ബഫറായി ക്യൂ പ്രവർത്തിക്കുന്നു. ഓരോ സന്ദേശവും മാത്രമാണ് ഡെലിവർ ചെയ്യുന്നത് വരിക്കാരായ ഉപഭോക്താക്കളിൽ ഒരാൾ. ക്യൂകൾ സാധാരണയായി ഉപഭോക്താക്കൾക്കിടയിൽ സന്ദേശങ്ങൾ വിതരണം ചെയ്യാൻ ശ്രമിക്കുന്നു. ഒരു ഉപഭോക്താവിന് മാത്രമേ ഈ സന്ദേശം ലഭിക്കൂ.

ക്യൂവിൽ "ഡ്യൂറബിൾ" എന്ന പദം പ്രയോഗിക്കുന്നു. വിശ്വാസ്യത ഒരു ഉപഭോക്താവ് സന്ദേശ വിതരണത്തിനായുള്ള ക്യൂവിൽ വരിക്കാരാകുന്നതുവരെ, സജീവ വരിക്കാരുടെ അഭാവത്തിൽ സന്ദേശമയയ്‌ക്കൽ സംവിധാനം സന്ദേശങ്ങൾ നിലനിൽക്കുമെന്ന് ഉറപ്പാക്കുന്ന ഒരു സേവന സ്വത്താണ്.

വിശ്വാസ്യത പലപ്പോഴും ആശയക്കുഴപ്പത്തിലാകുന്നു സ്ഥിരോത്സാഹം രണ്ട് പദങ്ങളും പരസ്പരം മാറിമാറി ഉപയോഗിക്കുന്നുണ്ടെങ്കിലും, അവ വ്യത്യസ്ത പ്രവർത്തനങ്ങൾ ചെയ്യുന്നു. മെസേജിംഗ് സിസ്റ്റം അത് സ്വീകരിക്കുന്നതിനും ഉപഭോക്താവിന് അയയ്ക്കുന്നതിനും ഇടയിൽ ഏതെങ്കിലും തരത്തിലുള്ള സ്റ്റോറേജിലേക്ക് ഒരു സന്ദേശം എഴുതുന്നുണ്ടോ എന്ന് സ്ഥിരത നിർണ്ണയിക്കുന്നു. ക്യൂവിലേക്ക് അയയ്‌ക്കുന്ന സന്ദേശങ്ങൾ സ്ഥിരമായേക്കാം അല്ലെങ്കിൽ സ്ഥിരമായിരിക്കില്ല.
ഉപയോഗ കേസിന് സന്ദേശത്തിൽ ഒറ്റത്തവണ പ്രവർത്തനം ആവശ്യമായി വരുമ്പോൾ പോയിന്റ്-ടു-പോയിന്റ് സന്ദേശമയയ്‌ക്കൽ ഉപയോഗിക്കുന്നു. ഒരു അക്കൗണ്ടിലേക്ക് പണം നിക്ഷേപിക്കുന്നതോ ഡെലിവറി ഓർഡർ പൂർത്തിയാക്കുന്നതോ ഉദാഹരണങ്ങളിൽ ഉൾപ്പെടുന്നു. എന്തുകൊണ്ടാണ് സന്ദേശമയയ്‌ക്കൽ സംവിധാനത്തിന് ഒറ്റത്തവണ ഡെലിവറി നൽകാൻ കഴിയാത്തതെന്നും ക്യൂകൾക്ക് ഡെലിവറി ഗ്യാരണ്ടി നൽകാൻ കഴിയുന്നത് എന്തുകൊണ്ടാണെന്നും ഞങ്ങൾ പിന്നീട് ചർച്ച ചെയ്യും ഒരിക്കലെങ്കിലും.

പ്രസാധകൻ-വരിക്കാരൻ

ഗബ്രിയേല കോൺഫറൻസ് നമ്പർ ഡയൽ ചെയ്യുന്നു. അവൾ കോൺഫറൻസുമായി ബന്ധപ്പെട്ടിരിക്കുമ്പോൾ, ബാക്കിയുള്ള കോൾ പങ്കാളികളോടൊപ്പം സ്പീക്കർ പറയുന്നതെല്ലാം അവൾ കേൾക്കുന്നു. അവൾ ട്യൂൺ ചെയ്യുമ്പോൾ, അവൾ പറഞ്ഞത് മിസ് ചെയ്യുന്നു. വീണ്ടും കണക്‌റ്റ് ചെയ്യുമ്പോൾ, അവൾ പറയുന്നത് കേൾക്കുന്നത് തുടരുന്നു.

ഇത് ഒരു സന്ദേശമയയ്‌ക്കൽ മോഡലിന്റെ ഒരു ഉദാഹരണമാണ് പ്രസിദ്ധീകരിക്കുക-സബ്സ്ക്രൈബ് ചെയ്യുക. കോൺഫറൻസ് കോളിംഗ് ഒരു ബ്രോഡ്കാസ്റ്റ് മെക്കാനിസമായി പ്രവർത്തിക്കുന്നു. നിലവിൽ എത്ര പേർ കോളിൽ ഉണ്ടെന്ന് സംസാരിക്കുന്ന വ്യക്തി ശ്രദ്ധിക്കുന്നില്ല - നിലവിൽ കണക്റ്റുചെയ്‌തിരിക്കുന്നവർ പറയുന്നത് കേൾക്കുമെന്ന് സിസ്റ്റം ഉറപ്പാക്കുന്നു.
ക്ലാസിക് സന്ദേശമയയ്‌ക്കൽ സംവിധാനങ്ങളിൽ, പബ്ലിഷ്-സബ്‌സ്‌ക്രൈബ് സന്ദേശമയയ്‌ക്കൽ മോഡൽ നടപ്പിലാക്കുന്നു ബലി. വിഷയം കോൺഫറൻസിംഗ് മെക്കാനിസത്തിന്റെ അതേ ബ്രോഡ്കാസ്റ്റിംഗ് രീതി നൽകുന്നു. ഒരു വിഷയത്തിലേക്ക് ഒരു സന്ദേശം അയയ്ക്കുമ്പോൾ, അത് വിതരണം ചെയ്യപ്പെടും എല്ലാ വരിക്കാരായ ഉപയോക്താക്കൾക്കും.

വിഷയങ്ങൾ സാധാരണമാണ് വിശ്വസനീയമല്ലാത്ത (സ്ഥിരതയില്ലാത്ത). ശ്രോതാവ് വിച്ഛേദിക്കുമ്പോൾ കോൺഫറൻസ് കോളിൽ പറയുന്നത് കേൾക്കാൻ കഴിയാത്ത ഒരു ശ്രോതാവിനെപ്പോലെ, വിഷയ സബ്‌സ്‌ക്രൈബർമാർക്ക് അവർ ഓഫ്‌ലൈനിലായിരിക്കുമ്പോൾ അയയ്‌ക്കുന്ന ഏതെങ്കിലും സന്ദേശങ്ങൾ നഷ്‌ടമാകും. ഇക്കാരണത്താൽ, വിഷയങ്ങൾ ഡെലിവറി ഗ്യാരണ്ടി നൽകുന്നുവെന്ന് നമുക്ക് പറയാം ഒന്നിൽ കൂടുതൽ അല്ല ഓരോ ഉപഭോക്താവിനും.

സന്ദേശങ്ങൾ വിവരദായക സ്വഭാവമുള്ളതും ഒരു സന്ദേശത്തിന്റെ നഷ്‌ടത്തിന് പ്രത്യേക പ്രാധാന്യം ഇല്ലാത്തതുമായ സന്ദർഭങ്ങളിൽ സാധാരണയായി പ്രസിദ്ധീകരിക്കുക-സബ്‌സ്‌ക്രൈബ് സന്ദേശമയയ്‌ക്കൽ ഉപയോഗിക്കുന്നു. ഉദാഹരണത്തിന്, ഒരു വിഷയത്തിന് സെക്കൻഡിൽ ഒരിക്കൽ ഒരു കൂട്ടം സെൻസറുകളിൽ നിന്ന് താപനില റീഡിംഗുകൾ കൈമാറാൻ കഴിയും. നിലവിലെ താപനിലയിൽ താൽപ്പര്യമുള്ളതും ഒരു വിഷയം സബ്‌സ്‌ക്രൈബ് ചെയ്യുന്നതുമായ ഒരു സിസ്റ്റം ഒരു സന്ദേശം നഷ്‌ടമായാൽ വിഷമിക്കേണ്ടതില്ല - മറ്റൊന്ന് സമീപഭാവിയിൽ എത്തും.

ഹൈബ്രിഡ് മോഡലുകൾ

സ്റ്റോറിന്റെ വെബ്‌സൈറ്റ് ഓർഡർ സന്ദേശങ്ങൾ "സന്ദേശ ക്യൂവിൽ" സ്ഥാപിക്കുന്നു. ഈ സന്ദേശങ്ങളുടെ പ്രധാന ഉപഭോക്താവ് എക്സിക്യൂട്ടീവ് സംവിധാനമാണ്. കൂടാതെ, പിന്നീടുള്ള ട്രാക്കിംഗിനായി ഓഡിറ്റ് സിസ്റ്റത്തിൽ ഈ ഓർഡർ സന്ദേശങ്ങളുടെ പകർപ്പുകൾ ഉണ്ടായിരിക്കണം. രണ്ട് സിസ്റ്റങ്ങൾക്കും സന്ദേശങ്ങൾ കടന്നുപോകാൻ അനുവദിക്കാനാവില്ല, സിസ്റ്റങ്ങൾ തന്നെ കുറച്ച് സമയത്തേക്ക് ലഭ്യമല്ലെങ്കിലും. വെബ്‌സൈറ്റിന് മറ്റ് സംവിധാനങ്ങളെക്കുറിച്ച് അറിയാൻ പാടില്ല.

ഒന്നിലധികം സിസ്റ്റങ്ങൾക്ക് ഒരു സന്ദേശത്തിന്റെ പകർപ്പ് ആവശ്യമായി വരുമ്പോൾ, സന്ദേശനഷ്ടം തടയുന്നതിന് വിശ്വാസ്യതയും സ്ഥിരതയും ആവശ്യമായി വരുമ്പോൾ, പബ്ലിഷ്-സബ്‌സ്‌ക്രൈബ്, പോയിന്റ്-ടു-പോയിന്റ് സന്ദേശമയയ്‌ക്കൽ മോഡലുകളുടെ സംയോജനമാണ് ഉപയോഗ കേസുകൾക്ക് പലപ്പോഴും ആവശ്യമായി വരുന്നത്.

ഈ കേസുകൾക്ക് ഒരു ലക്ഷ്യസ്ഥാനം (ക്യൂകൾക്കും വിഷയങ്ങൾക്കുമുള്ള പൊതുവായ പദം) ആവശ്യമാണ്, അത് സന്ദേശങ്ങൾ അടിസ്ഥാനപരമായി ഒരു വിഷയമായി വിതരണം ചെയ്യുന്നു, അതുവഴി ഓരോ സന്ദേശവും ആ സന്ദേശങ്ങളിൽ താൽപ്പര്യമുള്ള ഒരു പ്രത്യേക സിസ്റ്റത്തിലേക്ക് അയയ്‌ക്കും, മാത്രമല്ല ഓരോ സിസ്റ്റത്തിനും ഇൻകമിംഗ് സ്വീകരിക്കുന്ന നിരവധി ഉപഭോക്താക്കളെ നിർവചിക്കാൻ കഴിയും. സന്ദേശങ്ങൾ, അത് ഒരു ക്യൂ പോലെയാണ്. ഈ കേസിലെ വായന തരം ഓരോ ഓഹരി ഉടമയ്ക്കും ഒരിക്കൽ. ഈ ഹൈബ്രിഡ് ലക്ഷ്യസ്ഥാനങ്ങൾക്ക് പലപ്പോഴും ദീർഘവീക്ഷണം ആവശ്യമാണ്, അതിനാൽ ഒരു ഉപഭോക്താവ് ഓഫ്‌ലൈനിൽ പോകുകയാണെങ്കിൽ, ആ സമയത്ത് അയച്ച സന്ദേശങ്ങൾ ഉപഭോക്താവ് വീണ്ടും കണക്റ്റുചെയ്‌തതിന് ശേഷം ലഭിക്കും.

ഹൈബ്രിഡ് മോഡലുകൾ പുതിയതല്ല, ActiveMQ (വിഷയങ്ങളും ക്യൂകളും സംയോജിപ്പിക്കുന്ന വെർച്വൽ അല്ലെങ്കിൽ സംയോജിത ലക്ഷ്യസ്ഥാനങ്ങൾ വഴി), കാഫ്ക (അതിന്റെ ഡെസ്റ്റിനേഷൻ ഡിസൈനിന്റെ അടിസ്ഥാന സ്വത്ത് എന്ന നിലയിൽ) എന്നിവയുൾപ്പെടെ മിക്ക സന്ദേശമയയ്‌ക്കൽ സിസ്റ്റങ്ങളിലും ഉപയോഗിക്കാൻ കഴിയും.

ഇപ്പോൾ ഞങ്ങൾക്ക് ചില അടിസ്ഥാന പദാവലികളും ഒരു സന്ദേശമയയ്‌ക്കൽ സംവിധാനം എന്തിനുവേണ്ടി ഉപയോഗിക്കാം എന്നതിനെക്കുറിച്ചുള്ള ധാരണയും ഉള്ളതിനാൽ, നമുക്ക് വിശദാംശങ്ങളിലേക്ക് ഇറങ്ങാം.

വിവർത്തനം ചെയ്തു: tele.gg/middle_java

ഇനിപ്പറയുന്ന വിവർത്തനം ചെയ്ത ഭാഗം: അധ്യായം 3. കാഫ്ക

തുടരേണ്ടത് ...

അവലംബം: www.habr.com