[转帖]weblogic集群节点监控_Tomcat, WebLogic及J2EE讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛_联动北方技术论坛  
网站首页 | 关于我们 | 服务中心 | 经验交流 | 公司荣誉 | 成功案例 | 合作伙伴 | 联系我们 |
联动北方技术论坛-国内领先的Weblogic、Tuxedo中间件技术论坛
联动北方-国内领先的云技术服务提供商
»  游客             当前位置：  论坛首页 »  自由讨论区 »  Tomcat, WebLogic及J2EE讨论区 »
总帖数
1
每页帖数
101/1页1
返回列表
0
发起投票  发起投票 发新帖子
查看: 4251 | 回复: 0   主题： [转帖]weblogic集群节点监控        下一篇 
dwx8023
注册用户
等级：上尉
经验：612
发帖：114
精华：0
注册：2011-11-8
状态：离线
发送短消息息给dwx8023 加好友    发送短消息息给dwx8023 发消息
发表于： IP：您无权察看 2011-11-10 15:34:54 | [全部帖] [楼主帖] 楼主

由于项目需要，对weblogic集群做监控，并定时采集系统中队列执行时长、各节点占用内存
等情况。
第一步：获取MBeanHome

Java代码

  1. import javax.naming.Context; 
  2. import javax.naming.NamingException; 
  3. import weblogic.jndi.Environment; 
  4. import weblogic.management.MBeanHome; 
  6. publicclass WebLogicBeanHome 
  7. { 
  8.       private MBeanHome mBeanHome; 
  9.        
  10.       privatestaticfinal WebLogicBeanHome home = new WebLogicBeanHome(); 
  11.        
  12.       private WebLogicBeanHome() 
  13.        { 
  14.              init(); 
  15.        } 
  16.        
  17.       privatevoid init() 
  18.        { 
  19.              Environment environment = new Environment(); 
  20.              environment.setProviderUrl("t3://localhost:7001"); 
  21.              environment.setSecurityPrincipal("weblogic"); 
  22.              environment.setSecurityCredentials("weblogic"); 
  23.              Context context; 
  24.             try
  25.              { 
  26.                    context = environment.getInitialContext(); 
  27.                    mBeanHome = (MBeanHome) context.lookup(MBeanHome.ADMIN_JNDI_NAME); 
  28.              } 
  29.             catch(NamingException e) 
  30.              { 
  31.                    e.printStackTrace(); 
  32.              } 
  33.             catch(Exception ex) 
  34.              { 
  35.                    ex.printStackTrace(); 
  36.              } 
  37.        } 
  38.        
  39.       publicstatic WebLogicBeanHome getInstance() 
  40.        { 
  41.             return home; 
  42.        } 
  43.        
  44.       public MBeanHome getMBeanHome() 
  45.        { 
  46.             return mBeanHome; 
  47.        } 
  48.        
  49.       public String getServerName() 
  50.        { 
  51.             return mBeanHome.getMBeanServer().getServerName(); 
  52.        } 
  53.        
  54.       public String getDomainName() 
  55.        { 
  56.             return mBeanHome.getDomainName(); 
  57.        } 
  58.        
  59.       public Set getMBeansByType(String type) 
  60.        { 
  61.             if(type == null || type.trim().length() == 0) 
  62.              { 
  63.                   returnnull; 
  64.              } 
  65.             else
  66.              { 
  67.                   try
  68.                    { 
  69.                         return mBeanHome.getMBeansByType(type); 
  70.                    } 
  71.                   catch(Exception e) 
  72.                    { 
  73.                          e.printStackTrace(); 
  74.                          init(); 
  75.                         return mBeanHome.getMBeansByType(type); 
  76.                    } 
  77.              } 
  78.        } 
  79.        
  80.       public Set getAllMBeans() 
  81.        { 
  82.             return mBeanHome.getAllMBeans(); 
  83.        } 
  84. } 


import javax.naming.Context;
import javax.naming.NamingException;
import weblogic.jndi.Environment;
import weblogic.management.MBeanHome;

