最近需要开发一个插件：首先需要识别初nginx的版本号，其次需要列出该版本号存在的CVE漏洞列表。

本人从0开始，写一个bp的开发教程，思路为：跟着教程搭建出一个可以用在burpsuite的插件，然后在此基础上构建一个由GUI的插件，后面进一步去熟悉插件相关的API函数。本文教程基于gradle项目，因为方便引言一些插件库。

的函数：

词频：FreqDist(words_list), 接受list类型的参数，返回词典，key是元素，value是元素出现的次数

    fdist = FreqDist(dist).keys()
    dist_max=set(fdist[0:50])
    dist_min = set(fdist[-50:])

set() 函数创建一个无序不重复元素集，可进行关系测试，删除重复数据，还可以计算交集、差集、并集等。

>>>x = set('runoob')
>>> y = set('google')
>>> x, y
(set(['b', 'r', 'u', 'o', 'n']), set(['e', 'o', 'g', 'l']))   # 重复的被删除

1 走进KNN

1.k近邻算法的基本概念，原理以及应用

KNN（K-nearest neighbor）的基本思想非常的简单朴素，即对于一个待预测的样本x ，在训练集中找到距离其最近的k 个近邻 ，得票最高的类作为输出类别即可。当 k=1 时，则称为最近邻。

openvas插件开发

首先蚁剑的下载地址：

https://github.com/AntSwordProject/antSword

其次需要注意：

在使用虚拟机创建centos系统的时候,会发现原本打算分配的空间,有一部分给/mnt分配走了,这样就造成我们的根目录空间不够,所以我们要把/mnt分配走的空间还给根目录.

1 整体架构部署

SIEM全称为security information and event management，即安全信息和事件管理，通俗使用的说，安全信息指的是服务运行中产生的日志信息，事件管理即通过对安全信息进行各种分析方法的总称，如入侵检测等。目前我司一个项目中客户要求SIEM系统，最常见的采用elk+filebeat搭建SIEM系统，用来分析服务器产生的日志：其实初步只做到了安全信息管理，后面如果深入我会继续更新。下面先看下部署的整体架构：filebeat部署在哥哥需要收集日志的机器上，然后在云上部署elk系统，然后filebeat将日志传送到logstash中，然后logstash存到es中，进一步通过kibana进行数据化展示。

很多软件的安装都需要java8的环境，如何再Linux安装java8环境呢？

最近老板要求建设资产管理与服务软件，团队人员少，只能找找开源的啦，DefectDojo基于Django框架可以搭建看看

1 IDEA环境搭建

1）创建一个Maven Module

2）添加pom文件

<dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-core</artifactId>
            <version>2.8.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.5.7</version>
        </dependency>
</dependencies>

3）拷贝log4j.properties文件到项目根目录
需要在项目的src/main/resources目录下，新建一个文件，命名为“log4j.properties”，在文件中填入。

log4j.rootLogger=INFO, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n
log4j.appender.logfile=org.apache.log4j.FileAppender
log4j.appender.logfile.File=target/spring.log
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n

2 初始化ZooKeeper客户端

public class Zookeeper {

private String connectString;
private int sessionTimeout;
private ZooKeeper zkClient;

@Before   //获取客户端对象

public void init() throws IOException {

​    connectString = "hadoop102:2181,hadoop103:2181,hadoop104:2181";
​    int sessionTimeout = 10000;
​    
   //参数解读 1集群连接字符串  2连接超时时间 单位:毫秒  3当前客户端默认的监控器
​    zkClient = new ZooKeeper(connectString, sessionTimeout, new Watcher() {
​        @Override
​        public void process(WatchedEvent event) {
​        }
​    });
}

@After //关闭客户端对象
public void close() throws InterruptedException {
    zkClient.close();
}

}

3 获取子节点列表,不监听

