在学习SmartFrame框架时，发现一段IOC控制的代码有点意思，于是摘下来。

public class IocHelper {

    static {
        try {
            // 获取并遍历所有的 Bean 类
            Map, Object> beanMap = BeanHelper.getBeanMap();
            for (Map.Entry, Object> beanEntry : beanMap.entrySet()) {
                // 获取 Bean 类与 Bean 实例
                Class beanClass = beanEntry.getKey();
                Object beanInstance = beanEntry.getValue();
                // 获取 Bean 类中所有的字段（不包括父类中的方法）
                Field[] beanFields = beanClass.getDeclaredFields();
                if (ArrayUtil.isNotEmpty(beanFields)) {
                    // 遍历所有的 Bean 字段
                    for (Field beanField : beanFields) {
                        // 判断当前 Bean 字段是否带有 Inject 注解
                        if (beanField.isAnnotationPresent(Inject.class)) {
                            // 获取 Bean 字段对应的接口
                            Class interfaceClass = beanField.getType();
                            // 获取 Bean 字段对应的实现类
                            Class implementClass = findImplementClass(interfaceClass);
                            // 若存在实现类，则执行以下代码
                            if (implementClass != null) {
                                // 从 Bean Map 中获取该实现类对应的实现类实例
                                Object implementInstance = beanMap.get(implementClass);
                                // 设置该 Bean 字段的值
                                if (implementInstance != null) {
                                    beanField.setAccessible(true); // 将字段设置为 public
                                    beanField.set(beanInstance, implementInstance); // 设置字段初始值
                                } else {
                                    throw new InitializationError("依赖注入失败！类名：" + beanClass.getSimpleName() + "，字段名：" + interfaceClass.getSimpleName());
                                }
                            }
                        }
                    }
                }
            }
        } catch (Exception e) {
            throw new InitializationError("初始化 IocHelper 出错！", e);
        }
    }

    /**
     * 查找实现类
     */
    public static Class findImplementClass(Class interfaceClass) {
        Class implementClass = interfaceClass;
        // 判断接口上是否标注了 Impl 注解
        if (interfaceClass.isAnnotationPresent(Impl.class)) {
            // 获取强制指定的实现类
            implementClass = interfaceClass.getAnnotation(Impl.class).value();
        } else {
            // 获取该接口所有的实现类
            List> implementClassList = ClassHelper.getClassListBySuper(interfaceClass);
            if (CollectionUtil.isNotEmpty(implementClassList)) {
                // 获取第一个实现类
                implementClass = implementClassList.get(0);
            }
        }
        // 返回实现类对象
        return implementClass;
    }
}

1.创建项目使用org.apache.maven.archetype:maven-archetype-webapp 如下。

2.在pom.xml中加入Tomcat7的插件

   webapi
   
        
            org.apache.tomcat.maven
            tomcat7-maven-plugin
            2.1
            
                8080
                /
                UTF-8
                tomcat7
            
        
    

3.在配置中的命令行中选择，tomcat7:run项。


4.在run菜单中启用调试。

5.其它方式调试

import org.apache.zookeeper.*;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.data.Stat;

import java.util.concurrent.CountDownLatch;

class DataMonitor implements Watcher, AsyncCallback.StatCallback{
    public ZooKeeper zk = null;
    private int i = 0;
    public int iexistcheck = 0;
    public DataMonitor(){

    }

    public void process(WatchedEvent event) {
        String path = event.getPath();
        System.out.println("process: iexistcheck="+iexistcheck+" - "+"i:="+i+",path:"+path+" - state:" + event.getState());
        i++;
    }

    public void processResult(int rc, String path, Object ctx, Stat stat) {
        System.out.println("processResult.1:iexistcheck="+iexistcheck+" - "+"i:="+i+",rc:" + rc + " - path:"+path+" - state:" + stat);
        try {
            System.out.println("processResult.2.getData:iexistcheck="+iexistcheck+" - "+"i:="+i+" - "+new String(zk.getData("/test", false, null)));
        }catch (Exception e){
            System.out.print("processResult.3:exception.....iexistcheck="+iexistcheck+" - "+"i:="+i);
        }finally {
            System.out.println("processResult.4:iexistcheck="+iexistcheck+" - "+"i:="+i+",end......end......end..");
        }
    }
}

