RabbitMQ Message Middleware: Concepts, Installation, and SpringBoot Integration

Message middleware provides asynchronous, reliable message transmission between applications, improving system efficiency and decoupling services. Common scenarios include sending registration emails/SMS without blocking user flow and handling high‑traffic events such as flash sales.

Key concepts include the broker (server hosting the middleware), destinations (queues or topics), queues (point‑to‑point), topics (publish/subscribe), messages (header + body), producers, consumers, exchanges, bindings, and channels.

RabbitMQ is an open‑source AMQP‑compliant broker. It can be installed via Docker:

docker pull rabbitmq:management

docker run -d --name rabbitmq -p 5671:5671 -p 5672:5672 -p 4369:4369 -p 25672:25672 -p 15671:15671 -p 15672:15672 rabbitmq:management

RabbitMQ supports four exchange types:

direct – exact routing‑key match

fanout – broadcast to all bound queues

topic – pattern‑based routing

headers – routing based on message headers

In a SpringBoot project, add the AMQP starter dependency:

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

Configure the connection:

spring:
  rabbitmq:
    host: 192.168.66.10  # host address
    port: 5672           # port
    virtual-host: /      # default virtual host

Use AmqpAdmin to declare exchanges, queues, and bindings programmatically:

@SpringBootTest
@EnableRabbit
class RabbitMqDemoApplicationTests {

    @Autowired
    private AmqpAdmin amqpAdmin;

    @Test
    void contextLoads() {
        // Create direct exchange
        Exchange directExchange = new DirectExchange("direct-exchange");
        amqpAdmin.declareExchange(directExchange);
        // Create queue
        Queue queue = new Queue("test-queue");
        amqpAdmin.declareQueue(queue);
        // Bind queue to exchange
        Binding binding = new Binding("test-queue", Binding.DestinationType.QUEUE,
                "direct-exchange", "test-key", null);
        amqpAdmin.declareBinding(binding);
    }
}

Relevant constructors:

public DirectExchange(String name, boolean durable, boolean autoDelete, Map<String, Object> arguments) { ... }

public Queue(String name, boolean durable, boolean exclusive, boolean autoDelete, @Nullable Map<String, Object> arguments) { ... }

public Binding(String destination, DestinationType destinationType, String exchange, String routingKey, @Nullable Map<String, Object> arguments) { ... }

Send a message through the declared exchange:

@Autowired
private RabbitTemplate rabbitTemplate;

@Test
void sendMessage() {
    rabbitTemplate.convertAndSend("direct-exchange", "test-key", "hello rabbitmq!");
}

Consume messages with @RabbitListener:

@Service
public class MessageServiceImpl implements MessageService {

    @RabbitListener(queues = {"test-queue"})
    @Override
    public void receiveMessage(Message message) {
        byte[] body = message.getBody();
        MessageProperties props = message.getMessageProperties();
        System.out.println(new String(body));
        System.out.println(props);
    }
}

When the payload is JSON, Spring can directly convert it to a POJO:

@RabbitListener(queues = {"test-queue"})
@Override
public void receiveMessage(Message message, Person person) {
    System.out.println(person);
}