SpringBoot整合RabbitMQ详解

 
   org.springframework.boot
   spring-boot-starter-amqp
 

# 应用名称
spring:
  application:
    name: sb-rabbitmq
  rabbitmq:
    host: 192.168.1.201
    port: 5672
    username: guest
    password: guest
    virtual-host: /

package com.kkarma.config;


import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {
    public static final String EXCHANGE_NAME = "springboot-ex-topic";
    public static final String QUEUE_NAME = "springboot-queue-one";
    public static final String ROUTING_KEY = "*.kkarma.*";

    @Bean
    public Exchange getExchange(){
        return ExchangeBuilder.topicExchange(EXCHANGE_NAME).build();
    }

    @Bean
    public Queue getQueue() {
        return QueueBuilder.durable(QUEUE_NAME).build();
    }

    @Bean
    public Binding getBinding(Queue queue, Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with(ROUTING_KEY).noargs();
    }
}

package com.kkarma;

import com.kkarma.config.RabbitMQConfig;
import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
public class PublisherTest {

    private final RabbitTemplate rabbitTemplate;

    @Autowired
    public PublisherTest(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    @Test
    public void push() throws Exception {
        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, "com.kkarma.controller", "hello springboot rabbitmq");
        System.out.println("消息发送成功...");
    }
}

package com.kkarma.consumer;


import com.kkarma.config.RabbitMQConfig;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class Consumer {

    private final RabbitTemplate rabbitTemplate;

    @Autowired
    public Consumer(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME)
    public void pull(String msg, Channel channel, Message message) throws Exception {
        System.out.println("消费消息内容： " + msg);
        String correlationId = message.getMessageProperties().getCorrelationId();
        System.out.println("唯一标识： " + correlationId);
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
    }
}