Shulou(Shulou.com)06/01 Report--

This article mainly introduces "how to use spring boot+rocketMQ to achieve simple message sending and receiving". In daily operation, I believe that many people have doubts about how to use spring boot+rocketMQ to achieve simple message sending and receiving. The editor consulted all kinds of materials and sorted out simple and easy-to-use methods of operation. I hope it will be helpful for everyone to answer the doubts of "how to use spring boot+rocketMQ to achieve simple message sending and receiving". Next, please follow the editor to study!

1. Environment building

We are going to use rocketMQ, so we need to use rocketMQ services. Installation tutorial

The above does not describe how to run under windows, so talk about the installation method of windows.

Follow the installation tutorial to download the binaries and extract them to any directory:

Configure environment variables:

ROCKETMQ_HOMEE:\ rocketMQ\ rocketmq-all-4.4.0-bin-release / / path to extract the file

After completing the configuration, it is best to restart the computer! There may be an error that the environment variable cannot be found if you do not restart.

Start the service:

Open a command window in the bin folder of your installation directory.

Start namesrv first

Start mqnamesrv.cmd

Do not close this command box

Start broker

Start mqbroker.cmd-n 127.0.0.1 9876 autoCreateTopicEnable=true

Do not close this command box

If the pop-up prompt says' error: the main class xxxxxx' cannot be found or cannot be loaded. Open runbroker.cmd and enclose'% CLASSPATH%''in English double quotes. Save and re-execute the start statement.

If there is an error that there is not enough memory, make sure the machine has enough running memory, and then restart.

RocketMQ plug-in deployment, here has not been studied, directly refer to others.

=

Let's get down to business, official address.

The following spring boot versions are all 2.1.4.RELEASE

Build producer (producer), that is, message sender

Join pom

Org.apache.rocketmq rocketmq-spring-boot-starter 2.0.3## application.propertiesrocketmq.name-server=127.0.0.1:9876rocketmq.producer.group=my-group

Create a new controller to send messages:

@ RestControllerpublic class SendMessageApi {@ Resource private RocketMQTemplate rocketMQTemplate; @ GetMapping (value = "/ send/ {message}") public String echo (@ PathVariable String message) {/ send Hello, World! / / rocketMQTemplate.convertAndSend ("test-topic-1", "Hello, World!") directly to the topic test-topic-1 / send message rocketMQTemplate.send ("test-topic-1", MessageBuilder.withPayload (message). Build ()) to the theme test-topic-1; / send the object to the theme test-topic-2, where the object is your own custom dto and needs to serialize / / MessageDto messageDto = new MessageDto (); / / messageDto.setXXX (") / /... / rocketMQTemplate.convertAndSend ("test-topic-2", messageDto); System.out.println ("message sent successfully."); return message;}}

Build a consumer (consumer), that is, the message receiver

Join pom

Org.apache.rocketmq rocketmq-spring-boot-starter 2.0.3 my-consumer_test-topic-1 # application.propertiesrocketmq.name-server=127.0.0.1:9876 / / receives the string type message @ Service @ RocketMQMessageListener (topic = "test-topic-1", consumerGroup = "my-consumer_test-topic-1") public class MyConsumer1 implements RocketMQListener {public void onMessage (String message) {System.out.println ("received message:" + message) }} / / receive messages of object type @ Service @ RocketMQMessageListener (topic = "test-topic-2", consumerGroup = "my-consumer_test-topic-2") public class MyConsumer2 implements RocketMQListener {public void onMessage (MessageDto messageDto) {System.out.println ("received messageDto:" + messageDto.toString ());}}

Simple message sending and receiving are completed.

At this point, the study on "how to use spring boot+rocketMQ to achieve simple message sending and receiving" is over. I hope to be able to solve your doubts. The collocation of theory and practice can better help you learn, go and try it! If you want to continue to learn more related knowledge, please continue to follow the website, the editor will continue to work hard to bring you more practical articles!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.