public class WebLogicBeanHome
{
       private MBeanHome mBeanHome;

       private static final WebLogicBeanHome home = new WebLogicBeanHome();

       private WebLogicBeanHome()
       {
             init();
       }

       private void init()
       {
             Environment environment = new Environment();
             environment.setProviderUrl("t3://localhost:7001");
             environment.setSecurityPrincipal("weblogic");
             environment.setSecurityCredentials("weblogic");
             Context context;
             try
             {
                   context = environment.getInitialContext();
                   mBeanHome = (MBeanHome) context.lookup(MBeanHome.ADMIN_JNDI_NAME);
             }
             catch(NamingException e)
             {
                   e.printStackTrace();
             }
             catch(Exception ex)
             {
                   ex.printStackTrace();
             }
       }

       public static WebLogicBeanHome getInstance()
       {
             return home;
       }

       public MBeanHome getMBeanHome()
       {
             return mBeanHome;
       }

       public String getServerName()
       {
             return mBeanHome.getMBeanServer().getServerName();
       }

       public String getDomainName()
       {
             return mBeanHome.getDomainName();
       }

       public Set getMBeansByType(String type)
       {
             if(type == null || type.trim().length() == 0)
             {
                   return null;
             }
             else
             {
                   try
                   {
                         return mBeanHome.getMBeansByType(type);
                   }
                   catch(Exception e)
                   {
                         e.printStackTrace();
                         init();
                         return mBeanHome.getMBeansByType(type);
                   }
             }
       }

       public Set getAllMBeans()
       {
             return mBeanHome.getAllMBeans();
       }
}



第二步：将集群各节点状态信息构造成ServiceNode对象

