代码提交

liusheng

7 天以前 bd6c66c1a161e9f0fe94b94bed7935b2bde541f2

 ruoyi-admin/src/main/java/com/ruoyi/web/component/RedisMqReceiver.java

@@ -93,6 +93,9 @@
    @Value("${visitHosp}")
    private Integer visitHosp;

    @Value("${server.port}")
    private String port;

    // 创建固定大小的线程池
    private static final ExecutorService executorService = Executors.newFixedThreadPool(10);

@@ -107,7 +110,7 @@
        log.error("本机的网络IP为:{}", ip);
        String content = message.toString();
        //判断是不是任务信息，如果不是，直接返回，不需要执行
        if (!content.contains("taskid")) {
        if (!content.contains("taskid") || !port.equals("8095")) {
            log.error("不是任务信息");
            return;
        }