റാബിറ്റ്എംക്യു. ഭാഗം 1. ആമുഖം. എർലാങ്, AMQP

ഗുഡ് ആഫ്റ്റർനൂൺ, ഹബർ! എനിക്ക് ശേഖരിക്കാൻ കഴിഞ്ഞ അറിവിന്റെ ഒരു പാഠപുസ്തക-റഫറൻസ് പുസ്തകം പങ്കിടാൻ ഞാൻ ആഗ്രഹിക്കുന്നു RabbitMQ കൂടാതെ ചെറിയ ശുപാർശകളിലും നിഗമനങ്ങളിലും സംഗ്രഹിക്കുക.

ഉള്ളടക്ക പട്ടിക

• റാബിറ്റ്എംക്യു. ഭാഗം 1. ആമുഖം. എർലാങ്, AMQP, RPC
• റാബിറ്റ്എംക്യു. ഭാഗം 2. എക്സ്ചേഞ്ചുകൾ മനസ്സിലാക്കുന്നു
• റാബിറ്റ്എംക്യു. ഭാഗം 3. ക്യൂകളും ബൈൻഡിംഗുകളും മനസ്സിലാക്കൽ
• റാബിറ്റ്എംക്യു. ഭാഗം 4. സന്ദേശങ്ങളും ഫ്രെയിമുകളും എന്താണെന്ന് മനസ്സിലാക്കൽ
• റാബിറ്റ്എംക്യു. ഭാഗം 5: സന്ദേശ പ്രകടനം പ്രസിദ്ധീകരിക്കലും ഉപഭോഗവും
• റാബിറ്റ്എംക്യു. ഭാഗം 6. ഫെഡറേഷന്റെയും ഷോവൽ മൊഡ്യൂളുകളുടെയും അവലോകനം
• റാബിറ്റ്എംക്യു. ഭാഗം 7. കണക്ഷനെയും ചാനലിനെയും കുറിച്ചുള്ള വിശദാംശങ്ങൾ
• റാബിറ്റ്എംക്യു. ഭാഗം 8. .NET-ൽ RabbitMQ
• റാബിറ്റ്എംക്യു. ഭാഗം 9. നിരീക്ഷണം

AMQP-യെ കുറിച്ച് ചുരുക്കത്തിൽ

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

പ്രോട്ടോകോൾ AMQP മൂന്ന് ആശയങ്ങൾ അവതരിപ്പിക്കുന്നു:

• exchange (എക്സ്ചേഞ്ച് പോയിന്റ് അല്ലെങ്കിൽ എക്സ്ചേഞ്ച്) - ഇതിലേക്ക് സന്ദേശങ്ങൾ അയയ്ക്കുന്നു. എക്സ്ചേഞ്ച് പോയിന്റ് സന്ദേശം വിതരണം ചെയ്യുന്നു ഒന്നോ അതിലധികമോ ക്യൂവിൽ. അവൾ സന്ദേശങ്ങൾ ഒരു ക്യൂവിലേക്ക് നയിക്കുന്നു സൃഷ്ടിച്ച ലിങ്കുകളെ അടിസ്ഥാനമാക്കി (binding) അവനും ക്യൂവിനുമിടയിൽ
• queue (ക്യൂ) - ഡിസ്കിലോ റാമിലോ ഉള്ള ഒരു ഡാറ്റാ ഘടന സന്ദേശങ്ങളിലേക്കുള്ള ലിങ്കുകൾ സംഭരിക്കുകയും സന്ദേശങ്ങളുടെ പകർപ്പുകൾ നൽകുകയും ചെയ്യുന്നു consumers (ഉപഭോക്താക്കൾക്ക്)
• binding (ബൈൻഡിംഗ്) - ഒരു നിയമം ഈ സന്ദേശങ്ങൾ ഏത് ക്യൂവിലേക്കാണ് പോകേണ്ടതെന്ന് എക്സ്ചേഞ്ച് പോയിന്റിനോട് പറയുന്നു

പ്രോട്ടോക്കോൾ മുകളിൽ പ്രവർത്തിക്കുന്നു TCP / IP.

എർലാങ്ങിനെക്കുറിച്ച് ചുരുക്കത്തിൽ