Java代码

  1. import java.util.ArrayList; 
  2. import java.util.Iterator; 
  3. import java.util.List; 
  4. import java.util.Set; 
  6. import com.huawei.netforce.server.common.ExecuteQueue; 
  7. import com.huawei.netforce.server.common.ServiceNode; 
  8. import com.huawei.netforce.server.home.WebLogicBeanHome; 
  10. import weblogic.management.runtime.ExecuteQueueRuntimeMBean; 
  11. import weblogic.management.runtime.ExecuteThread; 
  12. import weblogic.management.runtime.JVMRuntimeMBean; 
  13. import weblogic.management.runtime.ServerRuntimeMBean_Stub; 
  15. publicclass ServerRuntime 
  16. { 
  17.       publicstaticfinal String RUNNING = "RUNNING"; 
  18.        
  19.       privatestaticfinal ServerRuntime server = new ServerRuntime(); 
  20.       
  21.       private ServerRuntime() 
  22.        { 
  23.             
  24.        } 
  25.       
  26.       publicstatic ServerRuntime getInstance() 
  27.        { 
  28.             return server; 
  29.        } 
  30.       
  31.       /** 
  32.        * 建造集群节点信息 
  33.        * @param set 
  34.        * @return 
  35.        */
  36.       public List buildServer(Set set) 
  37.        { 
  38.              List list = new ArrayList(); 
  39.             if(set == null) 
  40.             return list; 
  41.              Iterator it = set.iterator(); 
  42.             
  43.             while(it.hasNext()) 
  44.              { 
  45.                    ServerRuntimeMBean_Stub stub = (ServerRuntimeMBean_Stub) it.next(); 
  46.                    ServiceNode node = new ServiceNode(); 
  47.                   //节点名称 
  48.                    node.setName(stub.getName()); 
  49.                   //节点地址 
  50.                    node.setHost(stub.getListenAddress()); 
  51.                   //节点端口 
  52.                    node.setPort(String.valueOf(stub.getListenPort())); 
  53.                   //节点状态 
  54.                    node.setStatus(stub.getState()); 
  55.                   //节点当前可用内存 
  56.                    node.setFreeHeap(getJVMCurrentFreeHeap(stub)); 
  57.                   //节点总内存 
  58.                    node.setTotalHeap(getJVMCurrentHeapSize(stub)); 
  59.                   //节点总队列数 
  60.                    node.setQueueTotal(getExecuteQueueRuntime(stub).getExecuteThreadTotalCount()); 
  61.                   //节点当前占用队列数 
  62.                    node.setQueueUsed(node.getQueueTotal() - getExecuteQueueRuntime(stub).getExecuteThreadCurrentIdleCount()); 
  63.                   //节点队列详细列表 
  64.                    buildExcuteQueues(node, getExecuteQueueRuntime(stub).getExecuteThreads()); 
  65.                    list.add(node); 
  66.              } 
  67.             return list; 
  68.        } 
  69.        
  70.       /** 
  71.        * 建造队列线程信息 
  72.        * 
  73.        * @param eths 
  74.        */
  75.       privatevoid buildExcuteQueues(ServiceNode node, ExecuteThread[] eths) 
  76.        { 
  77.             if(eths == null) 
  78.              { 
  79.                   return; 
  80.              } 
  81.             for(int i = 0; i < eths.length; i++) 
  82.              { 
  83.                    ExecuteThread eThread = eths[i]; 
  84.                   if(eThread.getCurrentRequest() == null || "".equals(eThread.getCurrentRequest()) || "null".equals(eThread.getCurrentRequest())) 
  85.                    { 
  86.                         continue; 
  87.                    } 
  88.                    ExecuteQueue queue = new ExecuteQueue(); 
  89.                    queue.setNumber(i); 
  90.                    queue.setName(eThread.getName()); 
  91.                   //队列请求地址URL 
  92.                    queue.setRequest(eThread.getCurrentRequest()); 
  93.                   //队列请求时间 
  94.                    queue.setStartTime(eThread.getCurrentRequestStartTime()); 
  95.                    queue.setTotal(eThread.getServicedRequestTotalCount()); 
  96.                    node.add(queue); 
  97.              } 
  98.        } 
  99.       
  100.       public Set getServerRuntimes() 
  101.        { 
  102.             return WebLogicBeanHome.getInstance().getMBeansByType(Constant.ServerRuntime); 
  103.        } 
  104.       
  105.       privateboolean isStoped(ServerRuntimeMBean_Stub mBean) 
  106.        { 
  107.             return !RUNNING.equalsIgnoreCase(mBean.getState()); 
  108.        } 
  109.       
  110.       private JVMRuntimeMBean getJVMRuntime(ServerRuntimeMBean_Stub mBean) 
  111.        { 
  112.             return mBean.getJVMRuntime(); 
  113.        } 
  114.        
  115.       private ExecuteQueueRuntimeMBean getExecuteQueueRuntime(ServerRuntimeMBean_Stub mBean) 
  116.        { 
  117.             return mBean.getExecuteQueueRuntime(); 
  118.        } 
  119.       
  120.       privatelong getJVMCurrentFreeHeap(ServerRuntimeMBean_Stub mBean) 
  121.        { 
  122.             return getJVMRuntime(mBean).getHeapFreeCurrent(); 
  123.        } 
  124.       
  125.       privatelong getJVMCurrentHeapSize(ServerRuntimeMBean_Stub mBean) 
  126.        { 
  127.             return getJVMRuntime(mBean).getHeapSizeCurrent(); 
  128.        } 
  129.       
  130.       private String getOSVersion(ServerRuntimeMBean_Stub mBean) 
  131.        { 
  132.             return getJVMRuntime(mBean).getOSVersion(); 
  133.        } 
  134.       
  135.       private String getOSName(ServerRuntimeMBean_Stub mBean) 
  136.        { 
  137.             return getJVMRuntime(mBean).getOSName(); 
  138.        } 
  139.       
  140.       private String getJavaVersion(ServerRuntimeMBean_Stub mBean) 
  141.        { 
  142.             return getJVMRuntime(mBean).getJavaVersion(); 
  143.        } 
  144.       
  145.       private String getJavaVendor(ServerRuntimeMBean_Stub mBean) 
  146.        { 
  147.             return getJVMRuntime(mBean).getJavaVendor(); 
  148.        } 
  149. } 


