On the method of spring boot rabbitmq dynamic management

When using spring boot + rabbitmq, you may want to temporarily disable / enable listening or modify the number of listening consumers during the development process. If you restart every modification, it is a waste of time, so we have studied enabling and disabling monitoring or modifying some configurations without downtime

I Configuration of rabbitmq listening

Rabbitannotationdrivenconfiguration mainly monitors the configuration of factories and factories, but it only creates beans and does not have real initialization

Through the bean class name in the configuration, analyze that the listening of rabbitmq must be created by the listening factory, so find the listening factory simplerabbitlistenercontainerfactory

Since there is no initialization listening in the automatic configuration, it should be called elsewhere. Enter the listening factory class and find the initializecontainer (simplemessagelistenercontainer instance) method. It is speculated that the initialization must be related to this method, so check where to call, and find the rabbitlistener endpointregistry The createlistenercontainer (rabbitlistenerendpoint endpoint, rabbitlistenercontainerfactory factory) method contains code for creating a listening container and initializing it

Continue to find the place where this method is called, and find the rabbitlistener endpointregistrar After the afterpropertieset () method, I found that there are many places to call

Look at the afterpropertiesset method, which is in the initializingbean interface. I guess it should be the bean initialization method that the spring container will call after creating the bean, so find out where the rabbitlistener endpointregistrar was created. Originally, it is a private property in the rabbitlistenerannotationbeanpostprocessor, and the rabbitlistenerannotationbeanpostprocessor is initialized in the automatic configuration of rabbitbootstrapconfiguration, so this is the source of rabbitmq initialization listening

II Dynamic management rabbitmq listening

Back to the original problem, I want to dynamically enable and disable MQ listening, so first look at the initialization configuration class. Since there is initialization, there may be related management. Therefore, I found the start() and stop() methods in the rabbitlistenerendpointregistry, which operate on the listening container. The main source code is as follows

Write a controller, inject rabbitlistenerendpointregistry, and use start() and stop() to enable and disable listening. The rabbitlistenerendpointregistry instance can also obtain the listening container and modify some parameters of listening, such as the number of consumers. The code is as follows:

The above is the whole content of this article. I hope it will be helpful to your study, and I hope you can support programming tips.