പ്രോജക്റ്റിന്റെ സോഴ്സ് കോഡ് ശേഖരത്തിൽ ഉണ്ട് സാമൂഹികം. വാസ്തുവിദ്യ RabbitMQ-സെർവർ ഇതിനെ അടിസ്ഥാനമാക്കി എർലാങ് ഒപ്പം ബീം.

Erlang കമ്പനി വികസിപ്പിച്ചെടുത്തത് Ericsson 1980-കളുടെ മധ്യത്തിൽ, 99,999% പ്രവർത്തനസമയം ആവശ്യമുള്ള ആപ്ലിക്കേഷനുകൾക്കായി വിതരണം ചെയ്ത, തെറ്റ്-സഹിഷ്ണുതയുള്ള, തത്സമയ സംവിധാനമായി. Erlang വിവിധ വ്യവസായങ്ങളിലും ആധുനിക ആപ്ലിക്കേഷനുകളിലും ഉപയോഗിക്കുന്നു, ഉദാ. WhatsApp. ലേഖനത്തിൽ നിങ്ങൾക്ക് കൂടുതൽ വായിക്കാം 19 ബില്യൺ ഡോളറിന് ഫേസ്ബുക്ക് വാങ്ങിയ വാട്ട്‌സ്ആപ്പ് ആർക്കിടെക്ചർ

RabbitMQ-നെ കുറിച്ച് ചുരുക്കത്തിൽ

RabbitMQ ഒരു ഓപ്പൺ സോഴ്സ് സന്ദേശ ബ്രോക്കറാണ്. പ്രോട്ടോക്കോളിന്റെ എല്ലാ അടിസ്ഥാന തത്ത്വങ്ങളിലും ഇത് സന്ദേശങ്ങളെ നയിക്കുന്നു എഎംക്യുപി ൽ വിവരിച്ചിരിക്കുന്നു സവിശേഷതകൾ. RabbitMQ പ്രോട്ടോക്കോൾ നടപ്പിലാക്കുകയും അനുബന്ധമാക്കുകയും ചെയ്യുന്നു AMQP.

സന്ദേശമയയ്‌ക്കൽ മോഡലിന്റെ പ്രധാന ആശയം RabbitMQ കാര്യം ആണ് producer (പ്രസാധകൻ) ക്യൂവിലേക്ക് നേരിട്ട് സന്ദേശങ്ങൾ അയക്കുന്നില്ല. വാസ്തവത്തിൽ, പലപ്പോഴും, പ്രസാധകന് സന്ദേശം ഏതെങ്കിലും ക്യൂവിൽ ഡെലിവർ ചെയ്യപ്പെടുമോ എന്ന് പോലും അറിയില്ല.

പകരം, പ്രസാധകന് എക്സ്ചേഞ്ചിലേക്ക് സന്ദേശങ്ങൾ അയയ്ക്കാൻ മാത്രമേ കഴിയൂ. ഒരു വശത്ത്, എക്സ്ചേഞ്ച് പ്രസാധകരിൽ നിന്ന് സന്ദേശങ്ങൾ സ്വീകരിക്കുന്നു, മറുവശത്ത്, അത് അവരെ ക്യൂകളിലേക്ക് അയയ്ക്കുന്നു. കൈമാറ്റം ചെയ്യുന്ന സന്ദേശത്തിൽ എന്താണ് ചെയ്യേണ്ടതെന്ന് കൃത്യമായി അറിഞ്ഞിരിക്കണം. ഇത് ഒരു പ്രത്യേക ക്യൂവിൽ ചേർക്കേണ്ടതുണ്ടോ? ഒന്നിലധികം ക്യൂകളിലേക്ക് ഇത് ചേർക്കേണ്ടതുണ്ടോ? അല്ലെങ്കിൽ സന്ദേശം അവഗണിക്കണം.

ഹ്രസ്വമായ ജോലി RabbitMQ ഇനിപ്പറയുന്ന രീതിയിൽ വിവരിക്കാം:

