Springboot 整合 Rabbitmq消息隊列

一、創建SpringBoot項目，並引入依賴

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

 

二、pom.xml配置

#配置rabbitMq 服務器
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
    #虛擬host 可以不設置,使用server默認host
    virtual-host: /
    publisher-confirms: true
    publisher-returns: true
    listener:
      simple:
        acknowledge-mode: manual
        concurrency: 1
        max-concurrency: 10
        retry:
          enabled: true

 

三、普通工作隊列模式

1、首先在工程中新建RabbitConfig文件

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

/**
 * @author 
 * @date 
 * @description rabbitmq配置類
 */
@Configuration
public class RabbitConfig {

    /**
     * 定義隊列名
     */
    private final static String STRING = "string";


    /**
     * 定義string隊列
     * @return
     */
    @Bean
    public Queue string() {
        return new Queue(STRING);
    
}

 

2、創建生產者

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.xml.ws.Action;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author 
 * @date 
 * @description rabbit消息生產者
 */
@Component
public class RabbitProducer {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void stringSend() {
        Date date = new Date();
        String dateString = new SimpleDateFormat("YYYY-mm-DD hh:MM:ss").format(date);
        System.out.println("[string] send msg:" + dateString);  
      // 第一個參數為剛剛定義的隊列名稱
        this.rabbitTemplate.convertAndSend("string", dateString);
    }
}

 

3、創建消費者

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author 
 * @date 
 * @description rabbitmq消費者 @RabbitListener(queues = "simpleMsg") 監聽名simpleMsg的隊列
 */
@Component
@RabbitListener(queues = "string")
public class StringConsumer {

    @Autowired private AmqpTemplate rabbitmqTemplate;

    /**
     * 消息消費
     * @RabbitHandler 代表此方法為接受到消息后的處理方法
     */
    @RabbitHandler
    public void recieved(String msg) {
        System.out.println("[string] recieved message:" + msg);
    }

}

 

 

QQ群 ：216868740

 

4、調用

@RestController
public class TestController {

    @Autowired
    private RabbitProducer producer;

    @RequestMapping("/test")
    public void test(){
        for (int i = 0; i < 10; i++) {
            producer.stringSend();
        }
    }
}