| (原创)基于组件化的监控平台开发监控(更新: 支持Annotation) |
 |
| 作者是 x.matthew | |
| 2008-05-06 07:42:20 | |
|
经过一段时间的整理，现已经把整个项目转移到了SourceForge。目前的网址为 https://sourceforge.net/projects/spy2servers 希望大家能依旧大力支持。 言归正转，此次更新主要是支持Annotation,用于简单Spring的xml配置 此处下载 提供三种Annotation支持，分别 @SpyComponent @AlertComponent和@MessageAlertChannelActiveAwareComponent 我们在上篇文章中应用Spy2servers组件接口简单演示了接口开发的实现。下面改成基于Annotation，让我们从配置中解放出来 下面是实现的代码，与原先的方法区别，就是使用了Annotation 1 package org.xmatthew.mypractise;
2 3 import org.xmatthew.spy2servers.annotation.AlertComponent; 4 import org.xmatthew.spy2servers.core.AbstractAlertComponent; 5 import org.xmatthew.spy2servers.core.Message; 6 7 /** 8 * @author Matthew Xie 9 * 10 */ 11 @AlertComponent(name = "myAlertComponent") 12 public class SimpleAlertComponet extends AbstractAlertComponent{ 13 14 private boolean started; 15 16 @Override 17 protected void onAlert(Message message) { 18 if (started) { 19 System.out.println(message); 20 } 21 } 22 23 public void startup() { 24 25 started = true; 26 setStatusRun(); 27 28 } 29 30 public void stop() { 31 started = false; 32 setStatusStop(); 33 34 } 35 36 } 1 /**
2 * 3 */ 4 package org.xmatthew.mypractise; 5 6 import java.util.Collections; 7 import java.util.LinkedList; 8 import java.util.List; 9 10 import org.xmatthew.spy2servers.core.AbstractComponent; 11 import org.xmatthew.spy2servers.core.MessageAlertChannel; 12 import org.xmatthew.spy2servers.core.MessageAlertChannelActiveAwareComponent; 13 14 /** 15 * @author Matthew Xie 16 * 17 */ 18 @org.xmatthew.spy2servers.annotation.MessageAlertChannelActiveAwareComponent(name = "SimpleChannelAwareComponent") 19 public class SimpleChannelAwareComponent extends AbstractComponent implements 20 MessageAlertChannelActiveAwareComponent { 21 22 private boolean started; 23 24 private List<MessageAlertChannel> channels = Collections.synchronizedList(new LinkedList<MessageAlertChannel>()); 25 26 public List<MessageAlertChannel> getChannels() { 27 return channels; 28 } 29 30 public void onMessageAlertChannelActive(MessageAlertChannel channel) { 31 if (!started) { 32 return; 33 } 34 channels.add(channel); 35 printChannel(channel); 36 } 37 38 public void startup() { 39 started = true; 40 setStatusRun(); 41 42 } 43 44 public void stop() { 45 started = false; 46 setStatusStop(); 47 48 } 49 50 private void printChannel(MessageAlertChannel channel) { 51 if (channel != null) { 52 System.out.println("channel aware component say:"); 53 System.out.print("spyComponent is: "); 54 System.out.println(channel.getSpyComponent()); 55 System.out.print("alertComponent is: "); 56 System.out.println(channel.getAlertComponent()); 57 System.out.print("message is: "); 58 System.out.println(channel.getMessage()); 59 } 60 } 61 62 63 } 64 1 /**
2 * 3 */ 4 package org.xmatthew.mypractise; 5 6 import java.util.Date; 7 import java.util.UUID; 8 9 import org.xmatthew.spy2servers.annotation.SpyComponent; 10 import org.xmatthew.spy2servers.core.AbstractSpyComponent; 11 import org.xmatthew.spy2servers.core.Message; 12 13 /** 14 * @author Matthew Xie 15 * 16 */ 17 @SpyComponent(name = "mySpyComponent") 18 public class SimpleSpyComponent extends AbstractSpyComponent { 19 20 private boolean started; 21 22 /* (non-Javadoc) 23 * @see org.xmatthew.spy2servers.core.Component#startup() 24 */ 25 public void startup() { 26 started = true; 27 setStatusRun(); 28 try { 29 while (started) { 30 onSpy(createMessage()); 31 Thread.sleep(5000); 32 } 33 } catch (Exception e) { 34 e.printStackTrace(); 35 } 36 } 37 38 private Message createMessage() { 39 Message message = new Message(); 40 message.setId(UUID.randomUUID().toString()); 41 message.setCreateDate(new Date()); 42 message.setDescription("message sent by " + getName()); 43 message.setLevel(Message.LV_INFO); 44 message.setType("Test Message"); 45 return message; 46 } 47 48 public void stop() { 49 started = false; 50 setStatusStop(); 51 52 } 53 54 } 55 接下来，我们看一下配置文档 spy2servers.xml.简洁了很多 <?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.xmatthew.org/spy2servers/schema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:beans="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:util="http://www.springframework.org/schema/util" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.xmatthew.org/spy2servers/schema http://www.xmatthew.org/spy2servers/schema/spy2servers-1.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"> <annotation-driven /> <context:component-scan base-package="org.xmatthew.mypractise"/> <core-component> <!-- 配置核组件，这个必须要有 --> <simple-alertRule> <!-- 配置 消息报警机制--> <channel> <from value="mySpyComponent"/> <to value="myAlertComponent"/> </channel> </simple-alertRule> </core-component> <jmxService-component/> <!-- 开启jmx监控服务，其IP通过 java启动命令设置 默认为1616 --> <jetty> <!-- 配置内置服务器 --> <connectors> <nioConnector port="7758" /> <!-- using nio connector port is 7758 --> </connectors> <handlers> <!-- 配置内置基于web 方式的平台组件监控 servlet context为 /admin --> <servlet servletClass="org.xmatthew.spy2servers.component.web.ComponentsViewServlet" path="/admin" /> </handlers> </jetty> </beans:beans> 我们看到使用Annoation后，让配置部分精简了很多。 如有什么问题希望大家给我留言。 Good Luck! Yours Matthew! 2008年5月5日 22:48:32 |
|
| 最近更新 ( 2008-05-06 07:42:20 ) |
