弹性伸缩服务改造

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/listener/container/RabbitMQConfig.java

@@ -2,6 +2,7 @@ package com.gis.listener.container;
 
 import com.gis.receiver.QueueNameService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.AcknowledgeMode;
 import org.springframework.amqp.core.Queue;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
@@ -78,6 +79,7 @@ public class RabbitMQConfig {
         container.setMessageListener(doSliceQueueListener);
         container.setAutoStartup(!isDynamic); // 根据配置决定是否自动启动
         container.setPrefetchCount(2);
+        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         return container;
     }
 
@@ -89,6 +91,7 @@ public class RabbitMQConfig {
         container.setMessageListener(panoMigrateSceneQueueListener);
         container.setAutoStartup(!isDynamic); // 根据配置决定是否自动启动
         container.setPrefetchCount(1);
+        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         return container;
     }
 
@@ -100,6 +103,7 @@ public class RabbitMQConfig {
         container.setMessageListener(panoPayStatusSceneQueueListener);
         container.setAutoStartup(!isDynamic); // 根据配置决定是否自动启动
         container.setPrefetchCount(1);
+        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         return container;
     }
 
@@ -111,6 +115,7 @@ public class RabbitMQConfig {
         container.setMessageListener(new SceneQueueListener());
         container.setAutoStartup(!isDynamic); // 根据配置决定是否自动启动
         container.setPrefetchCount(1);
+        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         return container;
     }
 
@@ -123,6 +128,7 @@ public class RabbitMQConfig {
         container.setMessageListener(sceneWorkQueueListener);
         container.setAutoStartup(isDynamic); // 根据配置决定是否自动启动
         container.setPrefetchCount(2);
+        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         return container;
     }
 }

720yun_fd_consumer/run.sh

@@ -15,7 +15,7 @@ startApp(){
     	echo "程序已经在运行了"
     else
     	echo "执行 start 方法"
-    	nohup java -Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5530 -jar -XX:MetaspaceSize=1500m -XX:MaxMetaspaceSize=1500m -Xms4072m -Xmx4072m -Xmn1024m -Xss1m -XX:SurvivorRatio=8 ./$APP_NAME --spring.profiles.active=$APP_EVN --server.port=$APP_PORT -DDYNAMIC=$DYNAMIC > logs.log 2>error.log &  # 说明pid为空
+    	nohup java -DDynamic=$DYNAMIC -Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=n,address=5530 -jar -XX:MetaspaceSize=1500m -XX:MaxMetaspaceSize=1500m -Xms4072m -Xmx4072m -Xmn1024m -Xss1m -XX:SurvivorRatio=8 ./$APP_NAME --spring.profiles.active=$APP_EVN --server.port=$APP_PORT  > logs.log 2>error.log &  # 说明pid为空
 	echo Start Success!
 fi
 }