Category: rabbitmq

RabbitMQ – Producer Application ”; Previous Next Now let”s create a producer application which will send message to the RabbitMQ Queue. Create Project Using eclipse, select File → New → Maven Project. Tick the Create a simple project(skip archetype selection) and click Next. Enter the details, as shown below − groupId − com.tutorialspoint artifactId − producer version − 0.0.1-SNAPSHOT name − RabbitMQ Producer Click on Finish button and a new project will be created. pom.xml Now update the content of pom.xml to include dependencies for RabbitMQ. <project xmlns=”http://maven.apache.org/POM/4.0.0″ xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xsi:schemaLocation=”http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd”> <modelVersion>4.0.0</modelVersion> <groupId>com.tutorialspoint.activemq</groupId> <artifactId>producer</artifactId> <version>0.0.1-SNAPSHOT</version> <name>RabbitMQ Producer</name> <properties> <java.version>11</java.version> </properties> <dependencies> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.14.2</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.26</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-simple</artifactId> <version>1.7.26</version> </dependency> </dependencies> </project> Now create a Producer class which will send message to the RabbitMQ Queue. package com.tutorialspoint.rabbitmq; import java.io.IOException; import java.util.Scanner; import java.util.concurrent.TimeoutException; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class Producer { private static String QUEUE = “MyFirstQueue”; public static void main(String[] args) throws IOException, TimeoutException { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(“localhost”); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.queueDeclare(QUEUE, false, false, false, null); Scanner input = new Scanner(System.in); String message; do { System.out.println(“Enter message: “); message = input.nextLine(); channel.basicPublish(“”, QUEUE, null, message.getBytes()); } while (!message.equalsIgnoreCase(“Quit”)); } } } Producer class creates a connection, creates a channel, connects to a queue. If user enters quit then application terminates else it will send the message to the queue using basicPublish method. We”ll run this application in RabbitMQ – Test Application chapter. Print Page Previous Next Advertisements ”;

RabbitMQ – Features ”; Previous Next RabbitMQ is one of the most popular open source message broker. It is designed to provide high availability, scalability, reliability, performance and security for enterprise level messaging applications. Following are some of the salient features of RabbitMQ. LightWeight − RabbitMQ is lightweight and and is quity easy to install on premise as well as on cloud. Connectivity Options − RabbitMQ supports multiple messaging protocols and can be deployed in distributed/federated configurations to meet high availability, scalability requirements. Pluggable Architecture − RabbitMQ allows to choose a persistence mechanism and also provides options to customize security for authentication and authorization as per the application needs. Multi-Platform − RabbitMQ provides client APIs for many popular languages like Java, Python, JavaScript, Ruby etc. Broker Cluster − RabbitMQ can be deployed as clusters for high availability and throughput. It can be federated across multiple availability zones and regions. Features Rich − RabbitMQ provides many advanced features for both broker and clients. Simple Administration Interface − RabbitMQ administration console is easy to use but still provides many powerful administration features. Enterprise and Cloud Ready − RabbitMQ supports pluggable authentication and authorization. It supports LDAP and TLS. It can be easily deployed in public as well as private clouds. Features Rich − RabbitMQ provides many advanced features for both broker and clients. It provides plugins to support continuous integration, operational metrics, and integration to other enterprise systems etc. Management − RabbitMQ provides HTTP API, command line tool and UI to manage and monitor RabbitMQ. Print Page Previous Next Advertisements ”;

RabbitMQ – Environment Setup ”; Previous Next This chapter will guide you on how to prepare a development environment to start your work with RabbitMQ. It will also teach you how to set up JDK, Maven and Eclipse on your machine before you set up RabbitMQ − Setup Java Development Kit (JDK) You can download the latest version of SDK from Oracle”s Java site − Java SE Downloads. You will find instructions for installing JDK in downloaded files, follow the given instructions to install and configure the setup. Finally set PATH and JAVA_HOME environment variables to refer to the directory that contains java and javac, typically java_install_dir/bin and java_install_dir respectively. If you are running Windows and have installed the JDK in C:jdk-11.0.11, you would have to put the following line in your C:autoexec.bat file. set PATH=C:jdk-11.0.11;%PATH% set JAVA_HOME=C:jdk-11.0.11 Alternatively, on Windows NT/2000/XP, you will have to right-click on My Computer, select Properties → Advanced → Environment Variables. Then, you will have to update the PATH value and click the OK button. On Unix (Solaris, Linux, etc.), if the SDK is installed in /usr/local/jdk-11.0.11 and you use the C shell, you will have to put the following into your .cshrc file. setenv PATH /usr/local/jdk-11.0.11/bin:$PATH setenv JAVA_HOME /usr/local/jdk-11.0.11 Alternatively, if you use an Integrated Development Environment (IDE) like Borland JBuilder, Eclipse, IntelliJ IDEA, or Sun ONE Studio, you will have to compile and run a simple program to confirm that the IDE knows where you have installed Java. Otherwise, you will have to carry out a proper setup as given in the document of the IDE. Setup Eclipse IDE All the examples in this tutorial have been written using Eclipse IDE. So we would suggest you should have the latest version of Eclipse installed on your machine. To install Eclipse IDE, download the latest Eclipse binaries from www.eclipse.org/downloads. Once you download the installation, unpack the binary distribution into a convenient location. For example, in C:eclipse on Windows, or /usr/local/eclipse on Linux/Unix and finally set PATH variable appropriately. Eclipse can be started by executing the following commands on Windows machine, or you can simply double-click on eclipse.exe. %C:eclipseeclipse.exe Eclipse can be started by executing the following commands on Unix (Solaris, Linux, etc.) machine − $/usr/local/eclipse/eclipse After a successful startup, if everything is fine then it should display the following result − Set Maven In this tutorial, we are using maven to run and build the spring based examples to run RabbitMQ based applications. Follow the Maven – Environment Setup to install maven. Print Page Previous Next Advertisements ”;

