JAVA 实践项目 --- 树莓派信息自动化采集后入库项目 (五)

项目源代码可访问我的 github：https://github.com/Spacider/Gather-and-store
如果觉得好的话请给个 star 哦~

开发 IDE： IDEA 2018.03 JDK 1.8
开发环境： macOS 10.13.6 （如 windows 请对项目中部分路径进行改写）
数据库: Oracle 11g

第四阶段：发送给我们的服务端，并进行入库操作

这一阶段我们的任务就是接收上节客户端发送的对象数据，并且在分析以后把数据写入数据库！

此层项目结构为：

接下来，看代码：
1.编写一个 EnvServer 接口，其中有个抽象方法，作用就是接收各个客户端发送过来的集合对象：

/**
 * 服务器端模块
 */
public interface EnvServer extends WossModel  {
    /**
     * 接收各个客户端发送过来的集合对象 Collection(Environment)
     */
    void receive();
}
​

新创建一个实现包为 Impl ，创建实现类 EnvServerImpl，其中实现了 receive 方法，在写 receive 方法之前，我们先定义一个线程来接收，运用线程可以很好的体现"持续性"读取的特点。

class EnvServerThread extends Thread {

    private Socket socket;
    public EnvServerThread (Socket socket){
        this.socket = socket；
    }
}
​

使用构造器把 socket 对象传入！这样我们就可以在线程类中操作流来接收我们需要的数据了!

is = socket.getInputStream();
ois = new ObjectInputStream(is);
List <Environment> environmentList = (List <Environment>) ois.readObject();
​

获取到我们的输入流时，直接将其包装成对象流(上文发过来的时候使用对象流发送)，故我们可以通过 readObject 方法来得到我们上文从客户端发过来的对象！

之后 receive 方法可以这么写：

/**
     * 服务器接收方法
     */
    public void receive() {
        Socket socket = null;

        try {
            ServerSocket server = new ServerSocket(port);
            logger.info("server 启动"+ server);
            while(true){
                socket = server.accept();
                new EnvServerThread(socket).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
​

运行 EnvServerImpl 类和 ClientMain 类和 DataServer 类，在服务端的线程中打印对象数组，在看见数组并且数组正确时，就说明你这一部分写对了！

2.在获得对象以后我们需要对数组进行入库操作：
编写接口

/**
 * 入库模块
 */
public interface DBStore extends WossModel {
    /**
     * 把服务器接收到的数据写入到数据库中持久保存
     * 注意数据的录入是按天进行录入的
     * t_s ---> 拆分成多张表
     * 20/5 取余数
     * t_s0 t_s1 t_s2 t_s3 t_s4
     * @param col
     */
    void saveEnvToDB(Collection<Environment> col);
}
​

数据库操作自然会用到 jdbc！为了方便编写一个数组库的操作类，里边包含各种关于数据库的操作：
此处，请记得修改你的文件路径，第二记得修改文件中的内容，修改为你对应数据库的链接信息！
这个和一般网上所写的都差不多，就直接贴代码了：

/**
 * 数据库处理帮助类
 * 书写关于数据库的一些操作方法，比如 获取连接对象 、 封装插入方法
 */
public class DBhelper {

    // dhcp 缓冲池对象
    private static BasicDataSource DATA_SOURCE;

    static {
        Properties properties = new Properties();
        FileInputStream fis = null;
        try {
            fis = new FileInputStream(new File("/Users/wjh/Desktop/FirstProject/src/main/resources/config.properties"));
            properties.load(fis);

            // 通过读取 properties 文件来初始化 DATA_SOURCE
            DATA_SOURCE = new BasicDataSource();
            DATA_SOURCE = BasicDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            IOUtil.close(fis);
        }
    }

    /**
     * 获取 Connection 连接对象
     * @return
     */
    public static Connection getConnction(){
        Connection connection = null;
        try {
            connection = DATA_SOURCE.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return connection;
    }

    /**
     * 处理 SQL 语句方法
     * @param sql
     */
    public static void ExecuteSql(String sql){
        Connection connection = getConnction();
        PreparedStatement ps = null;

        try {
            ps = connection.prepareStatement(sql);
            ps.execute();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (ps != null) {
                    ps.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

​

之后我们就可以写入库的实现类 DBStoreImpl 了
通过我们刚才写的数据库操作类来获得一个数据库链接：

 Connection connection = DBhelper.getConnction();

​

之后就是对对象的拆分并通过 PreparedStatement 来对 sql 语句进行预加载，把对应的数据存入：

for (Environment environment : col) {
                DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
                Timestamp timestamp = environment.getGather_date();
                String tsStr = sdf.format(timestamp);
                // gather_date=2018-09-15 11:17:48.0

                String[] time = tsStr.split("\\-");
                String day = time[2];

                // 拼接 sql 语句
                String sql = "insert into T_DETAIL_" + day
                        + " values(?,?,?,?,?,?,?,?,?,?)";

                ps = connection.prepareStatement(sql);

                ps.setString(1,environment.getName());
                ps.setString(2,environment.getSrcID());
                ps.setString(3,environment.getDstID());
                ps.setString(4,environment.getDevID());
                ps.setString(5,environment.getSensorAddress());
                ps.setInt(6,environment.getCount());
                ps.setInt(7,environment.getCmd());
                ps.setString(8,environment.getData()+"");
                ps.setInt(9,environment.getStatus());
                ps.setTimestamp(10,environment.getGather_date());
​

接下来是对数组运行的处理，这里采用了缓存机制，等待 count 为 100 条的整数倍时再运行响应的 sql 语句，当 sql 语句较多时可以减少大量 sql 等待的场景。

ps.addBatch();

if ( count % 100 == 0 ) {
      ps.executeBatch();
  }
  count ++;
​

实现了入库的操作之后在 EnvServerImpl 类的线程类中加入如下一行，
把数据递交给入库类处理：

// 数据库入库操作
dbStore.saveEnvToDB(environmentList);
​

最后，运行 EnvServerImpl 类和 ClientMain 类和 DataServer 类，看到提示信息，并发现数据库内有我们需要的数据的时候，就完成了当前部分的编写！