4.1原始文件制作器（RawMaker.jar）
主要用来接收来自socket中的讯息，并将它解码，分割写入磁碟中，它是始终的无条件的运行的，不受程式其他模块的干扰，也不要求有对齐或其他解析功能。它生成后缀名为raw的文件并保存在raw文件夹下。
我们先定义一个位元组转换方法，用于将两个byte 拼接成一个short
public static short byteTransform(byte a,byte b) {
return (short) ((a << 8)| (0x00FF & b));}
另外，容器也是必不可少的，用来作为buffer保存我们的数据
public static byte[] itb(InputStream in) throws IOException{
ByteArrayOutputStream outStream = new ByteArrayOutputStream();
byte[] data = new byte[1204];
int count = -1;
int MaxWaitTimes=0;
while(((count = in.read(data,0,1204)) != -1)&&MaxWaitTimes<1) {
outStream.write(data, 0, count);
MaxWaitTimes++;}
data = null;
return outStream.toByteArray();
}
}
记录单个文件中的short数据数目，把它的初始值设为350*1202，是希望它第一次就能进入初始化文件的操作流程，它会在初始化后重新变为0
int rawRecCounter=350*1202;
全局计数器，记录当前的档案名称，有控制文件回圈记录的功能
int rawRecGlobalCounter=-1;
BufferedWriter out = null;
开启Socket管道
Socket s = new Socket(“140.110.141.23”,23000);
InputStream is = s.getInputStream();
我们的接收工作原则上不会停止，所以是while让它永远执行
while(true){
检测是否要建立一个新的文件，如果计数器表明已经产生了所有测站1秒的数据则新建立一个文件。
if(rawRecCounter>=350*1202) {
一个新的文件建立了，我们把计数器清零。
rawRecCounter=0;
如果全局计数器大于等于100，则让它为0，覆蓋100秒前的数据文件。
if(rawRecGlobalCounter>=99+1) {rawRecGlobalCounter=0;}else{System.out.println(“[Info]Making raw file “+(rawRecGlobalCounter+1)+”.raw”);
新建或覆蓋全局计数器指定的文件
rawRecGlobalCounter++;}
新建文件对象，它等于全局计数器的名称
File writename = new File(“raw”+File.separator+rawRecGlobalCounter+”.raw”);
新建文件
writename.createNewFile();
获取输出缓存
out = new BufferedWriter(new FileWriter(writename));}
将is流中的数据一行一行传入byte数组，方便之后的分析。
byte[] bytes = itb(is);
我们现在对单行byte数据进行处理
for(int i=0;i<bytes.length;i=i+2) {
把后面的byte和前面的byte粘贴，组成一个short
out.write(byteTransform(bytes[i+1],bytes[i])+” “);
当前文件记录的short数自增
rawRecCounter++;}
刷新缓存
out.flush();}}
至此，我们完成对于原始scoket数据包到原始文件的转换过程。
4.2处理器（Handle.jar）
主要用来解析制作器生成的文件，将混杂着预警资讯的所有测站（单秒）原始文件，解析分割到各自测站的文件资讯中，它可以创建并修改文件，并有一定的客观纠错功能（覆蓋写入）。同时它也控制着单个测站保存数据的最大值，避免磁盘空间溢出。
处理器承载这用户网页的显示和我们软体内部的显示，由于提供给用户的数据没有经过过滤和处理，所以速度会比较快。在这里，我们会忽略软体内部的文件处理方法，只讲述给用户流览器的呈现方法，因为方法是及其类似，而网页处理的过程相对简单。
首先我们需要一个文件处理计数器，用于标识我们处理到第几个文件，和制作器配合，初始数值范围是0到9999，当达到9999时，自动变为0，防止文件过多积压磁片和int形变量溢出。
int rawHandleController=0;
我们需要不停的处理制作器的资讯，所以是无限回圈
while(true) {
System.out.println(“[Info]Analyzing raw file “+rawHandleController+”.raw”);
生成一个文件对象，它将在之后读取制作器的预处理文件，使用separator方法是为了相容系统路径在Linux的使用。
File file = new File(“raw”+File.separator+rawHandleController+”.raw”);
检查文件存在性，通过与else配合，如果文件不存在，我们会让系统等待两秒之后再做检查，通常文件不存在是由于处理器先于制作器启动，或制作器在写入数据时发生延缓，这类情况通常较少出现
if(file.exists()) {
承载容器，接纳制作器生成的全部文本内容，供之后分析。
int[] a = getLineFromTxt(file,” “);
预先声明3个int形数组，他们将在之后承载单个文件
单个测站的xyz轴讯息。每个轴有100个资料。
int xData[] =new int[100];int yData[] =new int[100];int zData[] =new int[100];
这里记录的时测站编号，因为我们是通过之后的长度和时间来定位数据的，这时候测站编号已经被解析，我们需要一个变数来保存测站的编号，给以后使用。
int site=0;
遍历文件容器中的每一个数据，1200为安全边界，防止在解析到测站编号和时间后测站资讯不完整。
for(int i = 0; i< a.length-1200; i++){
如果我们解析到一个1200的数据且它的后面跟了一个正确的年份，我们则认为它是一个测站资讯的开始。我们可以再细化时间检查来提高它的准确度，但根据实际检测情况，这样的检查已经够用了，目前没有差错报告。
if(a[i]==1200&&a[i+3]==2018&&i<a.length-1200) {
回溯一个数据，将其记录在变数site中。
site=a[i-1];
这一组数据记录和控制写入在单个测站单轴的数组位置。
int xCounter=0;int yCounter=0;int zCounter=0;
根据具体要求，我们解析全文数据的102位（正文数据的100位），到数据包结束
for(int j=102;j<=601;j++) {
其中，每组数据（5个）有两个是我们不需要的,我们把它舍弃，只留下需要的部分
if(j%5==2) {xData[xCounter]=a[i+j];xCounter++;}if(j%5==3) {yData[yCounter]=a[i+j];yCounter++;}
if(j%5==4) {zData[zCounter]=a[i+j];zCounter++;}}
调用方法将数据写入，方法的形式参数分别是测站编号，x轴数据，y轴数据，z轴数据
createHtmlContext(site,xData,yData,zData);}}}else{
如果文件没有找到就等待两秒
System.out.println(“[Err]Cannot found file “+rawHandleController+”.raw!”);
Thread.sleep(2000);}
文件处理计数器自增，准备处理下一个文件
rawHandleController++;
处理完文件后，就删除它防止混淆。
if(file.exists()) {file.delete();}
当文件积累到10000个时，就重新从0开始计
if(rawHandleController>=99) {rawHandleController=0;}}}
文本处理函数，因为文件都是单行结构，所以只读一行即可。
public static int[] getLineFromTxt(File file, String split) throws Exception{
BufferedReader br = new BufferedReader(new FileReader(file));
String firstLine = br.readLine(); String[] arrs = firstLine.split(” “);int[] arr = new int[arrs.length];
for(int i = 0; i< arr.length; i++){arr[i] = Integer.parseInt(arrs[i]);}if(br!= null){br.close();br = null;}return arr;}
这个方法生成html，实际上是生成js脚本，生成的脚本和现有网页相互连接，完成了我们在流览器中的显示。
public static void createHtmlContext(int a,int xData[],int yData[],int zData[]) throws Exception{
这里原本有错误写入机制，后来因为速度原因被删除。这里一组数据用于接收单个测站以前的数据，加上新的数据后重新写入文件
String xDataFromHtml = “”;String yDataFromHtml = “”;String zDataFromHtml = “”;
创建一个文件对象，准备写入数据，它实际上是一个脚本供前端调用
File f = new File(“handled”+File.separator+a+”.js”);
如果单个测站数据文件不存在，我们需要新建一个js文件
if(!f.exists()) {
创建一个新的文件
f.createNewFile();
创建输出流
BufferedWriter out = new BufferedWriter(new FileWriter(f));
逐步拼接出符合要求的js文件，将数据添加到其中
这里是新文件的制作过程，它是一个网页数组的格式
out.write(“var arr1 = [“);for(int i=0;i<xData.length;i++) {out.write(xData[i]+”,”);}
out.write(“]; var arr2 = [“);for(int i=0;i<yData.length;i++) {out.write(yData[i]+”,”);}
out.write(“]; var arr3 = [“);for(int i=0;i<zData.length;i++) {out.write(zData[i]+”,”);}
out.write(“];”);out.flush();out.close();}else {
如果文件不存在，创建输出流。
BufferedReader br = new BufferedReader(new FileReader(f));
读取原来的文件，因为是单行结构，所以只读一行即可
String res = br.readLine();
创建正则运算式并匹配，意图抽取原来文件中X轴的数据
Pattern p1=Pattern.compile(“var arr1 = \\[(((\\w*|-\\w*),)*)\\]; var arr2 = \\[“);
Matcher m1=p1.matcher(res);
如果有匹配到if(m1.find()){
将匹配到的值也就是原来文件X轴的数值赋值给xDataFromHtml
xDataFromHtml= m1.group(1);
如果xDataFromHtml的长度大于1000，即有10秒以上的数据资讯，则清空
if(xDataFromHtml.length()>100*10) {xDataFromHtml=””;}
将我们新的数据拼接在原来数据的后面
for(int i=0;i<xData.length;i++) {xDataFromHtml+=xData[i]+”,”;}}
下面两组代码是匹配Y轴的数据，和X轴是类似的，但是注意，他们的正则运算式是不同的
Pattern p2=Pattern.compile(“\\]; var arr2 = \\[(((\\w*|-\\w*),)*)\\]; var arr3 = \\[“);
Matcher m2=p2.matcher(res);
if(m2.find()){yDataFromHtml= m2.group(1);
if(yDataFromHtml.length()>100*10) {yDataFromHtml=””;}
for(int i=0;i<yData.length;i++) {yDataFromHtml+=yData[i]+”,”;}}
下面两组代码是匹配Z轴的数据，和X轴是类似的，但是注意，他们的正则运算式是不同的
Pattern p3=Pattern.compile(“\\]; var arr3 = \\[(((\\w*|-\\w*),)*)\\];”);
Matcher m3=p3.matcher(res);if(m3.find()){
zDataFromHtml= m3.group(1);
if(zDataFromHtml.length()>100*10) {zDataFromHtml=””;}
for(int i=0;i<zData.length;i++) {zDataFromHtml+=zData[i]+”,”;} }
BufferedWriter out = new BufferedWriter(new FileWriter(f));
将最后的保存资讯写入硬碟
out.write(“var arr1 = [“);
out.write(xDataFromHtml);
out.write(“]; var arr2 = [“);out.write(yDataFromHtml);out.write(“]; var arr3 = [“);out.write(zDataFromHtml);out.write(“];”);out.flush();out.close();} }
我们再稍微提一下我们再软体内部文件处理时候，所运用的方法。
String xDataBuffer=””;String yDataBuffer=””;String zDataBuffer=””;Date d=new Date();String filepathPrefix=”handled”+File.separator+a+File.separator+(d.getYear()+1900)+File.separator+
d.getMonth()+File.separator+d.getDate()+File.separator+d.getHours()+File.separator+d.getMinutes()+File.separator;for(int i=0;i<xData.length;i++) {xDataBuffer=xData[i]+”,”;}for(int i=0;i<yData.length;i++) {yDataBuffer=yData[i]+”,”;}for(int i=0;i<zData.length;i++) {zDataBuffer=zData[i]+”,”;}txtTools.appTxt(xDataBuffer,filepathPrefix+”x.txt”);txtTools.appTxt(yDataBuffer, filepathPrefix+”y.txt”);txtTools.appTxt(zDataBuffer, filepathPrefix+”z.txt”);
可以发现，原理是类似的，只是转成了对于txt的操作。
4.3错误处理记录器（ErrHandle.jar）（已分拆）
会实时监控文件的生成情况，系统的占用情况。
儅缓存积压达到域值暂停制作器或儅文件异常暂停处理器，致命性错误重启系统并记录。同时记录对测站的访问和操作情况。由于此模块耗费大量的系统资源，并不适用于这个实时性要求比较高的程式，故取消了这个模块，同时将这个模块的重要功能分拆在其他模块中。
4.4单测站数据文件（xxxx.js）
处理器最终生成文件是一个javascript脚本，保存在handled文件夹下，封装了最后的结果（实时更新），前端用户在递交请求时，同时会请求这个js文件，将内容一并发送给客户端（浏览器）。这里我们再改版中将他移动到了用户UI中。
4.5前端用户交互文件组（index.html,xxxx.html等多项文件）
最顶级的交互页面由index.html支撑，用户选择测站后会带领进入相应的测站html。
4.6用户动作捕捉
原则上来说，我们应该制作大量的按钮，但是由于原始按钮都不太美观，而每个按钮添加图片和定位又显得耗时耗力，于是，我们使用相关滑鼠位置捕捉。
首先我们对于每个父容器的点击行为进行定位
contentPane.addMouseListener(new MouseAdapter() {@Override
public void mouseClicked(MouseEvent e) {checkPoint(e.getXOnScreen(),e.getYOnScreen());}});
请注意，我们定义了一个checkPoint方法，接下来我们来讲解它。
可以看出，我们是将按钮看作一个矩形，对其范围进行检测，当用户有点击事件时检测是否在这个区域。
private void checkPoint(int x,int y) {if(ptc(x,y,1498,190,1699,256)) {//do something}}
private boolean ptc(int x,int y,int a,int b,int c,int d) {if(x>=a&&x<=c&&y>=b&&y<=d) {return true;}else{return false;}}
4.7用户主介面
实际上介面设计的代码很多，我们将其全部忽略，只讲述我们认为重要的核心代码
获取一个时间的实例化类。
Date d=new Date();
我们可以看到，这里主要是配合制作器去找寻文件。它会去寻找一个当前时间的文件，它是制作器保存的，然后我们直接拿来用，将它显示在我们的面板中。
String filepathPrefix=”handled”+File.separator+nr.getText()+File.separator+(d.getYear()+1900)+File.separator+d.getMonth()+File.separator+d.getDate()+File.separator+d.getHours()+File.separator;
然而，如何定义当前时间呢，我们有定义，当用户查询时间不到当前分钟的30秒，我们会去获取上一分钟的数据，如果当前分钟已经过了30秒，我们获取当前分钟的数据。
if(d.getSeconds()>30){filepathPrefix+=d.getMinutes()+File.separator;}else{filepathPrefix+=(d.getMinutes()-1)+File.separator;}String filepath=””;
用户查询XYZ轴中的哪一个就去找那个文件
switch(axid) {case 0:filepath=filepathPrefix+”x.txt”;break;case 1:filepath=filepathPrefix+”y.txt”;break;case 2:filepath=filepathPrefix+”z.txt”;break;}
try {File f=new File(filepath);String data=””;
如果文件存在我们就读取它
if(f.exists()) {data=txtTools.readTxt(filepath);
但是我们的系统尚未正式部署，所以时常遇到没有找到文件的情况，此时用乱数代替
}else{for(int i=0;i<100;i++) {data+=(((int)(Math.random()*6))-3)+”,”;}}
4.8数据点抽象技术
我们的数据量很大，如果全部显示，显然是不现实的，但有时候，由于特殊情况我们的数据量有比较小，所以，我们无法给出一个固定值。我们需要对全部的点进行统计，给出一个适当的值，使得最终数据点不超过100个。
String outData=””;if(data.length()>100) {String temp[]=data.split(“,”);
int m=(int)(data.length()/100)-1;if(m==0) {m=1;}
for(int i=0;i<((int)(temp.length/m))-1;i++) {outData+=temp[i*m]+”,”;}
}else {outData=data;}
String title=nr.getText()+”测站在”+(d.getYear()+1900)+”年”+d.getMonth()+”月”+d.getDate()+”日”+d.getHours()+”时”+d.getMinutes()+”分的地震监测数据”;
showChat(title,outData);
这里我们用到了图表绘制，我们将在下一个小结进行讨论。
4.9图表绘制技术
对于这个软体，我们使用jfreechart来完成我们的图表绘制，它必须要提供一个数据集，然后对表格进行定义，但是到目前位置，我尚未找到合适的融合方法。同样的，我们省略大量的代码，只留下核心的。
定义表格显示方法public static void showChat(String title,String hourDataChain) {
创建一个标准表格StandardChartTheme mChartTheme = new StandardChartTheme(“”);
定义主题ChartFactory.setChartTheme(mChartTheme);
定义数据集CategoryDataset mDataset = GetDataset(dataChain);
创建JFreeChart mChart = ChartFactory.createLineChart();
定义数据集public static CategoryDataset GetDataset(String dataChain)
分隔原数据oneData=hourDataChain.split(“,”);
添加到数据集mDataset.addValue(Integer.parseInt(onerData[i]), “震幅”, “”+i);}
4.10设置修改与提交
我们在软体中会有大量的数据提交，但是我们不会在显示类中直接处理用户参数的变更，而是将它拷贝为两份，其中一份直接保存在内存，另一份传入硬碟，以确保用户在掉电后仍然可以在下次启动时获得他需要的设置，我们有多个设置文件，它们在使用时会拼接成一个完整的指令串。
首先我们创建一个文本文件
String sa=txtTools.readTxt(“data/settingA.txt”);
然后我们需要获取用户的所有填入参数并和原本的参数进行逐个比较，如果有不一致的再进行更改。String[] sp=sa.split(“,”);
String[] np=new String[] {t1.getText(),t2.getText(),t3.getText(),t4.getText(),t5.getText()”};
for(int i=0;i<18;i++) {if((!””.equals(np[i]))&&!sp[i].equals(np[i])) {sp[i]=np[i];}}String as=””;
for(int i=0;i<18;i++) {as+=sp[i]+”,”;}para.execOnce=0;para.userSetting=as+para.userSetting;
txtTools.writeTxt(as, “data/settingA.txt”);note(“更改提交”,”已提交您的更改！”);
4.11垃圾回收
我们在上一个步骤设定了参数，那么如何将他们应用在我们的垃圾回收中，其实原理比较简单。
首先我们获取整体运行开关，它是整个的开关
if(para.isreleaseCanWork==1) {
获取日期参数
Date d=new Date();
如果这几个设置参数不是-1的话，因为我们设置-1就是让这个选项失效 if(Integer.parseInt(ua[6])!=-1&&Integer.parseInt(ua[7])!=-1&&Integer.parseInt(ua[8])!=-1) {
首先是单次时间验证，就是检测用户设置的时间是否等于现在的时间，如果等于，就删掉指定测站的内容。 if(d.getHours()==Integer.parseInt(ua[6])&&d.getMinutes()==Integer.parseInt(ua[7])) {del(ua[3]);}}
下面几句是回圈执行语句，因为我们的release本身就是回圈执行的，所以我们不用加另外的回圈。我们将之前执行的时间和现在的时间进行比较，如果发现差距比用户设定的时间小，我们就执行删除指令，同时更新上次执行时间。 if(Integer.parseInt(ua[9])!=-1&&Integer.parseInt(ua[10])!=-1&&Integer.parseInt(ua[11])!=-1) {
int timec=Integer.parseInt(ua[9])*3600+Integer.parseInt(ua[10])*60+Integer.parseInt(ua[11]);
intnowtime=d.getHours()*3600+d.getMinutes()*60+d.getSeconds();if(nowtime-para.lasttime>timec) {del(ua[3]);}}
单次执行和上面的做法相似，就不再赘述。 if(Integer.parseInt(ua[12])!=-1&&Integer.parseInt(ua[13])!=-1&&Integer.parseInt(ua[14])!=-1&&Integer.parseInt(ua[15])!=-1) {if(d.getYear()+1900==Integer.parseInt(ua[12])&&d.getMonth()==Integer.parseInt(ua[13])&&d.getDate()==Integer.parseInt(ua[14])&&d.getHours()==Integer.parseInt(ua[15])) {para.execOnce=1;
del(ua[3]);}}
4.12测站资料搜寻
所有测站的资料被事先保存在一个siteNames文件中，它使用全局参数，同样，他的每个参数都用@分隔，这样在之后的处理中，我们就获得了一个新的数组，在数组之间搜寻可以比较快的找到资料，比如我们需要测站的消息，那么它一定的4的倍数，同样区域就是4的倍数加一。例如在主介面有这样的定义：
我们获取所有测站的全部资料
String ast[]=siteNames.allSiteList.split(“@”);for(int i=0;i<ast.length;i++) {和我们的选择进行对比，可以知道我们选的是区域，然后前进2位就是编号，后退两位就是纬度。
if(ast[i].equals(ne.getSelectedItem())) {nr.setText(ast[i-2]);gx.setText(ast[i+1]);gy.setText(ast[i+2]);}
4.13资料库技术
资料库本该使用一个类进行复用处理，但我们使用每个定制化的查询节省时间，首先我们需要获得一个连接实例。我们直接使用连接桥进行连接。
Class.forName(“com.mysql.cj.jdbc.Driver”);Connectionconn= DriverManager.getConnection(“jdbc:mysql://”+para.ip+”:”+para.port+para.remotePath, ” “, ” ” );
然后我们需要定制几个查询与更新方法。
比如我们支持透过姓名和手机号找人，这里我们写出通过姓名找人的方法。
public static String searchByName(String username) throws Exception {
Connection conn=init();String result = “”;PreparedStatement cmd=conn.prepareStatement(“select * from eqr where name='”+username+”‘;”);ResultSet set=cmd.executeQuery();while (set.next()) {result+= set.getInt(“id”)+”,”; result+= set.getString(“name”)+”,”;result+= set.getString(“card”)+”,”;result+= set.getString(“phone”)+”,”;}
set.close();conn.close();return result;}
再比如我们的修改密码的方法：
public static boolean update(String username,String password) throws Exception {
首先检测想要修改的用户是否存在
String tempQueryResult=query(username);if(tempQueryResult!=null) {
获得连接和执行语句。
Connection conn=init();PreparedStatement psql;
进行sql执行
psql = conn.prepareStatement(“update eqr set password = ‘”+password+”‘ where name='”+username+”‘;”);psql.executeUpdate();return true;}else {return false; }}
4.14设置解析与模型实践
我们通过时间来分隔我们需要保存的文件，这一点在之前已经讲过Date d=new Date();
我们取出记忆体中用户所有的设置，并设置文件案名String ua[]=para.userSetting.split(“,”);String filepathPrefix=”handled”+File.separator+a+File.separator+(d.getYear()+1900)+File.separator+d.getMonth()+File.separator+d.getDate()+File.separator+d.getHours()+File.separator+d.getMinutes()+File.separator;for(int i=0;i<xData.length;i++) {
首先实现我们的单点测量，取出各种参数和流过的每个数据进行比较和测算
if(ua[18].length()==4) {if(a==Integer.parseInt(ua[18])) {if(xData[i]>=Integer.parseInt(ua[20])) {
if(para.reqCount<Integer.parseInt(ua[19])) {para.reqCount++;}else {new sendAlert().sendBySite((a+””));para.reqCount=0;}} }}
多点测量和但点类似，但是由于我们是多个测站，所以需要再加一个回圈，比较所有测站的运行情况。我们定义测站的参数应该大于等于4，因为就算一个测站也应该有4个单位长度if(ua[21].length()>=4) {String[] sitesub=ua[21].split(“,”);for(int j=0;j<sitesub.length;j++) {if(a==Integer.parseInt(sitesub[j])) {if(xData[i]>=Integer.parseInt(ua[23])) {if(para.reqCount<Integer.parseInt(ua[22])) {para.reqCount++;}else {new sendAlert().sendBySite(a+””);para.reqCount=0;}}} } }
我们的设置中运行用户执行一些动作，那么这些动作我们会直接调用系统指令。 if(“1”.equals(ua[24])) {exec(“shutdown -s -t 30”);}else if(“2”.equals(ua[24])) {exec(“”);}
4.15灾害特色短信
我们运行用户自定义灾难指令字串，同样，这是保存在数组中的，它的形式是这样的public static String areaRep=”RB-100,RB-100MSG,RB-101,RB-101MSG”前者保存室内区域，后者保存区域内发生地震的短信提醒，然后，当出发地震时，我们去资料库检索所有该区域用户的手机号码，直接发送短信。我们有查询手机号码的定义：
首先获取连接Connection conn=init();String result = “”;
写入查询语句String sql=”select * from eqr where area='”+area+”‘;”;
执行查询语句PreparedStatement cmd=conn.prepareStatement(sql);
获得结果ResultSet set=cmd.executeQuery();while (set.next()) {result+= set.getString(“phone”)+”,”;}
关闭连接set.close(); conn.close();return result;