自定义监听器监听数据库中数据的变化

此程序只是一个简单的例子，主要监听数据库中Location的数据。

先写一个Event继承EventObject

Java代码  


package com.lbx.listong.servlet;  
  
import java.util.EventObject;  
  
public class LocationEvent extends EventObject {  
      
    private static final long serialVersionUID = 1L;  
    private Object obj;  
  
    public LocationEvent(Object source) {  
        super(source);  
        obj = source;  
    }  
  
    public Object getSource(){  
        return obj;  
    }  
      
}  

 然后写一个接口继承EventListener

Java代码  


package com.lbx.listong.servlet;  
  
import java.util.EventListener;  
  
public interface LocationListener extends EventListener {  
      
    public void locationEvent(LocationEvent le);  
  
}  

 测试这个监听，实现他的接口

Java代码  


package com.lbx.listong.servlet;  
  
import java.util.concurrent.Executors;  
import java.util.concurrent.ScheduledExecutorService;  
import java.util.concurrent.TimeUnit;  
  
import com.lbx.listong.service.LocationService;  
import com.lbx.listong.thread.ListThread;  
  
public class TestLocationListener implements LocationListener {  
  
    private LocationService ls;  
  
    public TestLocationListener() {  
        ls = new LocationService();  
        ls.addLocationListener(this);                     //注册监听  
        System.out.println("添加监听器完毕");  
        try {  
            // 调用此方法触发事件,触发的事件就是执行locationEvent(接口的方法)的方法  
            ls.addLocation("insert into tb_location (companyId,mobile,longitude,latitude,locationTime) values(2,'444','4','4','2011-03-23 11:03:04')");  
        } catch (Exception ex) {  
            ex.printStackTrace();  
        }  
    }  
  
    @Override  
    public void locationEvent(LocationEvent le) {  
        // TODO Auto-generated method stub  
        ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();   
        executor.scheduleWithFixedDelay(new ListThread(), 0, 2, TimeUnit.SECONDS);  
    }  
  
}  

 LocationService的代码，主要是一些业务的代码，里面只写了增加一个记录触发一个事件

Java代码  


package com.lbx.listong.service;  
  
import java.sql.Connection;  
import java.sql.ResultSet;  
import java.sql.SQLException;  
import java.sql.Statement;  
import java.util.ArrayList;  
import java.util.Enumeration;  
import java.util.List;  
import java.util.Vector;  
  
import com.lbx.listong.DBUtil.DB;  
import com.lbx.listong.servlet.LocationEvent;  
import com.lbx.listong.servlet.LocationListener;  
import com.lbx.listong.servlet.TestLocationListener;  
  
public class LocationService {  
    private Connection conn = null;  
    List list = new ArrayList();  
    String sql = "select * from tb_location";  
    Statement st = null;  
  
    private Vector repository = new Vector();  
    private LocationListener ll;  
    public LocationService()  
    {  
    }  
    //注册监听器，如果这里没有使用Vector而是使用ArrayList那么要注意同步问题  
    public void addLocationListener(LocationListener ll)  
    {  
        repository.addElement(ll);//这步要注意同步问题  
    }  
    //如果这里没有使用Vector而是使用ArrayList那么要注意同步问题  
    public void notifyLocationEvent(LocationEvent event) {  
        Enumeration e = repository.elements();//这步要注意同步问题  
        while(e.hasMoreElements())  
        {  
          ll = (LocationListener)e.nextElement();  
          ll.locationEvent(event);  
        }  
    }  
    //删除监听器，如果这里没有使用Vector而是使用ArrayList那么要注意同步问题  
    public void removeLocationListener(LocationListener ll)  
    {  
        repository.remove(ll);//这步要注意同步问题  
    }  
      
    public List getLocationList(){  
        conn = DB.getConnection();  
        try {  
            st = conn.createStatement();  
            ResultSet rs = st.executeQuery(sql);  
            while(rs.next()){  
                String longitude = rs.getString("longitude");  
                list.add(longitude);  
            }  
        } catch (SQLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }   
        return list;  
    }  
      
    public void addLocation(String sql){  
        boolean b = false;  
        conn = DB.getConnection();  
        try {  
            st = conn.createStatement();  
            int id = st.executeUpdate(sql);  
            if(id>0){  
                b = true;  
            }  
        } catch (SQLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
        //添加一个记录成功就通知事件,然后执行接口的方法  
        if(b){  
            System.out.println("sss");  
            notifyLocationEvent(new LocationEvent(this));  
        }  
    }  
      
    public static void main(String[] args){  
        new TestLocationListener();  
    }  
}