测试获取消息队列数量

README.md

@@ -1,3 +1,4 @@
+084dcd2a4_202403060901535350:;/home/ubuntu/data/084dcd2a4_202403060901535350:;084dcd2a4/1214926003990691840/084dcd2a4_202403060901535350/:;:;zfb-ecfQPqal8:;0:;13950265761:;11:;slam:;1214926003990691840:;084DCD2A4:;0:;V3
 "1460,13794930986",
 "1498,18680619513",
 "1537,18217332331",

src/test/java/com/fdkankan/task/TaskTestApplication.java

@@ -1,5 +1,6 @@
 package com.fdkankan.task;
 
+import cn.hutool.core.date.DateUtil;
 import com.fdkankan.task.entity.Repair;
 import com.fdkankan.task.entity.TbBuilding;
 import com.fdkankan.task.entity.TbHouse;
@@ -8,17 +9,19 @@ import com.fdkankan.task.mapper.TbBuildingMapper;
 import com.fdkankan.task.mapper.TbHouseMapper;
 import com.fdkankan.task.service.RepairService;
 import com.mybatisflex.core.query.QueryWrapper;
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Channel;
 import org.junit.jupiter.api.Test;
 import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.amqp.rabbit.core.ChannelCallback;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.test.context.SpringBootTest;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.UUID;
+import javax.annotation.Resource;
+import java.util.*;
 
 @SpringBootTest
 public class TaskTestApplication {
@@ -33,4 +36,14 @@ public class TaskTestApplication {
         List<Repair> repairs = repairMapper.selectListByQuery(queryWrapper);
         System.out.println(repairs);
     }
+
+    @Resource(name = "v3RabbitTemplate")
+    private RabbitTemplate secondRabbitTemplate;
+
+    @Test
+    void test2() {
+        Long queueModelingA = secondRabbitTemplate.execute(channel -> channel.messageCount("QUEUE_MODELING_A"));
+        System.out.println(queueModelingA);
+    }
+
 }

src/test/java/com/fdkankan/task/TestZfb.java

@@ -0,0 +1,18 @@
+package com.fdkankan.task;
+
+import cn.hutool.core.date.DateUtil;
+import org.junit.jupiter.api.Test;
+
+import java.util.Date;
+
+public class TestZfb {
+
+
+    static String dataFmt = "yyyyMMddHHmmssSSSS";
+    @Test
+    void test2(){
+        System.out.println(DateUtil.format(new Date(),dataFmt));
+//        /home/ubuntu/data/5838794f37f8_(null)
+        //202403052050160067
+    }
+}