0

我必须IDS为我的大学项目开发​​一个。我可以使用嗅探器的 java 代码和算法。我必须启用它以支持 1 GB 以太网流量/秒。为此，我们计划multi-threading在双核机器上合并和运行代码。我打算在IP. 程序的主要功能调用openInterface()类packetLoader{implements packetReciever} 的方法。该方法openInterface()打开NIC界面并开始捕获数据包。我应该改变这种方法openInterface()来合并multi-threading吗？我应该在什么时候开始制作线程？我应该根据什么参数制作单独的线程？我应该如何实施所需的multi-threading？

干杯：）

public void openInterface(String filter, int numOfPackets){
    try {
        if (!devName.startsWith(NIC_NAME_PREFIX)) {             
            if(numOfPackets == -1)
                packetSamplingRatio = 1;
            else {
                packetSamplingRatio = numOfPackets/(double)totalPcapFilePackets;
            }
        }

        //JpcapCaptor captor = null;
        if (devName.startsWith(NIC_NAME_PREFIX)) {
                        System.err.println(".........inside openinterface");
            NetworkInterface[] devicesList = JpcapCaptor.getDeviceList();
                                         System.err.println(".........inside openinterface 2");

            String nicName = devName.substring(NIC_NAME_PREFIX.length());
            int nicID = -1;
            for (int i = 0; i < devicesList.length; i++) {

                                System.err.println(".........inside openinterface 3");
                if (devicesList[i].name.equals(nicName)){
                                        System.err.println("Device no:" + i + "=" +devicesList[i].name);
                                        System.err.println("capturing on device= " + devicesList[i].name);
                    nicID = i;}
            }
            if (nicID >= 0){

                                captor = JpcapCaptor.openDevice(devicesList[1],
                        NIC_SNAPLEN, true, NIC_TIMEOUT);
                            System.err.println(".........Device is open for packet capturing with");
                            System.err.println("NIC_SNAPLEN = " + NIC_SNAPLEN + " and NIC_TIMEOUT=" + NIC_TIMEOUT);

                            }
            else {
                System.err.println("Network interface " + nicName
                        + "cannot be found!");
                System.err.println("Availabel NICs:");
                for(int k=0; k<devicesList.length; k++) {
                    System.out.println("- " + devicesList[k]);
                }
                System.exit(1);
            }
        } else {
                        System.err.println(".........inside else");
            captor = JpcapCaptor.openFile(devName);
        }

        if (filter != null){
            captor.setFilter(filter, true);
                   ;
                    }// Start reading packets
                    System.err.println(".........filter checked");
                    //PacketStorage ps = new PacketStorage(); 
        //captor.loopPacket(numOfPackets, this);
                    //captor.processPacket(numOfPackets, this);
                    for(int j =0; j<numOfPackets ; j++){
                    captor.getPacket();

                    System.err.println(".........captured packet" + j);

                    }
                    System.err.println(".........after capture.looppacket");
    }

    catch (IOException e) {
        System.err.println("Exception in openDevice " + e);
        System.exit(1);
    }
}
4

1 回答 1

0

我不确定是否会为每个客户端（IP 地址）生成一个新线程。如果仅用于大学项目，它可能还可以，但对于更真实的场景，如果客户数量变大，它可能会过度杀伤（和性能损失）。相反，我会创建一个大小固定的工作线程池（请参阅java.util.concurrent.Executors和）（CPU 的to是一个好的开始），并将要分析的数据包传递给它们。在您的情况下，它可以在您调用的循环中的代码示例末尾完成。当然，执行器池必须在应用程序启动时进行初始化。java.util.concurrent.ExecutorServicen+12*nforgetPacket()

除此之外，通常实现 IDS 并非易事，因为要使其真正正确，单独分析每个数据包是不够的。由于 IP 分段，数据包以片段的形式出现，因此可能需要将其中的几个合并在一起以正确检测入侵。但这是你问题范围之外的不同故事......

于 2012-12-13T09:28:52.397 回答