606
3

RabbitMQ המדריך למשתמש – חלק 2

606
זמן קריאה: 3 דקות

צעד אחר צעד – Rabbit בשילוב עם Net.

בפוסט זה נראה דוגמא לשימוש ב-RabbitMQ בשילוב עם Net. ונממש אפליקציה פשוטה שתתחבר לתור ותשלח ותקבל הודעה,

זאת כמובן בהמשך לפוסט הקודם בו הסברתי מה זה RabbitMQ ותור הודעות

תוכן עניינים

איך מתקינים?

וודאו תחילה שמותקן לכם Docker על המחשב, במידה ולא התקינו לפי ההוראות בלינק

ניתן להתקין את RabbitMQ בתור שרת על המחשב ללא צורך ב-Docker ותוכלו להוריד זאת מכאן

בחרתי לעבוד ולהרים את Rabbit על Container בDocker וכדי להתקין אותו יש צורך להריץ את הפקודה הבאה:

				
					docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.9-management
				
			

לאחר שהכל מסיים יש לכם שרת RabbitMQ מותקן שרץ על Docker, תוכלו לוודא שהכל הצליח על ידי כניסה לאפליקציה

הגדרות ברירת מחדל:

במידה והצלחתם כך נראה חלון האפליקציית הניהול של RabbitMQ:

כעת ניצור שתי אפליקציות, האחת של השולח והשניה של מקבל ההודעה, ניתן לשים אותם בשני מחשבים שונים או בשני מיקרוסרביסים שונים ולתקשר עם המחשב בו יצרנו את התור.

במידה ואנו רוצים לעשות זאת ממחשב שלא מותקן עליו הRabbit נצטרך להחליף את “localhost” ב-IP של המחשב הרלוונטי.

הקוד נמצא ב GitHub או שתוכלו לראותו בהמשך הדף.

הפעלתי את הקוד בשלושה מחשבים שונים, כאשר ה1 הוא אחד השולחים לתור, כך גם מספר 2 ומספר 3 היא אפליקציה שמקבלת את ההודעות הנשלחות אל התור

השולח:

				
					using RabbitMQ.Client;
using System;
using System.Text;

namespace Sender
{
    class Program
    {
        public static void Main(string[] args)
        {
            var factory = new ConnectionFactory() { HostName = "localhost"}; // If your broker resides on a different machine, you can specify the name or the IP address.
            using (var connection = factory.CreateConnection()) // Creates the RabbitMQ connection
            using (var channel = connection.CreateModel()) // Creates a channel, which is where most of the API for getting things done resides.
            {
                //Declares the queue
                var queueName = "queue1";
                var durable = false; // true if we are declaring a durable queue(the queue will survive a server restart)
                var exclusive = false; // true if we are declaring an exclusive queue (restricted to this connection)
                var autoDelete = true; // true if we are declaring an auto delete queue (server will delete it when no longer in use)

                channel.QueueDeclare(queueName, durable, exclusive, autoDelete, null);


                Console.WriteLine("Please enter your message. Type 'exit' to exit.");
                while (true)
                {
                    //Converts message to byte array
                    var message = Console.ReadLine();
                    if (message?.ToUpper() == "QUIT")
                    {
                        break;
                    }

                    var data = Encoding.UTF8.GetBytes(message);

                    // publish to the "default exchange", with the queue name as the routing key
                    var exchangeName = "";
                    var routingKey = queueName;
                    channel.BasicPublish(exchangeName, routingKey, null, data);

                    Console.WriteLine("Sent: {0}", message);
                }
            }
        }
    }
}
				
			

המקבל:

				
					using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Text;

namespace Receiver
{
    class Program
    {
        public static void Main(string[] args)
        {
            var factory = new ConnectionFactory() { HostName = "localhost" }; // If your broker resides on a different machine, you can specify the name or the IP address.
            using (var connection = factory.CreateConnection()) // Creates the RabbitMQ connection
            using (var channel = connection.CreateModel()) // Creates a channel, which is where most of the API for getting things done resides.
            {
                //Declares the queue
                var queueName = "queue1";
                var durable = false; // true if we are declaring a durable queue(the queue will survive a server restart)
                var exclusive = false; // true if we are declaring an exclusive queue (restricted to this connection)
                var autoDelete = true; // true if we are declaring an auto delete queue (server will delete it when no longer in use)

                channel.QueueDeclare(queueName, durable, exclusive, autoDelete, null);


                var consumer = new EventingBasicConsumer(channel);
                // Callback
                consumer.Received += (model, deliveryEventArgs) =>
                {
                    var body = deliveryEventArgs.Body.ToArray();
                    // convert the message back from byte[] to a string
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine("** Received message: {0} by Consumer thread **", message);
                };

                // Start receiving messages
                channel.BasicConsume(queue: queueName, // the name of the queue
                                     autoAck: true, // true if the server should consider messages acknowledged once delivered;
                                     consumer: consumer); // an interface to the consumer object
                Console.WriteLine("Press [enter] to exit.");
                Console.ReadLine();
            }
        }
    }
}
				
			
אמיר שטיימן
WRITEN BY

אמיר שטיימן

Backend Engineer @Cynet
ביום יום מפתח Backend בסביבת SaaS, מיקרו סרביסים בשילוב של מערכות מבוזרות. בזמני הפנוי - לומד ומשתדרג בעולם התוכנה, אוהד מכבי חיפה, פלייסטיישן ובירה עם חברים :)
Linkedin | Twitter

3 thoughts on “RabbitMQ המדריך למשתמש – חלק 2

  1. כל הכבוד!! אחלה מדריך! יא מלך

  2. כתבה מעולה !
    מקפיץ את הקהילה הישראלית 🙂

    מה דעתך על שרת תורים במצב של קבלת הודעות מיידיות (פחות מ30 שניות )
    מה החלופה בארכיטקטורה

    • · 25 ביולי 2022 at 11:30

      היי גבריאל, קודם כל תודה 🙂
      לא הבנתי עד הסוף את השאלה אך בכל זאת אנסה לענות.
      RabbitMQ הוא בעצם שרת התורים והוא כבר מקבל את ההודעות באופן מיידי אך דואג לשים אותם בתור.
      אם אנו נשלח הודעות ישירות לסרביסים בלי מתווך בדרך – מה יקרה אם אחד הסרביסים שלך רדומים? בדיוק עשה ריסט? מה יקרה להודעה?

כתיבת תגובה

האימייל לא יוצג באתר. שדות החובה מסומנים *