Codigo fuente del programa descargarMensajes
package hello;
import java.io.InputStream;
import javax.microedition.io.Connector;
import javax.microedition.io.HttpConnection;
import javax.microedition.rms.RecordStore;
import javax.microedition.rms.RecordStoreException;
/**
*
* @author Administrador
*/
public class descargarMensajes implements Runnable {
/** Creates a new instance of descargarMensajes */
String url = null;
public String alerta = null;
Thread t= null;
private RecordStore rsMensajes;
public boolean sedescargoMensajes = false;
public String archivo ="";
public boolean debug = false;
descargarMensajes(String url){
this.url = url;
t = new Thread(this);
}
public void send() {
t.start();
}
public void run() {
//Code to open HttpConnection and to send or receive data
downloadMensajes();
}
/** Creates a new instance of bajarMensajes */
private void downloadMensajes(){
url ="http://www.tusitio.com/tuarchivo";
try{
if (rsMensajes == null){
abrirRecordStoreMensajes();
}
HttpConnection c = null;
InputStream is = null;
StringBuffer b = new StringBuffer();
StringBuffer salida = new StringBuffer();
try {
c = (HttpConnection)Connector.open(url);
c.setRequestMethod(HttpConnection.GET);
c.setRequestProperty("IF-Modified-Since", "10 Nov 2000 17:29:12 GMT");
c.setRequestProperty("User-Agent","Profile/MIDP-1.0 Configuration/CLDC-1.0");
c.setRequestProperty("Content-Language", "es-ES");
is = c.openInputStream();
int ch, i, j;
String mensaje="";
int filas = 0;
while ((ch = is.read()) != -1) {
b.append((char) ch);
if (ch == '\n') {
filas++;
String linea = b.toString();
escribirRegistroMensajes(linea);
b.delete(0,b.length());
}
}
} catch(Exception e) {
System.out.println("descargarMensajes()\n " + e);
}
System.out.println("!Termino descarga...");
}catch(Exception e) {
System.out.println("descargarMensajes(): \n" + e);
}
}
/*
*
*/
public void abrirRecordStoreMensajes() {
try{
rsMensajes = RecordStore.openRecordStore("mensajesdb",true);
}catch(RecordStoreException e) {
System.out.println("Metodo:abrirRecordStoreMensajes()\n" + e +"" );
}
}//abrirRecordStoreMensajes
/*
*
*/
public void cerrarRecordStoreMensajes(){
try{
rsMensajes.closeRecordStore();
} catch (RecordStoreException e){
System.out.println("Metodo:cerrarRecordStoreMensajes()\n" + e );
}
}
public void escribirRegistroMensajes(String n) {
byte[] registro;
registro = n.getBytes();
try{
rsMensajes.addRecord(registro,0,registro.length);
} catch (RecordStoreException e){
System.out.println("Error al insertar registro\n "+e);
}
} //escribir
} //class
package hello;
import java.io.InputStream;
import javax.microedition.io.Connector;
import javax.microedition.io.HttpConnection;
import javax.microedition.rms.RecordStore;
import javax.microedition.rms.RecordStoreException;
/**
*
* @author Administrador
*/
public class descargarMensajes implements Runnable {
/** Creates a new instance of descargarMensajes */
String url = null;
public String alerta = null;
Thread t= null;
private RecordStore rsMensajes;
public boolean sedescargoMensajes = false;
public String archivo ="";
public boolean debug = false;
descargarMensajes(String url){
this.url = url;
t = new Thread(this);
}
public void send() {
t.start();
}
public void run() {
//Code to open HttpConnection and to send or receive data
downloadMensajes();
}
/** Creates a new instance of bajarMensajes */
private void downloadMensajes(){
url ="http://www.tusitio.com/tuarchivo";
try{
if (rsMensajes == null){
abrirRecordStoreMensajes();
}
HttpConnection c = null;
InputStream is = null;
StringBuffer b = new StringBuffer();
StringBuffer salida = new StringBuffer();
try {
c = (HttpConnection)Connector.open(url);
c.setRequestMethod(HttpConnection.GET);
c.setRequestProperty("IF-Modified-Since", "10 Nov 2000 17:29:12 GMT");
c.setRequestProperty("User-Agent","Profile/MIDP-1.0 Configuration/CLDC-1.0");
c.setRequestProperty("Content-Language", "es-ES");
is = c.openInputStream();
int ch, i, j;
String mensaje="";
int filas = 0;
while ((ch = is.read()) != -1) {
b.append((char) ch);
if (ch == '\n') {
filas++;
String linea = b.toString();
escribirRegistroMensajes(linea);
b.delete(0,b.length());
}
}
} catch(Exception e) {
System.out.println("descargarMensajes()\n " + e);
}
System.out.println("!Termino descarga...");
}catch(Exception e) {
System.out.println("descargarMensajes(): \n" + e);
}
}
/*
*
*/
public void abrirRecordStoreMensajes() {
try{
rsMensajes = RecordStore.openRecordStore("mensajesdb",true);
}catch(RecordStoreException e) {
System.out.println("Metodo:abrirRecordStoreMensajes()\n" + e +"" );
}
}//abrirRecordStoreMensajes
/*
*
*/
public void cerrarRecordStoreMensajes(){
try{
rsMensajes.closeRecordStore();
} catch (RecordStoreException e){
System.out.println("Metodo:cerrarRecordStoreMensajes()\n" + e );
}
}
public void escribirRegistroMensajes(String n) {
byte[] registro;
registro = n.getBytes();
try{
rsMensajes.addRecord(registro,0,registro.length);
} catch (RecordStoreException e){
System.out.println("Error al insertar registro\n "+e);
}
} //escribir
} //class
Comments