import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Set;

import com.huawei.netforce.server.common.ExecuteQueue;
import com.huawei.netforce.server.common.ServiceNode;
import com.huawei.netforce.server.home.WebLogicBeanHome;

import weblogic.management.runtime.ExecuteQueueRuntimeMBean;
import weblogic.management.runtime.ExecuteThread;
import weblogic.management.runtime.JVMRuntimeMBean;
import weblogic.management.runtime.ServerRuntimeMBean_Stub;

public class ServerRuntime
{
       public static final String RUNNING = "RUNNING";

       private static final ServerRuntime server = new ServerRuntime();

       private ServerRuntime()
       {

       }

       public static ServerRuntime getInstance()
       {
             return server;
       }

       /**
       * 建造集群节点信息
       * @param set
       * @return
       */
       public List buildServer(Set set)
       {
             List list = new ArrayList();
             if(set == null)
             return list;
             Iterator it = set.iterator();

             while(it.hasNext())
             {
                   ServerRuntimeMBean_Stub stub = (ServerRuntimeMBean_Stub) it.next();
                   ServiceNode node = new ServiceNode();
                   //节点名称
                   node.setName(stub.getName());
                   //节点地址
                   node.setHost(stub.getListenAddress());
                   //节点端口
                   node.setPort(String.valueOf(stub.getListenPort()));
                   //节点状态
                   node.setStatus(stub.getState());
                   //节点当前可用内存
                   node.setFreeHeap(getJVMCurrentFreeHeap(stub));
                   //节点总内存
                   node.setTotalHeap(getJVMCurrentHeapSize(stub));
                   //节点总队列数
                   node.setQueueTotal(getExecuteQueueRuntime(stub).getExecuteThreadTotalCount());
                   //节点当前占用队列数
                   node.setQueueUsed(node.getQueueTotal() - getExecuteQueueRuntime(stub).getExecuteThreadCurrentIdleCount());
                   //节点队列详细列表
                   buildExcuteQueues(node, getExecuteQueueRuntime(stub).getExecuteThreads());
                   list.add(node);
             }
             return list;
       }

       /**
       * 建造队列线程信息
       *
       * @param eths
       */
       private void buildExcuteQueues(ServiceNode node, ExecuteThread[] eths)
       {
             if(eths == null)
             {
                   return;
             }
             for(int i = 0; i < eths.length; i++)
             {
                   ExecuteThread eThread = eths[i];
                   if(eThread.getCurrentRequest() == null || "".equals(eThread.getCurrentRequest()) || "null".equals(eThread.getCurrentRequest()))
                   {
                         continue;
                   }
                   ExecuteQueue queue = new ExecuteQueue();
                   queue.setNumber(i);
                   queue.setName(eThread.getName());
                   //队列请求地址URL
                   queue.setRequest(eThread.getCurrentRequest());
                   //队列请求时间
                   queue.setStartTime(eThread.getCurrentRequestStartTime());
                   queue.setTotal(eThread.getServicedRequestTotalCount());
                   node.add(queue);
             }
       }

       public Set getServerRuntimes()
       {
             return WebLogicBeanHome.getInstance().getMBeansByType(Constant.ServerRuntime);
       }

       private boolean isStoped(ServerRuntimeMBean_Stub mBean)
       {
             return !RUNNING.equalsIgnoreCase(mBean.getState());
       }

       private JVMRuntimeMBean getJVMRuntime(ServerRuntimeMBean_Stub mBean)
       {
             return mBean.getJVMRuntime();
       }

       private ExecuteQueueRuntimeMBean getExecuteQueueRuntime(ServerRuntimeMBean_Stub mBean)
       {
             return mBean.getExecuteQueueRuntime();
       }

       private long getJVMCurrentFreeHeap(ServerRuntimeMBean_Stub mBean)
       {
             return getJVMRuntime(mBean).getHeapFreeCurrent();
       }