1. പ്രസാധകൻ ഒരു പ്രത്യേക എക്സ്ചേഞ്ചിലേക്ക് ഒരു സന്ദേശം അയയ്ക്കുന്നു
2. ഒരു എക്‌സ്‌ചേഞ്ച്, ഒരു സന്ദേശം ലഭിച്ചാൽ, അതിനും ക്യൂവിനും ഇടയിലുള്ള ബൈൻഡിംഗ് നിയമങ്ങൾക്കനുസൃതമായി അതിനെ ഒന്നോ അതിലധികമോ ക്യൂകളിലേക്ക് നയിക്കുന്നു.
3. ക്യൂ ഈ സന്ദേശത്തിലേക്കുള്ള ഒരു റഫറൻസ് സംഭരിക്കുന്നു. സന്ദേശം തന്നെ റാമിലോ ഡിസ്കിലോ സംഭരിച്ചിരിക്കുന്നു
4. ക്യൂവിൽ നിന്ന് ഒരു സന്ദേശം സ്വീകരിക്കാൻ ഉപഭോക്താവ് തയ്യാറായിക്കഴിഞ്ഞാൽ, സെർവർ ലിങ്ക് വഴി സന്ദേശത്തിന്റെ ഒരു പകർപ്പ് സൃഷ്ടിച്ച് അയയ്ക്കുന്നു.
5. ഉപഭോക്താവിന് സന്ദേശം ലഭിക്കുകയും ബ്രോക്കർക്ക് സ്ഥിരീകരണം അയയ്ക്കുകയും ചെയ്യുന്നു
6. സ്ഥിരീകരണം ലഭിക്കുമ്പോൾ, ബ്രോക്കർ, ക്യൂവിൽ നിന്ന് സന്ദേശത്തിന്റെ ഒരു പകർപ്പ് നീക്കം ചെയ്യുന്നു. തുടർന്ന് റാമിൽ നിന്നും ഡിസ്കിൽ നിന്നും ഇല്ലാതാക്കുന്നു

ആർ‌പി‌സി

പ്രക്രിയ RPC (വിദൂര നടപടിക്രമ കോൾ) ന്യൂക്ലിയസുമായുള്ള മിക്കവാറും എല്ലാ ഇടപെടലുകളും അടിവരയിടുന്നു RabbitMQ. ഉദാഹരണത്തിന്, ഉപഭോക്താവിന്റെ നിബന്ധനകളെക്കുറിച്ചുള്ള പ്രാഥമിക ചർച്ചകൾ RabbitMQ, ഒരു നിശ്ചിത പ്രക്രിയ പ്രകടമാക്കുന്നു RPC. ഈ ക്രമം പൂർത്തിയായിക്കഴിഞ്ഞാൽ, RabbitMQ ക്ലയന്റിൽ നിന്നുള്ള അഭ്യർത്ഥനകൾ സ്വീകരിക്കാൻ തയ്യാറാകും:

സ്പെസിഫിക്കേഷനിലും AMQP ക്ലയന്റിനും സെർവറിനും കമാൻഡുകൾ നൽകാൻ കഴിയും. സെർവറുമായി ആശയവിനിമയം നടത്താൻ ക്ലയന്റ് കാത്തിരിക്കുന്നു എന്നാണ് ഇതിനർത്ഥം. കമാൻഡുകൾ ക്ലാസുകളും രീതികളുമാണ്. ഉദാഹരണത്തിന്, Connection.Start - രീതി കോൾ Start ക്ലാസ് Connection.

കണക്ഷനും ചാനലുകളും

ക്ലയന്റും സെർവറും തമ്മിലുള്ള അത്തരം വിവര കൈമാറ്റത്തിന്, ചാനലുകൾ. ചാനലുകൾ ഉള്ളിൽ സൃഷ്ടിക്കപ്പെടുന്നു നിർദ്ദിഷ്ട കണക്ഷൻ. ഓരോ ചാനലും മറ്റ് ചാനലുകളിൽ നിന്ന് ഒറ്റപ്പെട്ടതാണ്. സിൻക്രണസ് കേസിൽ, ഒരു പ്രതികരണം ലഭിക്കുന്നതുവരെ അടുത്ത കമാൻഡ് എക്സിക്യൂട്ട് ചെയ്യാൻ സാധ്യമല്ല.

