异步队列名称

mooctest-site-server/src/main/java/cn/iselab/mooctest/site/configure/RabbitMQConfiguration.java

@@ -1,25 +1,23 @@
 package cn.iselab.mooctest.site.configure;
 
 import cn.iselab.mooctest.site.common.mqListener.AsyncToolMessageReceiver;
+import cn.iselab.mooctest.site.util.HostAddressUtils;
 import org.springframework.amqp.core.Queue;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-
-import java.util.UUID;
-
 /**
  * Created by tangshanshan on 2018/5/7.
  */
 @Configuration
 public class RabbitMQConfiguration {
 
-    public static final String JOB_RESULT_QUEUE = "jobResultQueue."+UUID.randomUUID().toString();
+    public static final String JOB_RESULT_QUEUE = "JobResult@"+HostAddressUtils.getHostHardwareAddress();
 
     @Bean
     @ConditionalOnExpression("${featureSwitch.server.enableRabbitListener}==true")
     public Queue jobResultQueue(){
-        return new Queue(JOB_RESULT_QUEUE,true,false,true);
+        return new Queue(JOB_RESULT_QUEUE,true,false,false);
     }
 
     @Bean

mooctest-site-server/src/main/java/cn/iselab/mooctest/site/util/HostAddressUtils.java

@@ -0,0 +1,34 @@
+package cn.iselab.mooctest.site.util;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.net.InetAddress;
+import java.net.NetworkInterface;
+import java.util.UUID;
+
+/**
+ * Created by tangshanshan on 2018/6/7.
+ */
+public class HostAddressUtils {
+
+    private Logger LOG = LoggerFactory.getLogger(getClass());
+
+    public static String getHostHardwareAddress() {
+        InetAddress ip;
+        try {
+            ip = InetAddress.getLocalHost();
+            NetworkInterface network = NetworkInterface.getByInetAddress(ip);
+            byte[] aMac = network.getHardwareAddress();
+            StringBuilder sbMac = new StringBuilder();
+            for (int i = 0; i < aMac.length; i++) {
+                sbMac.append(String.format("%02X%s", aMac[i], (i < aMac.length - 1) ? "-" : ""));
+            }
+            return sbMac.toString();
+
+        } catch (Exception e) {
+
+            return UUID.randomUUID().toString();
+        }
+    }
+}