Discuss RabbitMQ Tutorial ”; Previous Next RabbitMQ is an open source message broker written in Java. It”s fully compliant with JMS 1.1 standards. JMS is a specification that allows development of message based system. RabbitMQ acts as a broker of messages which sits in between applications and allows them to communicate in asynchronous and reliable way. In this tutorial, we”ll cover all the ways of using RabbitMQ which helps in solving the common problems developers/users face in activeMQ based applications. Print Page Previous Next Advertisements ”;

RabbitMQ – Test Application ”; Previous Next Start the Producer Application In eclipse, right click on the Producer.java source, and select Run As → Java Application. Producer application will start running and you”ll see the output as follows − Enter message: Start the Consumer Application In eclipse, right click on the Consumer.java source, and select Run As → Java Application. Consumer application will start running and you”ll see the output as follows − Waiting for messages. To exit press CTRL+C Send Message In Producer console window, type Hi and press enter button to send the message. Enter message: Hi Receive Message Verify in Consumer console window, the message is received. Waiting for messages. To exit press CTRL+C Received = Hi Send Quit as message to terminate the producer window session and terminate client window session. Verification Now open http://rabbitmq:15672/ in your browser. It will ask for credentials. Use guest/guest as username/password and it will load the RabbitMQ admin console where you can check Queues to check the status. It will show messages enqueued and delivered. Print Page Previous Next Advertisements ”;

