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 baowenvec2 = new Vector(); 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 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; } }