posts - 155,  comments - 601,  trackbacks - 0
有段时间没有更新了,今天上来与大家打声招呼先。Spy2servers这个项目自发布以来,受到不少的朋友支持,在此表示感谢。
经过一段时间的整理,现已经把整个项目转移到了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


posted on 2008-05-05 22:49 x.matthew 阅读(1673) 评论(2)  编辑  收藏 所属分类: Spy2Servers

只有注册用户登录后才能发表评论。


网站导航: