Originariamente inviata da
andbin
Ho riguardato un attimo l'altra tua discussione in cui hai postato il codice. Non ho tempo purtroppo adesso di valutare quel tuo codice ma ho visto ora che usi MulticastSocket.
No no , non centra l'altro post...
Non sto utilizzando il multicast; quello di cui ti parlo è un altro esercizio.
Se hai un pò di tempo potresti dargli un occhiata , Mi faresti un grande favore ; sto sclerando per riuscire a correggerlo.
ti posto il codice, magari lo fai partire sulla tua macchina e mi fai sapere
Client :
codice:
package appello19Febbraio2014;
import java.io.*;
import java.net.*;
import java.util.*;
import java.security.*;
import java.security.spec.*;
import javax.crypto.*;
public class Client{
InetAddress serverAddress;
int serverPort;
Socket socket;
int UDPPort;
DatagramSocket dSocket;
Socket gkSocket;
int gkPort;
Cipher cipher , decipher;
public Client(InetAddress serverAddress , int serverPort , int UDPPort , int gkPort){
this.serverAddress = serverAddress;
this.serverPort = serverPort;
this.UDPPort = UDPPort;
this.gkPort = gkPort;
try{
socket = new Socket(serverAddress , serverPort);
dSocket = new DatagramSocket(UDPPort);
gkSocket = new Socket(serverAddress , gkPort);
}catch(Exception err){
err.printStackTrace();
}
}//COSTRUTTORE
public void InizializzaCriptazione(){
try{
//RICHIESTA DELLA CHIAVE PUBBLICA :
OutputStream out = gkSocket.getOutputStream();
out.write(1);
//RICEZIONE DELLA CHIAVE PUBBLICA :
byte [] publicKeyByte = new byte [1000];
InputStream in = gkSocket.getInputStream();
//SALVATAGGIO DELLA CHIAVE PUBBLICA :
int numByte = in.read(publicKeyByte);
publicKeyByte = Arrays.copyOf(publicKeyByte , numByte);
X509EncodedKeySpec ks = new X509EncodedKeySpec(publicKeyByte);
KeyFactory kf = KeyFactory.getInstance("RSA");
PublicKey publicKey = kf.generatePublic(ks);
//INIZIALIZZAZIONE CIFRARI :
cipher = Cipher.getInstance("RSA/ECB/PKCS1Padding");
cipher.init(Cipher.ENCRYPT_MODE, publicKey);
decipher = Cipher.getInstance("RSA/ECB/PKCS1Padding");
decipher.init(Cipher.DECRYPT_MODE, publicKey);
in.close();
out.close();
}catch(Exception err){
try{
gkSocket.close();
}catch(Exception err2){
err2.printStackTrace();
}
}
}//RUN
public void InviaRichiestaEdAttendiPacchettoUDP(String richiesta){
InizializzaCriptazione();
try{
//INVIO DELLA RICHIESTA CIFRATA TRAMITE TCP :
OutputStream out = socket.getOutputStream();
out.write(cipher.doFinal(richiesta.getBytes()));
//ATTESA DEL PACCHETTO UDP :
byte [] buf = new byte [128];
DatagramPacket packet = new DatagramPacket(buf , buf.length);
dSocket.receive(packet);
//DECIFRAZIONE E STAMPA DEL MESSAGGIO RICEVUTO :
byte [] messaggioByte = decipher.doFinal(packet.getData());
String messaggio = new String(messaggioByte);
System.out.println(messaggio);
}catch(Exception err){
err.printStackTrace();
}
}// InviaRichiestaEdAttendiPacchettoUDP
public static void main (String [] args){
try{
InetAddress serverAddress = InetAddress.getByName("127.0.0.1"); //SULL'APPELLO : 150.2.66.55
int serverPort = 6800;
int UDPPort = 7700;
int gkPort = 7800;
Client client = new Client(serverAddress , serverPort , UDPPort , gkPort);
client.InviaRichiestaEdAttendiPacchettoUDP("127.0.0.1@Ciao");
}catch(Exception err){
err.printStackTrace();
}
}//MAIN
}// THREAD CLIENT
Host :
codice:
package appello19Febbraio2014;
import java.util.*;
import java.io.*;
import java.net.*;
import java.security.*;
import java.security.spec.*;
import javax.crypto.*;
public class Host extends Thread {
ServerSocket sSocket;
int skPort;
KeyPair kp;
Cipher cipher , decipher;
public Host(int skPort){
this.skPort = skPort;
try{
sSocket = new ServerSocket(skPort);
}catch(Exception err){
err.printStackTrace();
}
}//COSTRUTTORE
public void run(){
try{
while(true){
Socket s = sSocket.accept();
InputStream in = s.getInputStream();
in.read();
KeyPairGenerator kpg = KeyPairGenerator.getInstance("RSA");
kpg.initialize(1024);
kp = kpg.generateKeyPair();
OutputStream out = s.getOutputStream();
out.write(kp.getPublic().getEncoded());
}
}catch(Exception e){
try{
sSocket.close();
}catch(Exception e2){
e2.printStackTrace();
}
}
}//RUN
class gestisciRichieste extends Thread{
Socket s;
int UDPPort;
DatagramSocket dSocket;
public gestisciRichieste(Socket s , int UDPPort){
this.s = s;
this.UDPPort = UDPPort;
try{
dSocket = new DatagramSocket(UDPPort);
}catch(Exception e){
e.printStackTrace();
}
this.start();
}//COSTRUTTORE
public void run(){
try{
while(true){
decipher = Cipher.getInstance("RSA/ECB/PKCS1Padding");
decipher.init(Cipher.DECRYPT_MODE, kp.getPrivate());
cipher = Cipher.getInstance("RSA/ECB/PKCS1Padding");
cipher.init(Cipher.ENCRYPT_MODE, kp.getPrivate());
InputStream in = s.getInputStream();
byte [] richiestaByte = new byte [1000];
int numByte = in.read(richiestaByte);
richiestaByte = Arrays.copyOf(richiestaByte, numByte);
String richiesta = new String(decipher.doFinal(richiestaByte));
int pos = richiesta.indexOf("@");
String ip = richiesta.substring(0,pos);
String messaggio = richiesta.substring(pos+1);
System.out.println(ip);
InetAddress clientAddress = InetAddress.getByName(ip);
byte [] buf = new byte [1000];
buf = cipher.doFinal(messaggio.getBytes());
DatagramPacket packet = new DatagramPacket(buf,buf.length,clientAddress,UDPPort);
dSocket.send(packet);
in.close();
}
}catch(Exception e){
try{
dSocket.close();
}catch(Exception e2){
e2.printStackTrace();
}
}
}//RUN
}//THREAD GESTISCI RICHIESTE
public static void main (String [] args){
try{
int skPort = 7800;
int UDPPort = 7700;
ServerSocket servSocket = new ServerSocket(6800);
Host host = new Host(skPort);
host.start();
while(true){
Socket s = servSocket.accept();
gestisciRichieste gr = host.new gestisciRichieste(s,UDPPort);
}
}catch(Exception e){
e.printStackTrace();
}
}//MAIN
}//THREAD HOST
Per favore guardalo un attimo.
Ho messo come indirizzo l' ip di localHost 127.0.0.1
Ma mi da quella cacchio di eccezione
java.net.BindException: Address already in use: Cannot bind
at java.net.DualStackPlainDatagramSocketImpl.socketBi nd(Native Method)
at java.net.DualStackPlainDatagramSocketImpl.bind0(Un known Source)
at java.net.AbstractPlainDatagramSocketImpl.bind(Unkn own Source)
at java.net.DatagramSocket.bind(Unknown Source)
at java.net.DatagramSocket.<init>(Unknown Source)
at java.net.DatagramSocket.<init>(Unknown Source)
at java.net.DatagramSocket.<init>(Unknown Source)
at appello19Febbraio2014.Client.<init>(Client.java:30 )
at appello19Febbraio2014.Client.main(Client.java:112)
java.lang.NullPointerException
at appello19Febbraio2014.Client.InizializzaCriptazion e(Client.java:71)
at appello19Febbraio2014.Client.InviaRichiestaEdAtten diPacchettoUDP(Client.java:80)
at appello19Febbraio2014.Client.main(Client.java:113)
java.lang.NullPointerException
at appello19Febbraio2014.Client.InviaRichiestaEdAtten diPacchettoUDP(Client.java:85)
at appello19Febbraio2014.Client.main(Client.java:113)
Appena posso sono sempre ben disponibile (premettendo che il multicast non è certo la cosa che uso tutti i giorni ....).
Permessi di invio
Rispondi quotando