{"id":210,"date":"2020-04-15T22:18:08","date_gmt":"2020-04-15T22:18:08","guid":{"rendered":"https:\/\/www.kindsonthegenius.com\/microservices\/?p=210"},"modified":"2020-04-17T20:19:57","modified_gmt":"2020-04-17T20:19:57","slug":"rabbitmq-in-microservices-step-by-step-tutorial-with-springboot","status":"publish","type":"post","link":"https:\/\/www.kindsonthegenius.com\/microservices\/rabbitmq-in-microservices-step-by-step-tutorial-with-springboot\/","title":{"rendered":"RabbitMQ in Microservices – Step by Step Tutorial with SpringBoot"},"content":{"rendered":"

In this step by step tutorial, you will learn about RabbitMQ. We would build a Spring Boot project using IntelliJ. This tutorial covers the following<\/p>\n

    \n
  1. What is RabbitMQ?<\/a><\/li>\n
  2. How to Install and Configure RabbitMQ<\/a><\/li>\n
  3. View the RabbitMQ Console<\/a><\/li>\n
  4. Setup the Spring Application and Profiles<\/a><\/li>\n
  5. Send a Message to the Queue<\/a><\/li>\n
  6. Receive a Message from the Queue<\/a><\/li>\n
  7. Testing Send and Receive<\/a><\/li>\n
  8. Watch the Video<\/a><\/li>\n<\/ol>\n

     <\/p>\n

    1. What is RabbitMQ?<\/strong><\/h5>\n

    Well, RabbitMQ is a message broker. The next question is, ‘what is message broker?’. A message broker is simply a computer program that relays messages from the source(sender) to the destination(receiver).<\/p>\n

    The sender and receiver could be different microservices. Or perhaps, completed different applications.<\/p>\n

    Why we need a Message Broker<\/strong><\/p>\n

    According to the book ‘Practical Microservices Architectural Patterns’, messages helps to gracefully accommodate downtime or failures of coordinating applications. This means that if a microservice wants to send a message to another microservice but the destination microservice is down, then the message broker could store this message. So when the destination microservice is up, it could retrieve this message from the message broker.<\/p>\n

    We’ll demonstrate this in this tutorial.<\/p>\n

     <\/p>\n

    2. How to Install and Configure RabbitMQ<\/strong><\/h5>\n

    To install and configure RabbitMQ, follow the steps below:<\/p>\n

    Step 1:<\/strong> Download and install Erlang. RabbitMQ requires Erlang to be available in your machine. Download Erlang here<\/a><\/p>\n

    Step 2<\/strong>: Set ERLANG_HOME environment veriable to the location of your Erlang installation (you can see the video on how to do this). In my setup, the ERLANG_HOME is set to D:\\ProgramFiles\\erl10.7<\/span><\/p>\n

    Step 3<\/strong>: Download RabbitMQ from here.<\/a> Simply run the installer to install RabbitMQ.<\/p>\n

     <\/p>\n

    3. Start RabbitMQ and View the Dashboard<\/strong><\/h5>\n

    RabbitMQ provides a management dashboard as an HTTP-bases API for managing and monitoring the RabbitMQ server. This comes with a dashboard which you can access from the browser. Follow the steps below:<\/p>\n

    Step 1<\/strong>: Open command prompt and navigate to sbin folder inside the RabbitMQ install directory. For me, the directory is D:\\ProgramFiles\\RabbitMQ Server\\rabbitmq_server-3.8.3\\sbin<\/p>\n

    Step 2<\/strong>: Enable the management dashboard using the command:<\/p>\n

    rabbitmq-plugins enable rabbitmq_management\r\n<\/pre>\n
     <\/p>\n
    Step 3<\/strong>: Start RabbitMQ by running the command<\/p>\n
    rabbitmq-server.bat\r\n<\/pre>\n
    The above command starts up the management console in default port 15672<\/p>\n
    Step 4:<\/strong> Open your browser and visit<\/p>\n
    http:\/\/127.0.0.1:15672\r\n<\/pre>\n
    Login using the username: quest and password: guest;<\/p>\n
    The dashboard is shown below:<\/p>\n
    \"\"<\/a>
    RabbitMQ Login<\/figcaption><\/figure>\n
     <\/p>\n
    Once you login, you’ll see the dashboard as shown below:<\/p>\n
    \"RabbitMQ<\/a>
    RabbitMQ Dashboard Window<\/figcaption><\/figure>\n
     <\/p>\n
    4. Setup the Spring Application and Profiles<\/strong><\/h5>\n
    Build a new Spring Starter project (you can use Spring Tool Suite or IntellliJ IDE).<\/p>\n
    Add the following dependencies:<\/p>\n
    <dependency><\/span>\r\n\t<groupId><\/span>org.slf4j<\/groupId><\/span>\r\n\t<artifactId><\/span>slf4j-api<\/artifactId><\/span>\r\n\t<version><\/span>1.7.30<\/version><\/span>\r\n<\/dependency><\/span>\r\n\r\n<dependency><\/span>\r\n\t<groupId><\/span>org.springframework.boot<\/groupId><\/span>\r\n\t<artifactId><\/span>spring-boot-starter-amqp<\/artifactId><\/span>\r\n<\/dependency><\/span>\r\n<\/pre>\n
     <\/p>\n
    Next, in the base application class you need to declare a logger factory and the queue-name. The logger factory is used to log messages to the output. Use the two lines below:<\/p>\n
    private<\/span> final<\/span> static<\/span> String QUEUE_NAME =<\/span> \"hello\"<\/span>;<\/span>\r\n\r\nstatic<\/span> Logger logger \r\n\t\t=<\/span> LoggerFactory.<\/span>getLogger<\/span>(<\/span>DistributedMessagingApplication.<\/span>class<\/span>);<\/span>\r\n<\/pre>\n
     <\/p>\n
    Now, you need to creat etwo profiles: send and receive. The Send.java class would run on the ‘send’ profile while the Receive.java would run on the receive profile.<\/p>\n
    You need to create these profile using the Run Configuration. Just in case, you don’t know, profiles allow you to split an application into two parts which can run separately.<\/p>\n
    See how to create profile here.<\/a><\/p>\n
     <\/p>\n
    5. Send a Message to the Queue<\/strong><\/h5>\n
    Create a class named Send.java. This class contains the code to send a message to the queue. Also notice the @Profile annotation. This means that this class would run independently on the ‘send’ profile.<\/p>\n
    The content of the Send.java class is given below<\/p>\n
    @Profile<\/span>(<\/span>\"send\"<\/span>)<\/span>\r\npublic<\/span> class<\/span> Send<\/span> {<\/span>\r\n    static<\/span> Logger logger \r\n            =<\/span> LoggerFactory.<\/span>getLogger<\/span>(<\/span>Receive.<\/span>class<\/span>);<\/span>\r\n\r\n    private<\/span> final<\/span> static<\/span> String QUEUE_NAME =<\/span> \"hello\"<\/span>;<\/span>\r\n\r\n    public<\/span>  static<\/span> void<\/span> main<\/span>(<\/span>String[]<\/span> argv)<\/span>\r\n            throws<\/span> IOException,<\/span> TimeoutException {<\/span>\r\n        ConnectionFactory factory =<\/span> new<\/span> ConnectionFactory();<\/span>\r\n        factory.<\/span>setHost<\/span>(<\/span>\"localhost\"<\/span>);<\/span>\r\n        Connection connection =<\/span> factory.<\/span>newConnection<\/span>();<\/span>\r\n        Channel channel =<\/span> connection.<\/span>createChannel<\/span>();<\/span>\r\n        channel.<\/span>queueDeclare<\/span>(<\/span>QUEUE_NAME,<\/span>\r\n                false<\/span>,<\/span>\r\n                false<\/span>,<\/span>\r\n                false<\/span>,<\/span>\r\n                null<\/span>);<\/span>\r\n        String message =<\/span> \"Welcome to RabbitMQ\"<\/span>;<\/span>\r\n        channel.<\/span>basicPublish<\/span>(<\/span>\"\"<\/span>,<\/span>\r\n                QUEUE_NAME,<\/span>\r\n                null<\/span>,<\/span>\r\n                message.<\/span>getBytes<\/span>(<\/span>\"UTF-8\"<\/span>));<\/span>\r\n        logger.<\/span>debug<\/span>(<\/span>\"[!] Sent '\"<\/span> +<\/span> message +<\/span> \"'\"<\/span>);<\/span>\r\n        channel.<\/span>close<\/span>();<\/span>\r\n        connection.<\/span>close<\/span>();<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n<\/pre>\n
     <\/p>\n
    6. Receive a Message from the Queue<\/strong><\/h5>\n
    Create a class named Receive.java. This class would run on the ‘receive’ profile. You also need to create the receive profile as before.<\/p>\n
    The content of the file is given below:<\/p>\n
    @Profile<\/span>(<\/span>\"receive\"<\/span>)<\/span>\r\npublic<\/span> class<\/span> Receive<\/span> {<\/span>\r\n    static<\/span> Logger logger =<\/span> LoggerFactory.<\/span>getLogger<\/span>(<\/span>Receive.<\/span>class<\/span>);<\/span>\r\n\r\n    private<\/span> final<\/span> static<\/span> String QUEUE_NAME =<\/span> \"hello\"<\/span>;<\/span>\r\n\r\n    public<\/span>  static<\/span> void<\/span> main<\/span>(<\/span>String[]<\/span> argv)<\/span> \r\n            throws<\/span> IOException,<\/span> TimeoutException {<\/span>\r\n        ConnectionFactory factory =<\/span> new<\/span> ConnectionFactory();<\/span>\r\n        factory.<\/span>setHost<\/span>(<\/span>\"localhost\"<\/span>);<\/span>\r\n        Connection connection =<\/span> factory.<\/span>newConnection<\/span>();<\/span>\r\n        Channel channel =<\/span> connection.<\/span>createChannel<\/span>();<\/span>\r\n        channel.<\/span>queueDeclare<\/span>(<\/span>QUEUE_NAME,<\/span> \r\n                false<\/span>,<\/span> false<\/span>,<\/span>false<\/span>,<\/span> null<\/span>);<\/span>\r\n        logger.<\/span>info<\/span>(<\/span>\"[!] Waiting for messages. To exit press Ctrl+C\"<\/span>);<\/span>\r\n\r\n        Consumer consumer =<\/span> new<\/span> DefaultConsumer(<\/span>channel){<\/span>\r\n            @Override<\/span>\r\n            public<\/span> void<\/span> handleDelivery<\/span>(<\/span>String consumerTag,<\/span>\r\n                                       Envelope envelope,<\/span>\r\n                                       AMQP.<\/span>BasicProperties<\/span> properties,<\/span>\r\n                                       byte<\/span>[]<\/span> body)<\/span>\r\n                    throws<\/span> IOException {<\/span>\r\n                String message =<\/span> new<\/span> String(<\/span>body,<\/span> \"UTF-8\"<\/span>);<\/span>\r\n                logger.<\/span>info<\/span>(<\/span>\"[x] Message Recieved' \"<\/span> +<\/span> message +<\/span> \"'\"<\/span>);<\/span>\r\n            }<\/span>\r\n        };<\/span>\r\n        channel.<\/span>basicConsume<\/span>(<\/span>QUEUE_NAME,<\/span> true<\/span>,<\/span> consumer);<\/span>\r\n    }<\/span>\r\n}<\/span>\r\n<\/pre>\n
     <\/p>\n
    7. Testing Send and\u00a0<\/strong>Receive<\/h5>\n
    Now you can first run the application using the ‘send’ configuration. You’ll see in the console window a message that says: “Message sent…<\/p>\n
    Then go back to the RabbitMQ Dashboard.<\/p>\n
    Click on the Queues tabs<\/p>\n
    Expand on Messages and click on GetMessages.<\/p>\n
    You will see the message “Welcome to RabbitMQ”<\/p>\n
    Go back to IntelliJ and run the application using the ‘receive’ configuration.<\/p>\n
    One the application starts, you can see in the console window that the message is received.<\/p>\n
    Finally, go back and check the RabbitMQ Dashbaord for the messages. You’ll notice that they are no longer there.<\/p>\n
    So once a message is published, then it is retrieved and removed from the queue.<\/p>\n