JMS / RabbitMQ

RabbitMQ - Messaging Broker 







 




RabbitMQ Setup:


Steps to download and install RabbitMQ for Windows: https://www.rabbitmq.com/install-windows-manual.html 

Download the MQ zip file and supported Erlang exe from the above link. 

1. Install Erlang, set ERLANG_HOME and path in Environment variable. 

ERLANG_HOME: C:\Program Files\erl-24.0.4 
PATH: C:\Program Files\erl-24.0.4\bin

 2. Enable Rabbitmq management: 


C:\Program Files\rabbitmq_server-3.9.1\sbin>rabbitmq-plugins.bat enable rabbitmq_management

3. Execute the batch file to start rabbitMQ 

C:\Program Files\rabbitmq_server-3.9.1\sbin\rabbitmq-server

4. Launch the URL in the browser http://localhost:15672/  (guest/guest)



Types Of Exchanges:

  • Direct
  • Fanout
  • Topic
  • Headers

Direct:

The message will be redirected by Exchange to the specific queue based on the Key.

Do the below steps in RabbitMQ management:

1. Create Exchange (Type=direct)
2. Create Queues
3. Bind the queues with Exchange with routing key



Fanout:

The message will be redirected by Exchange to all the queues bind with it. 


Do the below steps in RabbitMQ management:

1. Create Exchange (Type=fanout)
2. Bind the queues with Exchange with routing key


Topic:


* One word
# Any number of word


1. Create Exchange (Type=topic)
2. Bind the queues with Exchange with routing key



Headers:



x-match=all   : it's like AND condition
x-match=any : it's like OR condition


1. Create Exchange (Type=headers)
2. Bind the queues with Exchange with arguments (refer to the below screenshot)



Default exchange:


Any message sending directly to queue, will be routed through Default Exchange which will be created by RabbitMQ by default. 

    channel.basicPublish("", "Queue-1", null, message.getBytes());

Pass the exchange name as empty. 


Exchange to Exchange Binding:






RabbitMQ with SpringBoot

RabbitMQ Template - for publishing message
RabbitMQ Listener  - for consumer


All the Example codes are available here https://github.com/vthangar0202/RabbitMQ




Comments

Post a Comment

Popular posts from this blog

Java Design Patterns

Image
D esign patterns are programming language independent strategies for solving the common object-oriented design problems. That means a design pattern represents an idea, not a particular implementation. By using the design patterns you can make your code more flexible, reusable, and maintainable. It is the most important part because java internally follows design patterns. Categorization of design patterns: Basically, design patterns are categorized into two parts: Core Java (or JSE) Design Patterns. JEE Design Patterns. Core Java Design Patterns In core java, there are mainly three types of design patterns, which are further divided into their sub-parts: 1.Creational Design Pattern Factory Pattern Abstract Factory Pattern Singleton Pattern Prototype Pattern Builder Pattern. 2. Structural Design Pattern Adapter Pattern Bridge Pattern Composite Pattern Decorator Pattern Facade Pattern Flyweight Pattern Proxy Pattern 3. Behavioral Design Pattern Chain Of Responsibility Pattern Command Pa...
Read more

Java 8 Concepts with Examples

Java 8 new features  1. Lambda Expressions A lambda expression is an anonymous function. A function that doesn’t have a name and doesn’t belong to any class.   so compiler does not create .class file. Used to provide the implementation of an interface which has functional interface      //Syntax of lambda expression ( parameter_list ) -> { function_body }      Example: Creating Thread with Lambda  package com.vasanth.java8; public class ThreadWithLambda { public static void main (String args[]){ //Traditional approach Runnable r1= new Runnable() { @Override public void run() { System. out .println( "Thread 1 started" ); } }; Thread t1= new Thread(r1); t1.start();                                        //With Lambda Runnabl...
Read more