RabbitMQ – Quick Guide ”; Previous Next RabbitMQ – Overview What is RabbitMQ? RabbitMQ is an open source message broker written in Java. It”s fully compliant with JMS 1.1 standards. It is developed and maintained by Apache Software Foundation and is licensed under Apache license. It provides high availability, scalability, reliability, performance and security for enterprise level messaging applications. JMS is a specification that allows development of message based system. RabbitMQ acts as a broker of messages which sits in between applications and allows them to communicate in asynchronous and reliable way. Types of Messaging There are two types of messaging options explained below for better understanding. Point to Point In this type of communication, the broker sends messages to only one consumer, while the other consumers will wait till they get the messages from the broker. No consumer will get the same message. If there are no consumers, the Broker will hold the messages till it gets a consumer. This type of communication is also called as Queue based communication where the Producer sends messages to a queue and only one consumer gets one message from the queue. If there is more than one consumer, they may get the next message but they won’t get the same message as the other consumer. Publish/Subscribe In this type of communication, the Broker sends same copy of messages to all the active consumers. This type of communication is also known as Topic based communication where broker sends same message to all active consumer who has subscribed for particular Topic. This model supports one-way communication where no verification of transmitted messages is expected. RabbitMQ – Environment Setup This chapter will guide you on how to prepare a development environment to start your work with RabbitMQ. It will also teach you how to set up JDK, Maven and Eclipse on your machine before you set up RabbitMQ − Setup Java Development Kit (JDK) You can download the latest version of SDK from Oracle”s Java site − Java SE Downloads. You will find instructions for installing JDK in downloaded files, follow the given instructions to install and configure the setup. Finally set PATH and JAVA_HOME environment variables to refer to the directory that contains java and javac, typically java_install_dir/bin and java_install_dir respectively. If you are running Windows and have installed the JDK in C:jdk-11.0.11, you would have to put the following line in your C:autoexec.bat file. set PATH=C:jdk-11.0.11;%PATH% set JAVA_HOME=C:jdk-11.0.11 Alternatively, on Windows NT/2000/XP, you will have to right-click on My Computer, select Properties → Advanced → Environment Variables. Then, you will have to update the PATH value and click the OK button. On Unix (Solaris, Linux, etc.), if the SDK is installed in /usr/local/jdk-11.0.11 and you use the C shell, you will have to put the following into your .cshrc file. setenv PATH /usr/local/jdk-11.0.11/bin:$PATH setenv JAVA_HOME /usr/local/jdk-11.0.11 Alternatively, if you use an Integrated Development Environment (IDE) like Borland JBuilder, Eclipse, IntelliJ IDEA, or Sun ONE Studio, you will have to compile and run a simple program to confirm that the IDE knows where you have installed Java. Otherwise, you will have to carry out a proper setup as given in the document of the IDE. Setup Eclipse IDE All the examples in this tutorial have been written using Eclipse IDE. So we would suggest you should have the latest version of Eclipse installed on your machine. To install Eclipse IDE, download the latest Eclipse binaries from www.eclipse.org/downloads. Once you download the installation, unpack the binary distribution into a convenient location. For example, in C:eclipse on Windows, or /usr/local/eclipse on Linux/Unix and finally set PATH variable appropriately. Eclipse can be started by executing the following commands on Windows machine, or you can simply double-click on eclipse.exe. %C:eclipseeclipse.exe Eclipse can be started by executing the following commands on Unix (Solaris, Linux, etc.) machine − $/usr/local/eclipse/eclipse After a successful startup, if everything is fine then it should display the following result − Set Maven In this tutorial, we are using maven to run and build the spring based examples to run RabbitMQ based applications. Follow the Maven – Environment Setup to install maven. RabbitMQ – Features RabbitMQ is one of the most popular open source message broker. It is designed to provide high availability, scalability, reliability, performance and security for enterprise level messaging applications. Following are some of the salient features of RabbitMQ. LightWeight − RabbitMQ is lightweight and and is quity easy to install on premise as well as on cloud. Connectivity Options − RabbitMQ supports multiple messaging protocols and can be deployed in distributed/federated configurations to meet high availability, scalability requirements. Pluggable Architecture − RabbitMQ allows to choose a persistence mechanism and also provides options to customize security for authentication and authorization as per the application needs. Multi-Platform − RabbitMQ provides client APIs for many popular languages like Java, Python, JavaScript, Ruby etc. Broker Cluster − RabbitMQ can be deployed as clusters for high availability and throughput. It can be federated across multiple availability zones and regions. Features Rich − RabbitMQ provides many advanced features for both broker and clients. Simple Administration Interface − RabbitMQ administration console is easy to use but still provides many powerful administration features. Enterprise and Cloud Ready − RabbitMQ supports pluggable authentication and authorization. It supports LDAP and TLS. It can be easily deployed in public as well as private clouds. Features Rich − RabbitMQ provides many advanced features for both broker and clients. It provides plugins to support continuous integration, operational metrics, and integration to other enterprise systems etc. Management − RabbitMQ provides HTTP API, command line tool and UI to manage and monitor RabbitMQ.

RabbitMQ – Subscriber Application ”; Previous Next Now let”s create a subscriber application which will receive message from the RabbitMQ Topic. Create Project Using eclipse, select File → New → Maven Project. Tick the Create a simple project(skip archetype selection) and click Next. Enter the details, as shown below − groupId − com.tutorialspoint artifactId − subscriber version − 0.0.1-SNAPSHOT name − RabbitMQ Subscriber Click on Finish button and a new project will be created. pom.xml Now update the content of pom.xml to include dependencies for RabbitMQ. <project xmlns=”http://maven.apache.org/POM/4.0.0″ xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xsi:schemaLocation=”http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd”> <modelVersion>4.0.0</modelVersion> <groupId>com.tutorialspoint.activemq</groupId> <artifactId>subscriber</artifactId> <version>0.0.1-SNAPSHOT</version> <name>RabbitMQ Subscriber</name> <dependencies> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.14.2</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.26</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-simple</artifactId> <version>1.7.26</version> </dependency> </dependencies> </project> Now create a Subscriber class which will receive message from the RabbitMQ Queue. package com.tutorialspoint.rabbitmq; import java.io.IOException; import java.nio.charset.StandardCharsets; import java.util.concurrent.TimeoutException; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.DeliverCallback; public class Subscriber { private static String EXCHANGE = “MyExchange”; public static void main(String[] args) throws IOException, TimeoutException { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(“localhost”); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); channel.exchangeDeclare(EXCHANGE, “fanout”); String queueName = channel.queueDeclare().getQueue(); channel.queueBind(queueName, EXCHANGE, “”); System.out.println(“Waiting for messages. To exit press CTRL+C”); DeliverCallback deliverCallback = (consumerTag, delivery) -> { String message = new String(delivery.getBody(), StandardCharsets.UTF_8); System.out.println(“Received ”” + message + “””); }; channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { }); } } Subscriber class creates a connection, creates a channel, declares the exchange, create a random queue and binds it with the exchange and then receives message from topic if there is any. Press Ctrl + C to terminate else it will keep polling queue for messages. We”ll run this application multiple times to create multiple subscribers in RabbitMQ – Test Application chapter. Print Page Previous Next Advertisements ”;

