Discussion :

[Talall]

Salut,
J'ai des données(des paquets réseau ) à insérer dans une base Cassandra!
Malheureusement, Je n'ai pu inséré les 10000 paquets que pendant 1 min !

Je cherche s'il y a quelqu'un qui peut m'aider à exploiter la notion de multithreading java afin d’accélérer l'insertion!!
Voici mon code d'insertion :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
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);//fonction qui fait l'insertion
               } 
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);
            }
            }}

et merci d'avance

[sipatsymasaka]

et si tu jettais un coup d'oeil ici? : http://alwin.developpez.com/tutorial/JavaThread/ pour voir si ça va marcher et si ça en vaut le coup.