Merge pull request #377 from jerry-sc/monitor-bug

fix the monitor bug which the spider will terminate when a seed url with port

webmagic-core/src/main/java/us/codecraft/webmagic/utils/UrlUtils.java

@@ -83,6 +83,15 @@ public class UrlUtils {
         return domain;
     }
 
+    public static String removePort(String domain) {
+        int portIndex = domain.indexOf(":");
+        if (portIndex != -1) {
+            return domain.substring(0, portIndex);
+        }else {
+            return domain;
+        }
+    }
+
     /**
      * allow blank space in quote
      */

webmagic-extension/src/main/java/us/codecraft/webmagic/monitor/SpiderMonitor.java

@@ -6,6 +6,7 @@ import us.codecraft.webmagic.Request;
 import us.codecraft.webmagic.Spider;
 import us.codecraft.webmagic.SpiderListener;
 import us.codecraft.webmagic.utils.Experimental;
+import us.codecraft.webmagic.utils.UrlUtils;
 
 import javax.management.*;
 import java.lang.management.ManagementFactory;
@@ -103,7 +104,8 @@ public class SpiderMonitor {
     }
 
     protected void registerMBean(SpiderStatusMXBean spiderStatus) throws MalformedObjectNameException, InstanceAlreadyExistsException, MBeanRegistrationException, NotCompliantMBeanException {
-        ObjectName objName = new ObjectName(jmxServerName + ":name=" + spiderStatus.getName());
+//        ObjectName objName = new ObjectName(jmxServerName + ":name=" + spiderStatus.getName());
+        ObjectName objName = new ObjectName(jmxServerName + ":name=" + UrlUtils.removePort(spiderStatus.getName()));
         mbeanServer.registerMBean(spiderStatus, objName);
     }
 

webmagic-extension/src/test/java/us/codecraft/webmagic/monitor/SeedUrlWithPortTest.java

+package us.codecraft.webmagic.monitor;
+
+import org.junit.Test;
+import us.codecraft.webmagic.Page;
+import us.codecraft.webmagic.Site;
+import us.codecraft.webmagic.Spider;
+import us.codecraft.webmagic.processor.PageProcessor;
+
+import javax.management.JMException;
+
+/**
+ * @author jerry_shenchao@163.com
+ */
+public class SeedUrlWithPortTest {
+
+    @Test
+    public void testSeedUrlWithPort() throws JMException {
+        Spider spider = Spider.create(new TempProcessor()).addUrl("http://www.hndpf.org:8889/");
+        SpiderMonitor.instance().register(spider);
+        spider.run();
+    }
+}
+
+class TempProcessor implements PageProcessor {
+
+    @Override
+    public void process(Page page) {
+
+    }
+
+    @Override
+    public Site getSite() {
+        return Site.me();
+    }
+}