Mobai
/
magic-Dependency
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add control for monitor

master
yihua.huang 2014-04-26 11:44:14 +08:00
parent 2770811a10
commit 04fde8203b
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -52,6 +52,8 @@ public class SpiderMonitor {
private Type type = Type.Local; private Type type = Type.Local;
private JMXConnectorServer jmxConnServer;
private List<SpiderStatusMXBean> spiderStatuses = new ArrayList<SpiderStatusMXBean>(); private List<SpiderStatusMXBean> spiderStatuses = new ArrayList<SpiderStatusMXBean>();
public List<SpiderStatusMXBean> getSpiders() { public List<SpiderStatusMXBean> getSpiders() {
@ -214,7 +216,7 @@ public class SpiderMonitor {
JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://" + jndiServer + ":" + rmiPort + "/" + jmxServerName); JMXServiceURL url = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://" + jndiServer + ":" + rmiPort + "/" + jmxServerName);
System.out.println("JMXServiceURL: " + url.toString()); System.out.println("JMXServiceURL: " + url.toString());
System.out.println("Please replace localhost of your ip if you want to connect it in remote server."); System.out.println("Please replace localhost of your ip if you want to connect it in remote server.");
JMXConnectorServer jmxConnServer = JMXConnectorServerFactory.newJMXConnectorServer(url, null, localServer); jmxConnServer = JMXConnectorServerFactory.newJMXConnectorServer(url, null, localServer);
jmxConnServer.start(); jmxConnServer.start();
} }
@ -222,6 +224,8 @@ public class SpiderMonitor {
objName = new ObjectName(jmxServerName + ":name=" + spiderStatus.getName()); objName = new ObjectName(jmxServerName + ":name=" + spiderStatus.getName());
localServer.registerMBean(spiderStatus, objName); localServer.registerMBean(spiderStatus, objName);
} }
objName = new ObjectName(jmxServerName + ":name=WebMagicMonitor");
localServer.registerMBean(jmxConnServer, objName);
return this; return this;
} }