Buenas. Necesito una ayuda para entender este codigo. El problema es que necesito crear la parte del cliente y que funcione para este codigo el cual pertenece al servidor.
Alguna propuesta?
public class HiloPrecioSubir extends Thread {
private Socket cliente = null;private BufferedReader entrada;private OutputStream salida;private File fDir = null;private String direccionCliente;private String nombre = "";private boolean instancia = false;private boolean debug = false;private String directorio = null;private int largoNombre =63;private String tokenEnc="ENC&%&%&%";private String tokenDet="DET&%&%&%";private Date fecha;
/** Creates a new instance of HiloPrecioSubir */
public HiloPrecioSubir(Socket socket, String directorio, String extensionArchivos, boolean debug) throws IOException {
this.cliente=socket;this.debug=debug;this.directorio=directorio;this.entrada=new BufferedReader(new InputStreamReader(cliente.getInputStream()));this.salida =cliente.getOutputStream();
if (this.directorio.endsWith("\\") || this.directorio.endsWith("/")) { //Se agrega terminacion unix '/'. Leothis.directorio = this.directorio.substring(0, this.directorio.length() - 1);}
fDir = new File(this.directorio);
if (!fDir.exists() || !fDir.isDirectory()) {System.out.println("El directorio no existe o no es un directorio v�lido");//System.exit(-1);return;}
this.start();}
public void run(){
String cadena="";String fechaHora="";
try {
int i=0;int c;direccionCliente = cliente.getLocalAddress().getHostName();direccionCliente = Utils.reemplazar(Utils.reemplazar(direccionCliente, '/', '@'), '.', '_');ControladorComandos ctrlCmd=new ControladorComandos();
if (debug)System.out.println("\tConectado con cliente("+cliente.getInetAddress()+") desde nuevo " + direccionCliente);
Utils.enviarFecha(salida);// Error.lanzarError(salida);
while((c = entrada.read()) != -1) {
if(i >= largoNombre) {
if(cadena.endsWith(tokenEnc)){
cadena=cadena.substring(0,cadena.length()-tokenEnc.length());nombre = nombre.trim();ctrlCmd.llamarComando(directorio, cadena.trim(), nombre, tokenEnc);if (debug)System.out.println("\t" + i + " bytes escritos en " + nombre+".txt" + ".");nombre="";cadena="";largoNombre+=i;
}else if(cadena.endsWith(tokenDet)){
cadena=cadena.substring(0,cadena.length()-tokenEnc.length());nombre = nombre.trim();ctrlCmd.llamarComando(directorio, cadena.trim(), nombre, tokenDet);if (debug)System.out.println("\t" + i + " bytes escritos en " + nombre+".txt" +".");nombre="";cadena="";largoNombre+=i;
}
cadena+=(char)c;} else {nombre+=(char)c;}i++;}
//Error.lanzarError(salida);
} catch (Exception e) {
System.out.println("Error: com.la14.chq.socket.ListaPrecioSubir: " + e.getMessage());
}finally{try{
salida.close();entrada.close();cliente.close();
}catch(IOException e){
System.out.println("Socket sin cerrar HiloPrecioSubir :"+e.getMessage());}}
Buenas. Necesito una ayuda para entender este codigo. El problema es que necesito crear la parte del cliente y que funcione para este codigo el cual pertenece al servidor.
Alguna propuesta?
public class HiloPrecioSubir extends Thread {
private Socket cliente = null;
private BufferedReader entrada;
private OutputStream salida;
private File fDir = null;
private String direccionCliente;
private String nombre = "";
private boolean instancia = false;
private boolean debug = false;
private String directorio = null;
private int largoNombre =63;
private String tokenEnc="ENC&%&%&%";
private String tokenDet="DET&%&%&%";
private Date fecha;
/** Creates a new instance of HiloPrecioSubir */
public HiloPrecioSubir(Socket socket, String directorio, String extensionArchivos, boolean debug) throws IOException {
this.cliente=socket;
this.debug=debug;
this.directorio=directorio;
this.entrada=new BufferedReader(new InputStreamReader(cliente.getInputStream()));
this.salida =cliente.getOutputStream();
if (this.directorio.endsWith("\\") || this.directorio.endsWith("/")) { //Se agrega terminacion unix '/'. Leo
this.directorio = this.directorio.substring(0, this.directorio.length() - 1);
}
fDir = new File(this.directorio);
if (!fDir.exists() || !fDir.isDirectory()) {
System.out.println("El directorio no existe o no es un directorio v�lido");
//System.exit(-1);
return;
}
this.start();
}
public void run(){
String cadena="";
String fechaHora="";
try {
int i=0;
int c;
direccionCliente = cliente.getLocalAddress().getHostName();
direccionCliente = Utils.reemplazar(Utils.reemplazar(direccionCliente, '/', '@'), '.', '_');
ControladorComandos ctrlCmd=new ControladorComandos();
if (debug)
System.out.println("\tConectado con cliente("+cliente.getInetAddress()+") desde nuevo " + direccionCliente);
Utils.enviarFecha(salida);
// Error.lanzarError(salida);
while((c = entrada.read()) != -1) {
if(i >= largoNombre) {
if(cadena.endsWith(tokenEnc)){
cadena=cadena.substring(0,cadena.length()-tokenEnc.length());
nombre = nombre.trim();
ctrlCmd.llamarComando(directorio, cadena.trim(), nombre, tokenEnc);
if (debug)
System.out.println("\t" + i + " bytes escritos en " + nombre+".txt" + ".");
nombre="";
cadena="";
largoNombre+=i;
}else if(cadena.endsWith(tokenDet)){
cadena=cadena.substring(0,cadena.length()-tokenEnc.length());
nombre = nombre.trim();
ctrlCmd.llamarComando(directorio, cadena.trim(), nombre, tokenDet);
if (debug)
System.out.println("\t" + i + " bytes escritos en " + nombre+".txt" +".");
nombre="";
cadena="";
largoNombre+=i;
}
cadena+=(char)c;
} else {
nombre+=(char)c;
}
i++;
}
//Error.lanzarError(salida);
} catch (Exception e) {
System.out.println("Error: com.la14.chq.socket.ListaPrecioSubir: " + e.getMessage());
}finally{
try{
salida.close();
entrada.close();
cliente.close();
}catch(IOException e){
System.out.println("Socket sin cerrar HiloPrecioSubir :"+e.getMessage());
}
}
}
}