public class ZooKeeperTest {

    private static CountDownLatch downLatch = new CountDownLatch(1);
    private static final int TIME_OUT = 300000;
    private static final String HOST = "localhost:2181";
    public static void main(String[] args) throws Exception{
        DataMonitor dm = new DataMonitor();
        ZooKeeper zookeeper = new ZooKeeper(HOST, TIME_OUT, dm);
        dm.zk = zookeeper;
        zookeeper.exists("/test", true, dm, dm);
        Stat stat =  null;
        for(int i = 0; i < 30; i++){
            String buf = "value="+i;
            System.out.println("loop i="+i);
            if(zookeeper.exists("/test", false) == null)
            {
                //PERSISTENT_SEQUENTIAL模式情况下，真正路径是从返回值获取。其格式为/test0000000028。
                //EPHEMERAL模式下，该节点是临时节点，当超时或session断开时，它也跟随着消失。适合检验机器岩机与否等状态。防单点或执备切换等。
                String node_real = zookeeper.create("/test", "znode1".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
                System.out.println("nodename:"+node_real);
            }
            //第三个参数为版本号，当前输入的版本号与目标版本的版本号是相同的情况，才能更新到数据。否则会更新失败。
            if(stat == null){
                stat = zookeeper.setData(node_real, buf.getBytes() , -1);
            }else{
                stat = zookeeper.setData(node_real, buf.getBytes() , stat.getVersion());
            }
            System.out.println("Czxid:" + stat.getCzxid() + " - Mzxid:" + stat.getMzxid() + " - Version:" + stat.getVersion());
            if(i > 5){
                if(i % 3 == 0){
                    dm.iexistcheck = i;
                    zookeeper.exists("/test", true, dm, dm);
                }
            }
            Thread.sleep(1000);
        }
        zookeeper.delete("/test", -1);
        Thread.sleep(5000);
        zookeeper.close();
    }
}

			org.apache.zookeeper
        		zookeeper
        		3.4.8
        		
            			
                			com.sun.jmx
                			jmxri
            			
            			
					com.sun.jdmk
                			jmxtools
            			
            			
                			javax.jms
                			jms
            			
        		
        	

loop i=0
process: iexistcheck=0 - i:=0,path:null - state:SyncConnected
processResult.1:iexistcheck=0 - i:=1,rc:-101 - path:/test - state:null
processResult.3:exception.....iexistcheck=0 - i:=1processResult.4:iexistcheck=0 - i:=1,end......end......end..
process: iexistcheck=0 - i:=1,path:/test - state:SyncConnected
Czxid:1055 - Mzxid:1056 - Version:1
loop i=1
Czxid:1055 - Mzxid:1057 - Version:2
loop i=2
Czxid:1055 - Mzxid:1058 - Version:3
loop i=3
Czxid:1055 - Mzxid:1059 - Version:4
loop i=4
Czxid:1055 - Mzxid:1060 - Version:5
loop i=5
Czxid:1055 - Mzxid:1061 - Version:6
loop i=6
Czxid:1055 - Mzxid:1062 - Version:7
processResult.1:iexistcheck=6 - i:=1,rc:0 - path:/test0000000029 - state:1055,1062,1480343483194,1480343489294,7,0,0,0,7,0,1055

processResult.2.getData:iexistcheck=6 - i:=1 - value=6
processResult.4:iexistcheck=6 - i:=1,end......end......end..
loop i=7
process: iexistcheck=6 - i:=1,path:/test0000000029 - state:SyncConnected
Czxid:1055 - Mzxid:1063 - Version:8
loop i=8
Czxid:1055 - Mzxid:1064 - Version:9
loop i=9
Czxid:1055 - Mzxid:1065 - Version:10
processResult.1:iexistcheck=9 - i:=2,rc:0 - path:/test0000000029 - state:1055,1065,1480343483194,1480343492344,10,0,0,0,7,0,1055

processResult.2.getData:iexistcheck=9 - i:=2 - value=9
processResult.4:iexistcheck=9 - i:=2,end......end......end..