@Override

@Transactional

public void analysisIPSLog() {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

SimpleDateFormat hmsdf = new SimpleDateFormat("HH:mm:ss");

List ipsLogPojoList = new ArrayList<>();

//从配置文件中读取服务器信息

ResourceBundle bundle = ResourceBundle.getBundle("config/ips_info");

String ip = bundle.getString("remote_ip");

int port = Integer.parseInt(bundle.getString("remote_port"));

String user = bundle.getString("remote_user");

String password = bundle.getString("remote_password");

String filePath = bundle.getString("remote_file_path");

Connection connection = null;

Session session = null;

InputStreamReader inputStreamReader=null;

BufferedReader bufferedReader=null;

try {

//采用ssh连接，获取连接对象

connection = FileUtils.getSSHConnection(ip, port, user, password);

if (connection != null) {

//执行ssh命令

String command = "tail -n +".concat(String.valueOf(pointer)).concat(" " + filePath);

session = connection.openSession();

session.execCommand(command);

InputStream sessionStdout = session.getStdout();

inputStreamReader = new InputStreamReader(sessionStdout);

bufferedReader = new BufferedReader(inputStreamReader);

//判断读取位置，在凌晨的时候，重置读取位置

String changePointer = hmsdf.format(new Date());

if (changePointer.contains("00:01")) {

pointer = 1L;

}

LOGGER.info("开始读取IPS日志文件，读取起始行位置【" + pointer + "】");

String str ;

while ((str = bufferedReader.readLine()) != null) {

String arrString[] = str.split(",");

if (arrString.length == 22) {//ips日志共计22个字段

IPSLogPojo ipsLogPojo = new IPSLogPojo();

ipsLogPojo.setCreateTime(sdf.format(new Date()));

ipsLogPojo.setStateCode("0");

ipsLogPojo.setIpslogTime(arrString[0]);

ipsLogPojo.setIpsSyslogId(arrString[1]);

ipsLogPojo.setIpsVSys(arrString[2]);

ipsLogPojoList.add(ipsLogPojo);

}

pointer++;

}

//将解析的数据入库

ipsLogDao.batchInsertData(ipsLogPojoList);

LOGGER.info("-------本次插入防火墙日志数量为【"+ipsLogPojoList.size()+"】条---------");

}

} catch (IOException e) {

LOGGER.warn("解析IPS日志异常，异常信息：",e);

} finally {

if(inputStreamReader!=null){

try {

inputStreamReader.close();

}catch (IOException e){

LOGGER.error("inputStreamReader关闭异常");

}

}

if(bufferedReader!=null){

try {

bufferedReader.close();

}catch (IOException e){

LOGGER.error("inputStreamReader关闭异常");

}

}

if (session != null) {

session.close();

}

if (connection != null) {

connection.close();

}

}

}