Java中SpringBoot如何整合RabbitMQ

這篇文章主要為大家展示了“Java中SpringBoot如何整合RabbitMQ”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“Java中SpringBoot如何整合RabbitMQ”這篇文章吧。

如果要進(jìn)行 RabbitMQ 整合的時候一定要注意以下幾個概念：交換空間、虛擬主機(jī)、隊列信息。本次為了方便起見將項目分為 兩個：RabbitMQ-Consumer、RabbitMQ-Producer。

1、 【兩個項目】將 rabbitmq 的依賴支持包拷貝到項目之中；

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

2、【microboot-rabbitmq-producer、microboot-rabbitmq-consumer】修改 application.yml 配置文件，追加 rabbitmq 的相關(guān)配置項：

server:
  port: 80
spring:
  messages:
    basename: i18n/Messages,i18n/Pages
  rabbitmq:
    addresses: rabbitmq-server
    username: studyjava
    password: hello
    virtual-host: /

 3、【microboot-rabbitmq-producer】建立一個消息的發(fā)送接口：

package cn.study.microboot.producer;
public interface IMessageProducerService {    
public void sendMessage(String msg) ;
}

4、 【microboot-rabbitmq-producer】為了可以正常使用 RabbitMQ 進(jìn)行消息處理，你還需要做一個消息生產(chǎn)配置類；

package cn.study.microboot.config;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ProducerConfig {
    public static final String EXCHANGE = "study.microboot.exchange"; // 交換空間名稱
    public static final String ROUTINGKEY = "study.microboot.routingkey"; // 設(shè)置路由key
    public static final String QUEUE_NAME = "study.microboot.queue"; // 隊列名稱
    @Bean
    public Binding bindingExchangeQueue(DirectExchange exchange,Queue queue) {
        return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY) ;
    }
    @Bean
    public DirectExchange getDirectExchange() { // 使用直連的模式
        return new DirectExchange(EXCHANGE, true, true);
    }
    @Bean
    public Queue queue() { // 要創(chuàng)建的隊列信息
        return new Queue(QUEUE_NAME);
    }
}

5、 【microboot-rabbitmq-producer】創(chuàng)建消息服務(wù)的實現(xiàn)子類：

package cn.study.microboot.producer.impl;
import javax.annotation.Resource;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;
import cn.study.microboot.config.ProducerConfig;
import cn.study.microboot.producer.IMessageProducerService;
@Service
public class MessageProducerServiceImpl implements IMessageProducerService {
    @Resource
    private RabbitTemplate rabbitTemplate;
    @Override
    public void sendMessage(String msg) {
        this.rabbitTemplate.convertAndSend(ProducerConfig.EXCHANGE,
                ProducerConfig.ROUTINGKEY, msg);
    }
}

6、 【microboot-rabbitmq-consumer】依然需要做一個消費者的配置程序類，而這個程序類里面主要的目的依然是設(shè)置交換空間、 路由 KEY 等信息。

package cn.study.microboot.config;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ConsumerConfig {
    public static final String EXCHANGE = "study.microboot.exchange"; // 交換空間名稱
    public static final String ROUTINGKEY = "study.microboot.routingkey"; // 設(shè)置路由key
    public static final String QUEUE_NAME = "study.microboot.queue"; // 隊列名稱
    @Bean
    public Queue queue() { // 要創(chuàng)建的隊列信息
        return new Queue(QUEUE_NAME);
    }
    @Bean
    public DirectExchange getDirectExchange() { // 使用直連的模式
        return new DirectExchange(EXCHANGE, true, true);
    }
    @Bean
    public Binding bindingExchangeQueue(DirectExchange exchange,Queue queue) {
        return BindingBuilder.bind(queue).to(exchange).with(ROUTINGKEY) ;
    }
}

7、 【microboot-rabbitmq-consumer】實現(xiàn)監(jiān)聽處理類：

package cn.study.microboot.consumer;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;
@Service
public class MessageConsumerService {
    @RabbitListener(queues="study.microboot.queue")
    public void receiveMessage(String text) {    // 進(jìn)行消息接收處理
        System.err.println("【*** 接收消息 ***】" + text);
    }
}

8、 【microboot-rabbitmq-producer】創(chuàng)建一個測試類實現(xiàn)消息的發(fā)送處理。

package cn.study.microboot.test;
import javax.annotation.Resource;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.web.WebAppConfiguration;
import cn.study.microboot.StartSpringBootMain;
import cn.study.microboot.producer.IMessageProducerService;
@SpringBootTest(classes = StartSpringBootMain.class)
@RunWith(SpringJUnit4ClassRunner.class)
@WebAppConfiguration
public class TestActiveMQ {
    @Resource
    private IMessageProducerService messageProducer;
    @Test
    public void testSend() throws Exception {
        for (int x = 0; x < 100; x++) {
            this.messageProducer.sendMessage("study - " + x);
        }
    }
}

9、 【microboot-rabbitmq-consumer】編寫消息接收測試類，這里面不需要編寫代碼，只需要做一個休眠即可：

package cn.study.microboot;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.web.WebAppConfiguration;
@SpringBootTest(classes = StartSpringBootMain.class)
@RunWith(SpringJUnit4ClassRunner.class)
@WebAppConfiguration
public class AppTest {
    @Test
    public void testStart() throws Exception {
        Thread.sleep(Long.MAX_VALUE);
    }
}

整體進(jìn)行項目開發(fā)之中整合的處理步驟還是簡單，但是千萬要注意，由于是第一次整合處理，所以將生產(chǎn)者與消費者的配置 類分開了，實際上這兩個類的作用是完全一樣的。

以上是“Java中SpringBoot如何整合RabbitMQ”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注億速云行業(yè)資訊頻道！