package BaoWen;
|
import java.io.File;
|
import java.util.Vector;
|
|
import Method.BaoWenShow;
|
import Method.GetNowTime;
|
import Method.SaveFIleInTxt;
|
import tbDataModel.Baowen;
|
import tbDataModel_Dell.Dell_tb_suanfa2;
|
|
/**
|
* ´¦ÀíÔʼ±¨ÎÄ
|
* »ùÕ¾10ÃëÖÓ×Ô¶¯Æô¶¯Êý¾Ý
|
* BBF9D5BE49443A2037313239202E0D0ABBF9D5BEC0E0D0CD3A2042202E0D0AB5A5B4CECDA8D1B6BBF9D5BECAFDC1BF3A203130B8F62E0D0A
|
*/
|
public class Dell_baowen_55AA0C implements Runnable{
|
static int sleeptime = 1;
|
static Thread t;
|
static Vector<Baowen> baowenvec2 = new Vector<Baowen>();
|
static int a = 0;
|
static File file = SaveFIleInTxt.creatFilelog();
|
static int AAaa0cnum=1;
|
|
public static void intsert(String ip, String hex, String time, int port) {
|
AAaa0cnum++;
|
if(AAaa0cnum==5000000) {
|
AAaa0cnum=1;
|
}
|
Baowen baowen = new Baowen();
|
baowen.setHex(hex);
|
baowen.setIp(ip);
|
baowen.setAddtime(time);
|
baowen.setTimestamp(GetNowTime.timestamp());
|
baowen.setPort(port);
|
baowenvec2.add(baowen);
|
}
|
|
|
public static Vector<Baowen> getBaowenvec2() {
|
return baowenvec2;
|
}
|
|
/**
|
* ´¦ÀíÔʼ±¨ÎÄ
|
*/
|
public void dellhex() {
|
int size = baowenvec2.size();
|
if (size == 0) {
|
sleeptime =50;
|
return;
|
}
|
//Èç¹ûÊý¾Ý´óÓÚ10ÍòÌõûÓд¦ÀíÔòÇå¿Õ
|
if (size > 100000) {
|
baowenvec2.removeAllElements();
|
} else {
|
sleeptime =1;//20230708yang
|
Baowen baowen0 = baowenvec2.get(0);
|
String ip = baowen0.getIp();
|
int port = baowen0.getPort();
|
String hex = baowen0.getHex();
|
String time = baowen0.getAddtime();
|
int timestamp = baowen0.getTimestamp();
|
dell2(ip,port,hex,time,timestamp);//2023.07.08yang
|
baowenvec2.remove(baowen0);//2023.07.08yang
|
}
|
}
|
|
public static void dell2(String ip,int port,String hex,String time,int timestamp) {
|
Have_Yuanshi_Do.Dell_yuanshi(ip, hex, time);
|
if (hex.startsWith("55AA0C")) {
|
BaoWenShow.ok("2", "55AA0C", hex, ip, "´¦ÀíÔʼ±¨ÎÄ");
|
Dell_55AA0C.dell(ip, time, hex, timestamp, port);
|
}
|
if(Dell_tb_suanfa2.isJnalog_open()){
|
SaveFIleInTxt.save_jiexibaowen(hex, file);
|
}
|
}
|
|
|
/**
|
* Æô¶¯Ï̵߳ķ½·¨
|
*/
|
public void startThread() {
|
t = new Thread(this);
|
t.start();
|
}
|
|
public void run() {
|
while (true) {
|
try {
|
dellhex();
|
synchronized (this){//·ÀÖ¹ÆäËûÏ̵߳÷ÓüÓÉÏͬ²½Ëø 2023.07.17 zsh
|
Thread.sleep(sleeptime);//ÐÝÃßʱ¼ä
|
}
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
|
public static int getAAaa0cnum() {
|
return AAaa0cnum;
|
}
|
|
//´òÓ¡ÈÕÖ¾
|
public static File getFile() {
|
return file;
|
}
|
|
|
|
}
|