       private long getJVMCurrentHeapSize(ServerRuntimeMBean_Stub mBean)
       {
             return getJVMRuntime(mBean).getHeapSizeCurrent();
       }

       private String getOSVersion(ServerRuntimeMBean_Stub mBean)
       {
             return getJVMRuntime(mBean).getOSVersion();
       }

       private String getOSName(ServerRuntimeMBean_Stub mBean)
       {
             return getJVMRuntime(mBean).getOSName();
       }

       private String getJavaVersion(ServerRuntimeMBean_Stub mBean)
       {
             return getJVMRuntime(mBean).getJavaVersion();
       }

       private String getJavaVendor(ServerRuntimeMBean_Stub mBean)
       {
             return getJVMRuntime(mBean).getJavaVendor();
       }
}



第三步：处理集群节点状态数据

Java代码

  1. import java.util.ArrayList; 
  2. import java.util.List; 
  4. import org.quartz.Job; 
  5. import org.quartz.JobExecutionContext; 
  6. import org.quartz.JobExecutionException; 
  8. import com.huawei.netforce.server.Handler; 
  9. import com.huawei.netforce.server.ServerRuntime; 
  10. import com.huawei.netforce.server.common.ServiceNode; 
  11. import com.huawei.netforce.server.handlers.LogHandler; 
  12. import com.huawei.netforce.server.handlers.MsgHandler; 
  14. publicclass ServerRuntimeJob implements Job 
  15. { 
  16.       privatestatic List handlers = new ArrayList(); 
  17.        
  18.       static
  19.        { 
  20.             //短信处理 如内存不足、队列堵塞等情况发送告警短信 
  21.              handlers.add(new MsgHandler()); 
  22.             //日志处理 如将执行时间较长的队列记录日志，定期优化 
  23.              handlers.add(new LogHandler()); 
  24.        } 
  25.        
  26.       //quartz定时执行 一般为5分钟执行一次 
  27.       publicvoid execute(JobExecutionContext arg0) throws JobExecutionException 
  28.        { 
  29.              ServerRuntime runtime = ServerRuntime.getInstance(); 
  30.              
  31.              List list = runtime.buildServer(runtime.getServerRuntimes()); 
  32.             try
  33.              { 
  34.                    processServerNode(list); 
  35.              } 
  36.             catch(Exception e) 
  37.              { 
  38.                    e.printStackTrace(); 
  39.              } 
  40.        } 
  41.       
  42.       //处理集群各服务节点状态数据 
  43.       privatevoid processServerNode(List list) throws Exception 
  44.        { 
  45.              ServiceNode node = null; 
  46.             for(int i = 0; i < list.size(); i++) 
  47.              { 
  48.                    node = (ServiceNode)list.get(i); 
  49.                    handle(node); 
  50.              } 
  51.        } 
  52.        
  53.       //handles链中的各Handle分别处理 
  54.       privatevoid handle(ServiceNode node) throws Exception 
  55.        { 
  56.             for(int i = 0; i < handlers.size(); i++) 
  57.              { 
  58.                    Handler handler = (Handler)handlers.get(i); 
  59.                    handler.handle(node); 
  60.              } 
  61.        } 
  62. } 


赞(0)    操作        顶端 
总帖数
1
每页帖数
101/1页1
返回列表
发新帖子
请输入验证码： 点击刷新验证码
您需要登录后才可以回帖 登录 | 注册
技术讨论

Weblogic中间件技术论坛

 |

Tuxedo中间件技术论坛

 |

数据库论坛

 |

Java论坛

 |

Linux/unix论坛

 |

网站地图


Powered by LandingBJ     @ 2008-2018     联动北方   
京ICP证号090597    京ICP备案09017624号    京公网安备110112000093号    
400-810-2327     Email：service@landingbj.com   

Powered by landingbj @ 2008-2015 联动北方
京ICP证号090597 京ICP备案09017624号 京公网安备110112000093号
86-27-87056338 Email：service@landingbj.com