സമാന്തരമായി കമാൻഡുകൾ അയയ്ക്കാൻ, നിങ്ങൾ നിരവധി ചാനലുകൾ തുറക്കേണ്ടതുണ്ട്. ഓരോ ചാനലും പ്രത്യേകം സൃഷ്ടിക്കുന്നു Erlang പ്രക്രിയ. ഒരു കണക്ഷനിൽ ഒന്നിലധികം ചാനലുകൾ ഉണ്ടാകാം (മൾട്ടിപ്ലക്സിംഗ്). ഓരോ ചാനലിനും മെമ്മറിയിൽ ചില ഘടനകളും വസ്തുക്കളും ഉണ്ട്. അതിനാൽ, ഒരു കണക്ഷനിൽ കൂടുതൽ ചാനലുകൾ ഉണ്ട് RabbitMQ കൂടുതൽ മെമ്മറി ഉപയോഗിക്കുന്നു അത്തരമൊരു കണക്ഷൻ കൈകാര്യം ചെയ്യാൻ.

ഒരു കണക്ഷനും ചാനലും സൃഷ്ടിക്കുന്നതിനുള്ള ലളിതമായ ഉദാഹരണം RabbitMQ.Client:

// ...
private void TryConnect()
{
    var factory = new ConnectionFactory() 
    {
        HostName = "host_name",
        UserName = "user_name",
        Password = "p@ssword",
        // Включение автоматичекого восстановления
        // соединения после сбоев сети 
        AutomaticRecoveryEnabled = true
    };
    _connection = factory.CreateConnection();
}
// ...
public void CreateChanel()
{
    _channel = _connection.CreateModel();
    // other options 
}

ഓരോ പ്രവർത്തനത്തിനും ഒരു പുതിയ കണക്ഷൻ തുറക്കുന്നത് ശക്തമായി നിരുത്സാഹപ്പെടുത്തുന്നു ഉയർന്ന ചെലവിലേക്ക് നയിക്കും. ചാനലുകളും സ്ഥിരതയുള്ളതായിരിക്കണം, എന്നാൽ പല പ്രോട്ടോക്കോൾ പിശകുകളും ചാനൽ അടയ്ക്കുന്നതിന് കാരണമാകുന്നു, അതിനാൽ ചാനലിന്റെ ആയുസ്സ് കണക്ഷനേക്കാൾ കുറവായിരിക്കാം.

RabbitMQ എവിടെയാണ് ഉപയോഗിക്കുന്നത്?

മൈക്രോസർവീസുകളുടെ പശ്ചാത്തലത്തിൽ, പ്രോട്ടോക്കോൾ AMQP അതിന്റെ നടപ്പാക്കലും RabbitMQ പലപ്പോഴും ഉപയോഗിക്കുന്നു അസമന്വിത ഇടപെടൽ സേവനങ്ങൾക്കിടയിൽ.

സന്ദർഭത്തിൽ IIOT പ്രോട്ടോക്കോൾ AMQP അതിന്റെ നടപ്പാക്കലും RabbitMQ സെർവറുകൾ (സെർവർ-സെർവർ) തമ്മിലുള്ള ഡാറ്റ കൈമാറ്റത്തിനായി ഉപയോഗിക്കുന്നു. കൂടാതെ പ്ലഗിൻ ഉപയോഗിക്കുക MQTT പ്ലഗിൻ RabbitMQ ഇത് പ്രോട്ടോക്കോൾ നടപ്പാക്കലാണ് മ്ക്ത്ത് സെൻസറിനും സെർവറിനുമിടയിൽ കുറഞ്ഞ വേഗതയിലും ഉയർന്ന ലേറ്റൻസി പരിതസ്ഥിതികളിലും ഡാറ്റ കൈമാറുന്നതിന് (പിന്തുണയ്ക്കുന്ന പ്രോട്ടോക്കോളുകളുടെ ഒരു പൂർണ്ണ ലിസ്റ്റ് ഇവിടെ പട്ടികപ്പെടുത്തിയിരിക്കുന്നു പദ്ധതി വെബ്സൈറ്റ്).

അടുത്ത ലേഖനത്തിൽ നമ്മൾ എക്സ്ചേഞ്ചുകൾ കൂടുതൽ വിശദമായി മനസ്സിലാക്കാൻ തുടങ്ങും.

റെഫറൻസുകൾ

• RabbitMQ പ്രോജക്റ്റ് സൈറ്റ്

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