Cassandraデータベースに挿入するデータ (ネットワーク パケット) があります。
残念ながら、私のアプリケーションは 10000 パケットを挿入するのに約 1 分かかります!
Javaマルチスレッドの概念を操作して挿入を加速するのを手伝ってくれる人を探しています! これが私のコードです:
PcapPacketHandler<String> jpacketHandler;
jpacketHandler = new PcapPacketHandler<String>() {
GestionPacketDAO g1;
int row=0;
public void nextPacket(PcapPacket packet, String user) {
row++;
String s = packet.toHexdump();
try {
g1 = new GestionPacketDAO();
g1.Insert(s, row);// Insert is the function which insert data into database
}
catch (InvalidRequestException exg)
{Logger.getLogger(AccueilInsertion.class.getName()).log(Level.SEVERE, null, exg);
}
catch (TException exg) {
Logger.getLogger(AccueilInsertion.class.getName()).log(Level.SEVERE, null, exg);
}
}}
ありがとうございました !!