RabbitMQ – Test Application Topic ”; Previous Next Start the Publisher Application In eclipse, right click on the Publisher.java source, and select Run As → Java Application. Publisher application will start running and you”ll see the output as follows − Enter message: Start the Subscriber Application In eclipse, right click on the Subscriber.java source, and select Run As → Java Application. Subscriber application will start running and you”ll see the output as follows − Waiting for messages. To exit press CTRL+C Start another Subscriber Application In eclipse, again right click on the Subscriber.java source, and select Run As → Java Application. Another Subscriber application will start running and you”ll see the output as follows − Waiting for messages. To exit press CTRL+C Send Message In Publisher console window, type Hi and press enter button to send the message. Enter message: Hi Receive Message Verify in Subscriber console windows, the message is received in each window. Received = Hi Send Quit as message to terminate all publisher and subscriber console window sessions. Verification Now open http://rabbitmq:15672/ in your browser. It will ask for credentials. Use guest/guest as username/password and it will load the RabbitMQ admin console where you can check Queues and Exchanges to check the status of messages delivered and bindings. Print Page Previous Next Advertisements ”;

RabbitMQ – Publisher Application ”; Previous Next Now let”s create a publisher application which will send message to the RabbitMQ Exchange. This exchange will deliver the message to the queue which is bound with the exchange. Create Project Using eclipse, select File → New → Maven Project. Tick the Create a simple project(skip archetype selection) and click Next. Enter the details, as shown below − groupId − com.tutorialspoint artifactId − publisher version − 0.0.1-SNAPSHOT name − RabbitMQ Publisher Click on Finish button and a new project will be created. pom.xml Now update the content of pom.xml to include dependencies for RabbitMQ. <project xmlns=”http://maven.apache.org/POM/4.0.0″ xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xsi:schemaLocation=”http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd”> <modelVersion>4.0.0</modelVersion> <groupId>com.tutorialspoint.activemq</groupId> <artifactId>publisher</artifactId> <version>0.0.1-SNAPSHOT</version> <name>RabbitMQ Publisher</name> <properties> <java.version>11</java.version> </properties> <dependencies> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>5.14.2</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.26</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-simple</artifactId> <version>1.7.26</version> </dependency> </dependencies> </project> Now create a Publisher class which will send message to the RabbitMQ topic to broadcast it to all the subscribers. package com.tutorialspoint.rabbitmq; import java.io.IOException; import java.util.Scanner; import java.util.concurrent.TimeoutException; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class Publisher { private static final String EXCHANGE = “MyExchange”; public static void main(String[] args) throws IOException, TimeoutException { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(“localhost”); try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) { channel.exchangeDeclare(EXCHANGE, “fanout”); Scanner input = new Scanner(System.in); String message; do { System.out.println(“Enter message: “); message = input.nextLine(); channel.basicPublish(EXCHANGE, “”, null, message.getBytes()); } while (!message.equalsIgnoreCase(“Quit”)); } } } Producer class creates a connection, creates a channel, declare an exchange and then asks user to enter message. The message is sent to exchange and as queue name, we are not passing queue name thus all queues which are bound to this exchange will get the message. If user enters quit then application terminates else it will send the message to the topic. We”ll run this application in RabbitMQ – Test Application chapter. Print Page Previous Next Advertisements ”;

RabbitMQ – Overview ”; Previous Next What is RabbitMQ? RabbitMQ is an open source message broker written in Java. It”s fully compliant with JMS 1.1 standards. It is developed and maintained by Apache Software Foundation and is licensed under Apache license. It provides high availability, scalability, reliability, performance and security for enterprise level messaging applications. JMS is a specification that allows development of message based system. RabbitMQ acts as a broker of messages which sits in between applications and allows them to communicate in asynchronous and reliable way. Types of Messaging There are two types of messaging options explained below for better understanding. Point to Point In this type of communication, the broker sends messages to only one consumer, while the other consumers will wait till they get the messages from the broker. No consumer will get the same message. If there are no consumers, the Broker will hold the messages till it gets a consumer. This type of communication is also called as Queue based communication where the Producer sends messages to a queue and only one consumer gets one message from the queue. If there is more than one consumer, they may get the next message but they won’t get the same message as the other consumer. Publish/Subscribe In this type of communication, the Broker sends same copy of messages to all the active consumers. This type of communication is also known as Topic based communication where broker sends same message to all active consumer who has subscribed for particular Topic. This model supports one-way communication where no verification of transmitted messages is expected. Print Page Previous Next Advertisements ”;