રેબિટએમક્યુ. ભાગ 1. પરિચય. Erlang, AMQP

શુભ બપોર, હેબર! હું જ્ઞાનની પાઠ્યપુસ્તક-સંદર્ભ પુસ્તક શેર કરવા માંગુ છું જે મેં એકત્ર કરવામાં વ્યવસ્થાપિત કર્યું છે RabbitMQ અને ટૂંકી ભલામણો અને તારણો માં સંક્ષિપ્ત કરો.

સમાવિષ્ટોનું કોષ્ટક

• રેબિટએમક્યુ. ભાગ 1. પરિચય. Erlang, AMQP અને RPC
• રેબિટએમક્યુ. ભાગ 2. એક્સચેન્જને સમજવું
• રેબિટએમક્યુ. ભાગ 3. કતાર અને બંધનને સમજવું
• રેબિટએમક્યુ. ભાગ 4. સંદેશાઓ અને ફ્રેમ્સ શું છે તે સમજવું
• રેબિટએમક્યુ. ભાગ 5: સંદેશ પ્રકાશન અને વપરાશ કામગીરી
• રેબિટએમક્યુ. ભાગ 6. ફેડરેશન અને પાવડો મોડ્યુલોની સમીક્ષા
• રેબિટએમક્યુ. ભાગ 7. કનેક્શન અને ચેનલ વિશેની વિગતો
• રેબિટએમક્યુ. ભાગ 8. .NET માં RabbitMQ
• રેબિટએમક્યુ. ભાગ 9. મોનીટરીંગ

AMQP વિશે સંક્ષિપ્તમાં

AMQP (એડવાન્સ્ડ મેસેજ ક્યુઇંગ પ્રોટોકોલ) એ સિસ્ટમના ઘટકો વચ્ચે સંદેશા પ્રસારિત કરવા માટેનો એક ઓપન પ્રોટોકોલ છે. મૂળભૂત વિચાર એ છે કે વ્યક્તિગત સબસિસ્ટમ્સ (અથવા સ્વતંત્ર એપ્લિકેશન્સ) AMQP બ્રોકર દ્વારા મનસ્વી રીતે સંદેશાઓની આપ-લે કરી શકે છે, જે રાઉટીંગ કરે છે, સંભવતઃ ડિલિવરીની ખાતરી આપે છે, ડેટા સ્ટ્રીમ્સનું વિતરણ કરે છે અને ઇચ્છિત સંદેશાના પ્રકારોને સબ્સ્ક્રાઇબ કરે છે.

પ્રોટોકોલ AMQP ત્રણ ખ્યાલો રજૂ કરે છે:

• exchange (વિનિમય બિંદુ અથવા વિનિમય) - સંદેશાઓ તેને મોકલવામાં આવે છે. વિનિમય બિંદુ સંદેશનું વિતરણ કરે છે એક અથવા વધુ કતારોમાં. તેણીએ સંદેશાઓને કતારમાં રૂટ કરે છે બનાવેલ જોડાણો પર આધારિત (binding) તેની અને કતાર વચ્ચે
• queue (કતાર) - ડિસ્ક પર અથવા RAM માં ડેટા માળખું સંદેશાઓની લિંક્સ સંગ્રહિત કરે છે અને સંદેશાઓની નકલો આપે છે consumers (ગ્રાહકો માટે)
• binding (બંધનકર્તા) - એક નિયમ જે વિનિમય બિંદુને જણાવે છે કે આ સંદેશાઓ કઈ કતારમાં જવા જોઈએ

પ્રોટોકોલ ટોચ પર ચાલે છે ટીસીપી / આઈપી.

એર્લાંગ વિશે સંક્ષિપ્તમાં

પ્રોજેક્ટનો સ્ત્રોત કોડ રીપોઝીટરીમાં છે GitHub. આર્કિટેક્ચર રેબિટએમક્યુ-સર્વર પર આધારિત છે એર્લાંગ અને બીમ.

Erlang કંપની દ્વારા વિકસિત Ericsson 1980 ના દાયકાના મધ્યમાં 99,999% અપટાઇમની જરૂર હોય તેવી અરજીઓ માટે વિતરિત, ખામી-સહિષ્ણુ, રીઅલ-ટાઇમ સિસ્ટમ તરીકે. Erlang વિવિધ ઉદ્યોગો અને આધુનિક કાર્યક્રમોમાં વપરાય છે, દા.ત. WhatsApp. તમે લેખમાં વધુ વાંચી શકો છો WhatsApp આર્કિટેક્ચર, જેને Facebookએ $19 બિલિયનમાં ખરીદ્યું

RabbitMQ વિશે સંક્ષિપ્તમાં

રેબિટમ્યુક્યુ ઓપન સોર્સ મેસેજ બ્રોકર છે. તે પ્રોટોકોલના તમામ મૂળભૂત સિદ્ધાંતો સાથે સંદેશાઓને રૂટ કરે છે AMQP માં વર્ણવેલ સ્પષ્ટીકરણો. RabbitMQ પ્રોટોકોલને લાગુ કરે છે અને પૂરક બનાવે છે AMQP.

માં મેસેજિંગ મોડલનો મુખ્ય વિચાર RabbitMQ વસ્તુ છે producer (પ્રકાશક) સીધા કતારમાં સંદેશા મોકલતા નથી. હકીકતમાં, અને ઘણી વાર, પ્રકાશકને એ પણ ખબર હોતી નથી કે સંદેશ કોઈપણ કતારમાં વિતરિત કરવામાં આવશે કે નહીં.

તેના બદલે, પ્રકાશક એક્સચેન્જને માત્ર સંદેશા મોકલી શકે છે. એક તરફ, એક્સચેન્જ પ્રકાશકો તરફથી સંદેશા મેળવે છે, અને બીજી તરફ, તે તેમને કતારોમાં મોકલે છે. એક્સચેન્જને ખબર હોવી જોઈએ કે તેને જે મેસેજ મળે છે તેનું શું કરવું. શું તેને ચોક્કસ કતારમાં ઉમેરવું જોઈએ? શું તેને બહુવિધ કતારોમાં ઉમેરવું જોઈએ? અથવા સંદેશને અવગણવો જોઈએ.

સંક્ષિપ્ત કામ RabbitMQ નીચે પ્રમાણે વર્ણવી શકાય છે:

1. પ્રકાશક ચોક્કસ વિનિમયને સંદેશ મોકલે છે
2. એક વિનિમય, સંદેશ પ્રાપ્ત કર્યા પછી, તેને અને કતાર વચ્ચેના બંધનકર્તા નિયમો અનુસાર તેને એક અથવા વધુ કતારોમાં લઈ જાય છે.
3. કતાર આ સંદેશનો સંદર્ભ સંગ્રહિત કરે છે. સંદેશ પોતે RAM અથવા ડિસ્ક પર સંગ્રહિત થાય છે
4. એકવાર ગ્રાહક કતારમાંથી સંદેશ પ્રાપ્ત કરવા માટે તૈયાર થઈ જાય, સર્વર લિંક દ્વારા સંદેશની નકલ બનાવે છે અને મોકલે છે.
5. ગ્રાહક સંદેશ પ્રાપ્ત કરે છે અને બ્રોકરને પુષ્ટિ મોકલે છે
6. બ્રોકર, પુષ્ટિ પ્રાપ્ત કર્યા પછી, કતારમાંથી સંદેશની નકલ દૂર કરે છે. પછી RAM અને ડિસ્કમાંથી કાઢી નાખે છે

આર.પી.સી.

Процесс 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