{"id":54288,"date":"2025-12-01T06:15:40","date_gmt":"2025-12-01T06:15:40","guid":{"rendered":"https:\/\/www.devopsschool.com\/blog\/?p=54288"},"modified":"2025-12-01T06:15:40","modified_gmt":"2025-12-01T06:15:40","slug":"dotnet-rabbitmq-with-net-demo-and-lab-example","status":"publish","type":"post","link":"https:\/\/www.devopsschool.com\/blog\/dotnet-rabbitmq-with-net-demo-and-lab-example\/","title":{"rendered":"DOTNET: RabbitMQ with .net Demo and Lab Example"},"content":{"rendered":"\n

We\u2019ll run RabbitMQ in Docker on an AWS EC2 instance<\/strong>, and use your Windows laptop<\/strong> for both the producer<\/strong> and consumer<\/strong>.<\/p>\n\n\n\n

I\u2019ll walk you through:<\/p>\n\n\n\n

    \n
  1. Create & configure EC2<\/li>\n\n\n\n
  2. Install Docker & run RabbitMQ container<\/li>\n\n\n\n
  3. Securely expose RabbitMQ over IP<\/li>\n\n\n\n
  4. Write .NET Producer (Windows)<\/li>\n\n\n\n
  5. Write .NET Consumer (Windows)<\/li>\n\n\n\n
  6. Test end-to-end<\/li>\n<\/ol>\n\n\n\n
    \n\n\n\n

    1. Provision AWS EC2 for RabbitMQ<\/h2>\n\n\n\n

    1.1 Launch EC2 instance<\/h3>\n\n\n\n

    In AWS Console:<\/p>\n\n\n\n

      \n
    1. Go to EC2 \u2192 Instances \u2192 Launch instance<\/strong>.<\/li>\n\n\n\n
    2. Name: rabbitmq-ec2<\/code>.<\/li>\n\n\n\n
    3. AMI:\n
        \n
      • Ubuntu Server 22.04 LTS<\/strong> (or Amazon Linux if you prefer).<\/li>\n<\/ul>\n<\/li>\n\n\n\n
      • Instance type: t3.small<\/code> or t3.micro<\/code> is OK for demo.<\/li>\n\n\n\n
      • Key Pair: select or create one (for SSH).<\/li>\n\n\n\n
      • Network:\n
          \n
        • VPC: default (or your custom VPC).<\/li>\n\n\n\n
        • Subnet: any public subnet.<\/li>\n\n\n\n
        • Auto-assign Public IP: Enable<\/strong> \u2705 (important).<\/li>\n<\/ul>\n<\/li>\n<\/ol>\n\n\n\n

          1.2 Security group ports<\/h3>\n\n\n\n

          Create or configure a security group, e.g., rabbitmq-sg<\/code>, with:<\/p>\n\n\n\n

            \n
          • SSH<\/strong>: TCP 22, Source = your IP only (e.g., x.x.x.x\/32<\/code>).<\/li>\n\n\n\n
          • RabbitMQ AMQP<\/strong>: TCP 5672<\/strong>, Source = your IP (for .NET code) or office IP range.<\/li>\n\n\n\n
          • RabbitMQ Management UI<\/strong>: TCP 15672<\/strong>, Source = your IP (for browser access).<\/li>\n<\/ul>\n\n\n\n
            \n

            Don\u2019t leave 0.0.0.0\/0 open in production. For demo it\u2019s \u201cokay-ish\u201d, but better to restrict.<\/p>\n<\/blockquote>\n\n\n\n

            Launch the instance.<\/p>\n\n\n\n

            \n\n\n\n

            2. Install Docker & run RabbitMQ on EC2<\/h2>\n\n\n\n

            2.1 SSH into the EC2 instance<\/h3>\n\n\n\n

            From your Windows laptop:<\/p>\n\n\n

            ssh<\/span> -i<\/span> \"your-key<\/span>.pem<\/span>\" ubuntu<\/span>@EC2_PUBLIC_IP<\/span>\n<\/code><\/span>Code language:<\/span> CSS<\/span> (<\/span>css<\/span>)<\/span><\/small><\/pre>\n\n\n
            (Replace your-key.pem<\/code> path and EC2_PUBLIC_IP<\/code> with the instance\u2019s public IP.)<\/p>\n\n\n\n
            2.2 Install Docker (Ubuntu example)<\/h3>\n\n\n
            # Update packages<\/span>\nsudo apt-get update\n\n# Install Docker<\/span>\nsudo apt-get install -y docker.io\n\n# Enable & start Docker<\/span>\nsudo systemctl enable docker\nsudo systemctl start docker\n\n# Verify<\/span>\ndocker --version\n<\/code><\/span>Code language:<\/span> PHP<\/span> (<\/span>php<\/span>)<\/span><\/small><\/pre>\n\n\n
            2.3 Run RabbitMQ Docker container (with remote access)<\/h3>\n\n\n\n
            Important: the default guest<\/code> user cannot<\/strong> log in remotely (only from localhost), so we\u2019ll create a new user.<\/p>\n\n\n\n
            Run RabbitMQ with management:<\/p>\n\n\n
            sudo<\/span> docker<\/span> run<\/span> -d<\/span> \\\n  --hostname<\/span> my-rabbit<\/span> \\\n  --name<\/span> rabbitmq-demo<\/span> \\\n  -p<\/span> 5672:5672<\/span> \\\n  -p<\/span> 15672:15672<\/span> \\\n  rabbitmq<\/span>:3-management<\/span>\n<\/code><\/span>Code language:<\/span> CSS<\/span> (<\/span>css<\/span>)<\/span><\/small><\/pre>\n\n\n
            Wait a few seconds, then:<\/p>\n\n\n
            sudo docker ps\n<\/code><\/span><\/pre>\n\n\n
            You should see rabbitmq:3-management<\/code> running.<\/p>\n\n\n\n
            2.4 Create a dedicated user for remote access<\/h3>\n\n\n\n
            Connect into the container:<\/p>\n\n\n
            sudo docker exec -it rabbitmq-demo bash\n<\/code><\/span><\/pre>\n\n\n
            Inside the container:<\/p>\n\n\n
            # Add a user - choose your own username & password<\/span>\nrabbitmqctl add_user myuser mypassword\n\n# Give full permissions on the default vhost \"\/\"<\/span>\nrabbitmqctl set_permissions -p \/ myuser \".*\"<\/span> \".*\"<\/span> \".*\"<\/span>\n\n# (Optional) Give administrator tag for UI access<\/span>\nrabbitmqctl set_user_tags myuser administrator\n\nexit<\/span>\n<\/code><\/span>Code language:<\/span> PHP<\/span> (<\/span>php<\/span>)<\/span><\/small><\/pre>\n\n\n
            Now you\u2019ll use myuser \/ mypassword<\/code> from Windows.<\/p>\n\n\n\n
            \n\n\n\n
            3. Verify RabbitMQ Management UI from your laptop<\/h2>\n\n\n\n
            On your Windows laptop<\/strong>, open browser:<\/p>\n\n\n
            http:\/\/EC2_PUBLIC_IP:15672<\/span>\n<\/code><\/span>Code language:<\/span> JavaScript<\/span> (<\/span>javascript<\/span>)<\/span><\/small><\/pre>\n\n\n
            Log in with:<\/p>\n\n\n\n
              \n
            • Username: myuser<\/code><\/li>\n\n\n\n
            • Password: mypassword<\/code><\/li>\n<\/ul>\n\n\n\n
              You should see the RabbitMQ dashboard \ud83c\udf89<\/p>\n\n\n\n
              \n\n\n\n
              4. Prepare .NET projects on Windows laptop<\/h2>\n\n\n\n
              We\u2019ll create two console apps<\/strong> on your laptop:<\/p>\n\n\n\n
                \n
              • RabbitMqProducer<\/code> \u2013 sends messages to EC2 RabbitMQ<\/li>\n\n\n\n
              • RabbitMqConsumer<\/code> \u2013 receives & processes them<\/li>\n<\/ul>\n\n\n\n
                4.1 Create solution & projects<\/h3>\n\n\n\n
                In PowerShell \/ CMD:<\/p>\n\n\n
                mkdir RabbitMqEc2Demo\ncd RabbitMqEc2Demo\n\ndotnet new<\/span> sln -n RabbitMqEc2Demo\n\ndotnet new<\/span> console<\/span> -n RabbitMqProducer\ndotnet new<\/span> console<\/span> -n RabbitMqConsumer\n\ndotnet sln add RabbitMqProducer\/RabbitMqProducer.csproj\ndotnet sln add RabbitMqConsumer\/RabbitMqConsumer.csproj\n<\/code><\/span>Code language:<\/span> JavaScript<\/span> (<\/span>javascript<\/span>)<\/span><\/small><\/pre>\n\n\n
                4.2 Install RabbitMQ client in both apps<\/h3>\n\n\n
                cd<\/span> RabbitMqProducer<\/span>\ndotnet<\/span> add<\/span> package<\/span> RabbitMQ<\/span>.Client<\/span>\ncd<\/span> ..\n\ncd<\/span> RabbitMqConsumer<\/span>\ndotnet<\/span> add<\/span> package<\/span> RabbitMQ<\/span>.Client<\/span>\ncd<\/span> ..\n<\/code><\/span>Code language:<\/span> CSS<\/span> (<\/span>css<\/span>)<\/span><\/small><\/pre>\n\n\n
                \n\n\n\n
                5. Producer code (from Windows \u2192 EC2 RabbitMQ)<\/h2>\n\n\n\n
                Edit RabbitMqProducer\/Program.cs<\/code> and replace with:<\/p>\n\n\n
                using System.Text;\nusing RabbitMQ.Client;\n\nConsole.WriteLine(\"RabbitMQ Producer starting...\"<\/span>);\n\n\/\/ Replace with your EC2 public IP or DNS<\/span>\nvar<\/span> rabbitMqHost = \"EC2_PUBLIC_IP_OR_DNS\"<\/span>;  \/\/ e.g. \"3.110.45.123\"<\/span>\nvar<\/span> queueName = \"demo_queue\"<\/span>;\n\nvar<\/span> factory = new<\/span> ConnectionFactory\n{\n    HostName = rabbitMqHost,\n    Port = 5672<\/span>,\n    UserName = \"myuser\"<\/span>,      \/\/ user created on EC2 RabbitMQ<\/span>\n    Password = \"mypassword\"<\/span>,  \/\/ password you set<\/span>\n    VirtualHost = \"\/\"<\/span>         \/\/ default vhost<\/span>\n};\n\nusing var<\/span> connection = factory.CreateConnection();\nusing var<\/span> channel = connection.CreateModel();\n\n\/\/ Declare queue - safe to call many times<\/span>\nchannel.QueueDeclare(\n    queue: queueName,\n    durable<\/span>: true<\/span>,\n    exclusive<\/span>: false<\/span>,\n    autoDelete<\/span>: false<\/span>,\n    arguments<\/span>: null<\/span>);\n\nConsole.WriteLine($\"Connected to RabbitMQ at {rabbitMqHost}. Queue: {queueName}\"<\/span>);\n\nfor<\/span> (int i = 1<\/span>; i <= 10<\/span>; i++)\n{\n    var<\/span> message = $\"Hello from Windows Producer! Message #{i}\"<\/span>;\n    var<\/span> body = Encoding.UTF8.GetBytes(message);\n\n    var<\/span> properties = channel.CreateBasicProperties();\n    properties.Persistent = true<\/span>; \/\/ store on disk<\/span>\n\n    channel.BasicPublish(\n        exchange: \"\"<\/span>,\n        routingKey<\/span>: queueName,\n        basicProperties<\/span>: properties,\n        body<\/span>: body);\n\n    Console.WriteLine($\"[x] Sent: {message}\"<\/span>);\n}\n\nConsole.WriteLine(\"All messages sent. Press any key to exit.\"<\/span>);\nConsole.ReadKey();\n<\/code><\/span>Code language:<\/span> JavaScript<\/span> (<\/span>javascript<\/span>)<\/span><\/small><\/pre>\n\n\n
                \n\n\n\n
                6. Consumer code (from Windows \u2192 EC2 RabbitMQ)<\/h2>\n\n\n\n
                Edit RabbitMqConsumer\/Program.cs<\/code> and replace with:<\/p>\n\n\n
                using System.Text;\nusing RabbitMQ.Client;\nusing RabbitMQ.Client.Events;\n\nConsole.WriteLine(\"RabbitMQ Consumer starting...\"<\/span>);\n\n\/\/ Same EC2 host & credentials<\/span>\nvar<\/span> rabbitMqHost = \"EC2_PUBLIC_IP_OR_DNS\"<\/span>;  \/\/ e.g. \"3.110.45.123\"<\/span>\nvar<\/span> queueName = \"demo_queue\"<\/span>;\n\nvar<\/span> factory = new<\/span> ConnectionFactory\n{\n    HostName = rabbitMqHost,\n    Port = 5672<\/span>,\n    UserName = \"myuser\"<\/span>,\n    Password = \"mypassword\"<\/span>,\n    VirtualHost = \"\/\"<\/span>,\n    DispatchConsumersAsync = true<\/span>\n};\n\nusing var<\/span> connection = factory.CreateConnection();\nusing var<\/span> channel = connection.CreateModel();\n\nchannel.QueueDeclare(\n    queue: queueName,\n    durable<\/span>: true<\/span>,\n    exclusive<\/span>: false<\/span>,\n    autoDelete<\/span>: false<\/span>,\n    arguments<\/span>: null<\/span>);\n\n\/\/ Optional QoS to process one message at a time<\/span>\nchannel.BasicQos(prefetchSize: 0<\/span>, prefetchCount<\/span>: 1<\/span>, global<\/span>: false<\/span>);\n\nConsole.WriteLine($\"Connected to RabbitMQ at {rabbitMqHost}. Waiting for messages on queue: {queueName}\"<\/span>);\n\nvar<\/span> consumer = new<\/span> AsyncEventingBasicConsumer(channel);\n\nconsumer.Received += async<\/span> (model, ea) =>\n{\n    var<\/span> body = ea.Body.ToArray();\n    var<\/span> message = Encoding.UTF8.GetString(body);\n\n    Console.WriteLine($\"[x] Received: {message}\"<\/span>);\n\n    \/\/ Simulate some processing work<\/span>\n    await<\/span> Task.Delay(500<\/span>);\n\n    \/\/ Acknowledge the message<\/span>\n    channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple<\/span>: false<\/span>);\n};\n\nchannel.BasicConsume(\n    queue: queueName,\n    autoAck<\/span>: false<\/span>,\n    consumer<\/span>: consumer);\n\nConsole.WriteLine(\"Press [enter] to exit.\"<\/span>);\nConsole.ReadLine();\n<\/code><\/span>Code language:<\/span> JavaScript<\/span> (<\/span>javascript<\/span>)<\/span><\/small><\/pre>\n\n\n
                \n\n\n\n
                7. Run the full flow<\/h2>\n\n\n\n
                7.1 Start the consumer (Windows)<\/h3>\n\n\n\n
                Open terminal on your laptop:<\/p>\n\n\n
                cd RabbitMqEc2Demo\/RabbitMqConsumer\ndotnet run\n<\/code><\/span><\/pre>\n\n\n
                You should see:<\/p>\n\n\n
                RabbitMQ<\/span> Consumer<\/span> starting<\/span>...\nConnected<\/span> to<\/span> RabbitMQ<\/span> at<\/span> EC2_PUBLIC_IP_OR_DNS<\/span>. Waiting<\/span> for<\/span> messages<\/span> on<\/span> queue<\/span>: demo_queue<\/span>\nPress<\/span> [enter]<\/span> to<\/span> exit<\/span>.\n<\/code><\/span>Code language:<\/span> CSS<\/span> (<\/span>css<\/span>)<\/span><\/small><\/pre>\n\n\n
                (Queue might be empty initially.)<\/p>\n\n\n\n
                7.2 Run the producer (Windows)<\/h3>\n\n\n\n
                Open another terminal:<\/p>\n\n\n
                cd RabbitMqEc2Demo\/RabbitMqProducer\ndotnet run\n<\/code><\/span><\/pre>\n\n\n
                You should see:<\/p>\n\n\n
                RabbitMQ<\/span> Producer<\/span> starting<\/span>...\nConnected<\/span> to<\/span> RabbitMQ<\/span> at<\/span> EC2_PUBLIC_IP_OR_DNS<\/span>. Queue<\/span>: demo_queue<\/span>\n[x]<\/span> Sent<\/span>: Hello<\/span> from<\/span> Windows<\/span> Producer<\/span>! Message<\/span> #1<\/span>\n...\n[x]<\/span> Sent<\/span>: Hello<\/span> from<\/span> Windows<\/span> Producer<\/span>! Message<\/span> #10<\/span>\nAll<\/span> messages<\/span> sent<\/span>. Press<\/span> any<\/span> key<\/span> to<\/span> exit<\/span>.\n<\/code><\/span>Code language:<\/span> CSS<\/span> (<\/span>css<\/span>)<\/span><\/small><\/pre>\n\n\n
                Now check the consumer<\/strong> terminal; you should see each message being received & processed:<\/p>\n\n\n
                [x]<\/span> Received<\/span>: Hello<\/span> from<\/span> Windows<\/span> Producer<\/span>! Message<\/span> #1<\/span>\n[x]<\/span> Received<\/span>: Hello<\/span> from<\/span> Windows<\/span> Producer<\/span>! Message<\/span> #2<\/span>\n...\n<\/code><\/span>Code language:<\/span> CSS<\/span> (<\/span>css<\/span>)<\/span><\/small><\/pre>\n\n\n
                7.3 Inspect via RabbitMQ Management UI<\/h3>\n\n\n\n
                In browser:<\/p>\n\n\n
                http:\/\/EC2_PUBLIC_IP:15672<\/span>\n<\/code><\/span>Code language:<\/span> JavaScript<\/span> (<\/span>javascript<\/span>)<\/span><\/small><\/pre>\n\n\n
                Log in with myuser \/ mypassword<\/code>.<\/p>\n\n\n\n
                  \n
                • Go to Queues<\/strong> \u2192 click demo_queue<\/code><\/li>\n\n\n\n
                • You can see:\n
                    \n
                  • Ready \/ unacked messages counts<\/li>\n\n\n\n
                  • Consumers count<\/li>\n\n\n\n
                  • Message rates<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n\n\n\n
                    Try experiments:<\/p>\n\n\n\n
                      \n
                    • Stop consumer, run producer \u2192 messages accumulate in queue.<\/li>\n\n\n\n
                    • Start consumer again \u2192 it drains messages from queue.<\/li>\n<\/ul>\n\n\n\n
                      \n\n\n\n
                      8. Hardening \/ Production Thoughts (for your training)<\/h2>\n\n\n\n
                      You can mention this in your tutorial:<\/p>\n\n\n\n
                        \n
                      • Use non-default credentials<\/strong>, strong passwords.<\/li>\n\n\n\n
                      • Restrict Security Group to your office VPN \/ corporate IPs.<\/li>\n\n\n\n
                      • Consider TLS<\/strong> for RabbitMQ traffic (amqps).<\/li>\n\n\n\n
                      • Use separate vhosts<\/strong> for environments (dev \/ stage \/ prod).<\/li>\n\n\n\n
                      • Use Docker volumes<\/strong> or EBS volumes for persistent data.<\/li>\n<\/ul>\n","protected":false},"excerpt":{"rendered":"
                        We\u2019ll run RabbitMQ in Docker on an AWS EC2 instance, and use your Windows laptop for both the producer and consumer. I\u2019ll walk you through: 1. Provision AWS EC2 for… <\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"_joinchat":[],"footnotes":""},"categories":[11138],"tags":[],"class_list":["post-54288","post","type-post","status-publish","format-standard","hentry","category-best-tools"],"_links":{"self":[{"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/posts\/54288","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/comments?post=54288"}],"version-history":[{"count":1,"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/posts\/54288\/revisions"}],"predecessor-version":[{"id":54289,"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/posts\/54288\/revisions\/54289"}],"wp:attachment":[{"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/media?parent=54288"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/categories?post=54288"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.devopsschool.com\/blog\/wp-json\/wp\/v2\/tags?post=54288"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}