@Test
public void ls() throws IOException, KeeperException, InterruptedException {
    //用客户端对象做各种操作
    List<String> children = zkClient.getChildren("/", false);
    System.out.println(children);
&#125;

4 获取子节点列表,并监听

@Test
public void lsAndWatch() throws KeeperException, InterruptedException {
    List<String> children = zkClient.getChildren("/atguigu", new Watcher() &#123;
        @Override
        public void process(WatchedEvent event) &#123;
            System.out.println(event);
        &#125;
    &#125;);
System.out.println(children);
    //因为设置了监听,所以当前线程不能结束
Thread.sleep(Long.MAX_VALUE);
    &#125;

5 创建子节点

@Test
public void create() throws KeeperException, InterruptedException {
//参数解读 1节点路径  2节点存储的数据  
//3节点的权限(使用Ids选个OPEN即可) 4节点类型 短暂 持久 短暂带序号 持久带序号
     String path = zkClient.create("/atguigu", "shanguigu".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

//创建临时节点

//String path = zkClient.create("/atguigu2", "shanguigu".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);

System.out.println(path);

//创建临时节点的话,需要线程阻塞
//Thread.sleep(10000);

}

6 判断Znode是否存在

@Test
public void exist() throws Exception {

Stat stat = zkClient.exists("/atguigu", false);
System.out.println(stat == null ? "not exist" : "exist");

}

7 获取子节点存储的数据,不监听

@Test
public void get() throws KeeperException, InterruptedException {
    //判断节点是否存在
    Stat stat = zkClient.exists("/atguigu", false);
    if (stat == null) {
        System.out.println("节点不存在...");
        return;
    }

byte[] data = zkClient.getData("/atguigu", false, stat);
System.out.println(new String(data));

}

8 获取子节点存储的数据,并监听

@Test
public void getAndWatch() throws KeeperException, InterruptedException {
    //判断节点是否存在
    Stat stat = zkClient.exists("/atguigu", false);
    if (stat == null) {
        System.out.println("节点不存在...");
        return;
    }

    byte[] data = zkClient.getData("/atguigu", new Watcher() {
        @Override
        public void process(WatchedEvent event) {
            System.out.println(event);
        }
    }, stat);
    System.out.println(new String(data));
    //线程阻塞
    Thread.sleep(Long.MAX_VALUE);
}

9 设置节点的值

@Test
public void set() throws KeeperException, InterruptedException {
    //判断节点是否存在
    Stat stat = zkClient.exists("/atguigu", false);
    if (stat == null) {
        System.out.println("节点不存在...");
        return;
    }
    //参数解读 1节点路径 2节点的值 3版本号
    zkClient.setData("/atguigu", "sgg".getBytes(), stat.getVersion());
}

10 删除空节点

@Test
public void delete() throws KeeperException, InterruptedException {
    //判断节点是否存在
    Stat stat = zkClient.exists("/aaa", false);
    if (stat == null) {
        System.out.println("节点不存在...");
        return;
    }
    zkClient.delete("/aaa", stat.getVersion());
}

11 删除非空节点,递归实现

//封装一个方法,方便递归调用
public void deleteAll(String path, ZooKeeper zk) throws KeeperException, InterruptedException {
    //判断节点是否存在
    Stat stat = zkClient.exists(path, false);
    if (stat == null) {
        System.out.println("节点不存在...");
        return;
    }
    //先获取当前传入节点下的所有子节点
    List<String> children = zk.getChildren(path, false);
    if (children.isEmpty()) &#123;
        //说明传入的节点没有子节点,可以直接删除
        zk.delete(path, stat.getVersion());
    &#125; else &#123;
        //如果传入的节点有子节点,循环所有子节点
        for (String child : children) &#123;
            //删除子节点,但是不知道子节点下面还有没有子节点,所以递归调用
            deleteAll(path + "/" + child, zk);  
        &#125;
        //删除完所有子节点以后,记得删除传入的节点
        zk.delete(path, stat.getVersion());
    &#125;
&#125;
//测试deleteAll
@Test
public void testDeleteAll() throws KeeperException, InterruptedException &#123;
    deleteAll("/atguigu",zkClient);
&#125;