电信采集之数据处理

package com.briup.util;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.List;
import java.util.Properties;

public class BackUPImpl implements BackUP {

    String filePath;
    Object object = null;
    private static List<BIDR> list;

    @Override
    public void init(Properties p) {
        // TODO Auto-generated method stub

    }

    // 通过键名获取已经备份的数据 key备份数据的键
    @Override
    public Object load(String key, boolean flag) throws Exception {
        // TODO Auto-generated method stub
        File file = new File(filePath, key);
        // file是否为空
        if (file.exists() && file.length() != 0) {
            ObjectInputStream ois = new ObjectInputStream(new FileInputStream(file));
            object = ois.readObject();
        }
        return object;

    }

    // 通过键名存储数据，key-备份数据的键，date-需要备份的数据，flag如果键值已经存在数据，追加还是覆盖之前的数据
    // 文件路径key
    @Override
    public void store(String key, Object date, boolean flag) throws Exception {
        // TODO Auto-generated method stub
        // 通过key找备份文件，键值就是文件名
        // 接收到完整数据
        File file = new File(key);
        if(file.exists()){
        ObjectOutputStream oos = new ObjectOutputStream(new FileOutputStream(file, flag));
        oos.writeObject(date);
        oos.flush();
        oos.close();
        
    }
    }

}

package com.briup.woss.client;

import java.io.*;
import java.net.Socket;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Properties;

import com.briup.util.BIDR;
import com.briup.util.Configuration;
import com.briup.woss.ConfigurationAWare;

public class ClientImpl implements Client{
   private static String id;
   private static int port;
  
    
    private static ObjectOutputStream oo;

    @Override
    public void init(Properties p) {
        // TODO Auto-generated method stub
        id=p.getProperty("id");//通过将依赖注入的方式将配置信息注入到该模块中
        port=Integer.parseInt(p.getProperty("port"));    
    }
    
     
    @Override
    public void send(Collection<BIDR> collection) throws Exception {
        //创建Socket指定ip地址端口号
        Socket socket=new Socket(id,port);
        //数据流
        OutputStream os=socket.getOutputStream();
        oo=new ObjectOutputStream(os);//将数据保存在对象流中,保存的是完全信息
        oo.writeObject(collection);
        System.out.println(collection);
        System.out.println(collection.size());
        oo.flush();
        oo.close();
        socket.close();
        
        
    // TODO Auto-generated method stub
    //1.id+port
    //2.数据流
        

    }


    
    }

package com.briup.woss.Server;
import java.io.*;
import java.net.*;
import java.util.Collection;
import java.util.List;
import java.util.Properties;
import com.briup.util.BIDR;
import com.briup.woss.server.Server;

public class ServrImpl implements Server{
    private ServerSocket ss;
    private int port;
    private ObjectInputStream oi;
    

    @Override
    public void init(Properties p) {
        // TODO Auto-generated method stub
        System.out.println(p.get("port"));
         port=Integer.parseInt((String) p.get("port"));
         System.out.println(port);
    
    }
    
    @SuppressWarnings("unchecked")
    @Override
    public Collection<BIDR> revicer() throws Exception {
        
        // TODO Auto-generated method stub
        //1.port
        //数据流
        //1)创建ServerSocket
        ss=new ServerSocket(port);
        System.out.println("服务器已启动，请连接·····");
        while(true){
        Socket s=ss.accept();
        oi=new ObjectInputStream(s.getInputStream());
        List<BIDR> c=(List<BIDR>)oi.readObject();
        System.out.println("连接成功");
        return c;
        }
        
        
    }

    @Override
    public void shutdown() {
        // TODO Auto-generated method stub
        
    }
    

    

}

package com.briup.util;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;

import org.dom4j.*;
import org.dom4j.io.SAXReader;

import com.briup.woss.ConfigurationAWare;
import com.briup.woss.WossModule;
import com.briup.woss.client.Client;
import com.briup.woss.client.Gather;
import com.briup.woss.server.DBStore;
import com.briup.woss.server.Server;

public class ConfigurationImpl implements Configuration{
    String filePath="src/com/briup/woss/File/conf.xml";
    //存入woss模块对象
    Map<String,WossModule> wossMap=new HashMap<>();
    //存放配置信息
    Properties pro=new Properties();
    @Override
    public BackUP getBackup() throws Exception {
        // TODO Auto-generated method stub
        return (BackUP) wossMap.get("backup");
    }

    @Override
    public Client getClient() throws Exception {
        // TODO Auto-generated method stub
        return (Client) wossMap.get("client");
    }

    @Override
    public DBStore getDBStore() throws Exception {
        // TODO Auto-generated method stub
        return (DBStore) wossMap.get("dbstore");
    }
    

    public static void main(String[] args) throws Exception {
        new ConfigurationImpl().getDBStore();
    }
    
    @Override
    public Gather getGather() throws Exception {
        // TODO Auto-generated method stub
        return (Gather) wossMap.get("gather");
    }
    

    @Override
    public Logger getLogger() throws Exception {
        // TODO Auto-generated method stub
        return (Logger) wossMap.get("logger");
    }


    @Override
    public Server getServer() throws Exception {
        return (Server) wossMap.get("server");
    }
    

    public ConfigurationImpl() {
        try {
        //1.获取解析器。读取conf.xml
           //创建SAXReader读取器，专门用于读取xml
        SAXReader saxReader=new SAXReader();
        //2.获取根节
            Document document=saxReader.read(filePath);
            
            Element rootElement=document.getRootElement();

            //3.获取子节点--属性值
            List elements=rootElement.elements();
            for(Object object:elements){
                Element e=(Element)object;
                String name=e.getName();
                //System.out.println("子节点"+name);
                //class
                String attValue=e.attributeValue("class");
//                System.out.println(attValue);
                //通过反射获取对象
                    WossModule woss;
                    try {
                        woss = (WossModule)Class.forName(attValue).newInstance();
//                        System.out.println(woss);
                        wossMap.put(name, woss);
//                        System.out.println(name);
                        for(String key:wossMap.keySet()){
//                            System.out.println(key+":"+wossMap.get(key));
                            
                            //4.固定值-->Properties
                            List ee=e.elements();
                            for(Object obj:ee){
                                Element el=(Element)obj;
                                String key1=el.getName();
                                String value=el.getText();
//                                System.out.println(key1);
//                                System.out.println(el.getName()+"*:*"+el.getText());
                                pro.put(key1, value);
                                String po=(String)pro.get("po");
                             //   System.out.println("po:**************");
                            //    System.out.println(po);   
                                
                            }
                            //配置信息依赖注入
                            for(Object obj:wossMap.values()){
                                //调用init（）方法，注入配置信息
                                if(obj instanceof WossModule){
                                    ((WossModule) obj).init(pro);
                                }
                                if(obj instanceof ConfigurationAWare){
                                    ((ConfigurationAWare)obj).setConfiguration(this);
                                }
                            }
                                
                        }

                    
                    } catch (ClassNotFoundException e1) {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                    }
                    //class--->实例化对象放入集合
               
                    
                    }
            
            
        } catch (Exception e2) {
            // TODO Auto-generated catch block
            e2.printStackTrace();
        }
        
            
            
        
        
        //固定值
        //class实例化对象放入集合
        
    }

}