获取返回消息代码优化

src/main/java/com/founder/service/ResourceService.java

@@ -150,20 +150,29 @@ public class ResourceService {
 
             // 循环消费 任务进度 并更新前台界面
             while (true) {
-                ConsumerRecords<String, String> records = consumer.poll(10000);//消费间隔单位：毫秒
-                for (ConsumerRecord<String, String> consumerRecord : records) {
-                    logger.info("消息队列返回内容：{"+consumerRecord.key()+":"+consumerRecord.value()+"}"); // 消息key：taskid的值// 消息value：消息的json字符串
-                    try {
-                        if("JJXX".equals(type)){
-                            TbZhzxJjxx entity = parseJjxx(consumerRecord.value());
-                            xxcxDao.insertJjxx(entity);
-                        }else if("CJXX".equals(type)){
-                            TbZhzxCjxx entity = parseCjxx(consumerRecord.value());
-                            xxcxDao.insertCjxx(entity);
+                ConsumerRecords<String, String> records = null;//消费间隔单位：毫秒
+                try {
+                    records = consumer.poll(10000);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+                if(records!=null){
+                    for (ConsumerRecord<String, String> consumerRecord : records) {
+                        logger.info("消息队列返回内容：{"+consumerRecord.key()+":"+consumerRecord.value()+"}"); // 消息key：taskid的值// 消息value：消息的json字符串
+                        try {
+                            if("JJXX".equals(type)){
+                                TbZhzxJjxx entity = parseJjxx(consumerRecord.value());
+                                xxcxDao.insertJjxx(entity);
+                            }else if("CJXX".equals(type)){
+                                TbZhzxCjxx entity = parseCjxx(consumerRecord.value());
+                                xxcxDao.insertCjxx(entity);
+                            }
+                        } catch (Exception e) {
+                            e.printStackTrace();
                         }
-                    } catch (Exception e) {
-                        e.printStackTrace();
                     }
+                }else{
+                    logger.warn("消息队列没有内容返回。");
                 }
             }