优化查询

src/main/java/com/ydtech/config/RabbitMQConfig.java

@@ -0,0 +1,124 @@
+package com.ydtech.config;
+
+import com.ydtech.constants.RabbitMqEnum;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.*;
+import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.connection.CorrelationData;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RabbitMQConfig {
+
+    /**
+     * 消费者数量，默认10
+     */
+    public static final int DEFAULT_CONCURRENT = 10;
+
+    /**
+     * 每个消费者获取最大投递数量 默认50
+     */
+    public static final int DEFAULT_PREFETCH_COUNT = 50;
+
+    private final static Logger log = LoggerFactory.getLogger(RabbitMQConfig.class);
+
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    Queue queue() {
+        return new Queue(RabbitMqEnum.ORDER_QUEUE.getCode(), true);
+    }
+
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    Queue queueFail() {
+        return new Queue(RabbitMqEnum.ORDER_QUEUE_FAIL.getCode(), true);
+    }
+
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    Queue queueSign() {
+        return new Queue(RabbitMqEnum.ORDER_QUEUE_SIGN.getCode(), true);
+    }
+
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    DirectExchange exchange() {
+        return new DirectExchange(RabbitMqEnum.ORDER_EXCHANGE.getCode(),true,false);
+    }
+
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    DirectExchange exchangeFail() {
+        return new DirectExchange(RabbitMqEnum.ORDER_EXCHANGE_FAIL.getCode(),true,false);
+    }
+
+    @Bean
+        //设置队列持久化 第二个参数  保证数据不丢失
+    DirectExchange exchangeSign() {
+        return new DirectExchange(RabbitMqEnum.ORDER_EXCHANGE_SIGN.getCode(),true,false);
+    }
+
+    @Bean
+    Binding binding(Queue queue, DirectExchange exchange) {
+        return BindingBuilder.bind(queue).to(exchange).with(RabbitMqEnum.ORDER_ROUTINGKEY.getCode());
+    }
+
+
+    @Bean
+    Binding bindingFail(Queue queue, DirectExchange exchange) {
+        return BindingBuilder.bind(queue).to(exchange).with(RabbitMqEnum.ORDER_ROUTINGKEY_FAIL.getCode());
+    }
+    @Bean
+    Binding bindingSign(Queue queue, DirectExchange exchange) {
+        return BindingBuilder.bind(queue).to(exchange).with(RabbitMqEnum.ORDER_ROUTINGKEY_SIGN.getCode());
+    }
+    /**
+     *  @version
+     *  @author: hxl
+     *  @Date: 2024/11/5 10:27
+     *  @Description:  手动确认保证消息消费成功
+     */
+    @Bean
+    public RabbitTemplate createRabbitTemplate(ConnectionFactory connectionFactory) {
+        RabbitTemplate rabbitTemplate = new RabbitTemplate();
+        rabbitTemplate.setConnectionFactory(connectionFactory);
+        rabbitTemplate.setMandatory(true);
+        // 设置配置回调函数
+        rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
+            @Override
+            public void confirm(CorrelationData correlationData, boolean ack, String cause) {
+                log.info("ConfirmCallback:     " + "相关数据：" + correlationData);
+                log.info("ConfirmCallback:     " + "确认情况：" + ack);
+                log.info("ConfirmCallback:     " + "原因：" + cause);
+            }
+        });
+        rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {
+            @Override
+            public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
+                log.info("ReturnCallback:     " + "消息：" + message);
+                log.info("ReturnCallback:     " + "回应码：" + replyCode);
+                log.info("ReturnCallback:     " + "回应信息：" + replyText);
+                log.info("ReturnCallback:     " + "交换机：" + exchange);
+                log.info("ReturnCallback:     " + "路由键：" + routingKey);
+            }
+        });
+        return rabbitTemplate;
+    }
+
+
+
+    @Bean
+    public SimpleRabbitListenerContainerFactory pointTaskContainerFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {
+        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
+        factory.setPrefetchCount(DEFAULT_PREFETCH_COUNT);
+        factory.setConcurrentConsumers(DEFAULT_CONCURRENT);
+        factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
+        configurer.configure(factory, connectionFactory);
+        return factory;
+    }
+}

src/main/java/com/ydtech/constants/RabbitMqEnum.java

@@ -13,15 +13,15 @@ public enum RabbitMqEnum {
 
     ORDER_ROUTINGKEY("order_push_routingKey", "关键字"),
 
-    ORDER_QUEUE_FLAL("order_push_fail_queue", "消息失败队列"),
-    ORDER_EXCHANGE_FLAL("order_push_fail_exchange", "消息失败交换机"),
+    ORDER_QUEUE_FAIL("order_push_fail_queue", "消息失败队列"),
+    ORDER_EXCHANGE_FAIL("order_push_fail_exchange", "消息失败交换机"),
 
-    ORDER_ROUTINGKEY_FLAL("order_push_fail_routingKey", "消息失败关键字"),
+    ORDER_ROUTINGKEY_FAIL("order_push_fail_routingKey", "消息失败关键字"),
 
-    ORDER_QUEUE_SIGN("order_push_sign_queue", "承保订单队列"),
-    ORDER_EXCHANGE_SIGN("order_push_sign_exchange", "承保订单交换机"),
+    ORDER_QUEUE_SIGN("order_push_sign_queue", "承包订单队列"),
+    ORDER_EXCHANGE_SIGN("order_push_sign_exchange", "承包订单交换机"),
 
-    ORDER_ROUTINGKEY_SIGN("order_push_sign_routingKey", "承保订单关键字");
+    ORDER_ROUTINGKEY_SIGN("order_push_sign_routingKey", "承包订单关键字");
 
     private final String code;
     private final String desc;

src/main/java/com/ydtech/modules/order/orderThread/OrderFailRunnableThread.java

@@ -60,7 +60,7 @@ public class OrderFailRunnableThread implements Runnable {
             try{
                 //更新狀態
                 insOrderPushMsgService.save(insOrderPushMsg);
-                this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE_FLAL.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_FLAL.getCode(), message_cj);
+                this.rabbitTemplate.convertAndSend(RabbitMqEnum.ORDER_EXCHANGE_FAIL.getCode(), RabbitMqEnum.ORDER_ROUTINGKEY_FAIL.getCode(), message_cj);
             }catch(Exception e){
                 e.getStackTrace();
             }