[JAVA] parsing file XML

[AbuJaffa]

ciao a tutti

Devo poter leggere da un file xml (feed rss) titoli, sorgenti e contenuti delle notizie. Ho utilizzato le librerie StAX per effettuare il parsing del file xml, però a me interessa estrapolare solo le parti dette sopra, cioè filtrare dal risultato del parsing solo alcune zone. Devo farlo in maniera grezza, cioè scandendo i risultati oppure c'è una via maestra più veloce?
Grazie a tutti...

[Angus]

Ci sono tanti modi, e tutti dipendono da quello che vuoi fare. Per esempio potresti utilizzare una trasformazione XSLT.

[AbuJaffa]

Allora, devo prelevare titolo, contenuto, link e data della notizia.
Cosa sarebbe questa trasformazione XSLT?

[Angus]

XSL è un linguaggio che ti permette di definire una trasformazione applicabile ad un documento XML per ottenere tipicamente un altro documento XML.
Puoi utilizzarlo come approccio completamente alternativo al tuo, o utilizzarlo solo nel punto in cui ti serve attraverso un'espressione XPath. Ma preferisco non dilungarmi su questo perchè forse *devi* utilizzare stax.
Se invece devi procedere con una fase di parsing e con una successiva fase di "filtro", allora puoi tentare comunque con XPath, prendendo spunto da quanto esposto qui .

[AbuJaffa]

uhm... senti a questo punto per non fare dei controlli man mano che il processo di parsing va avanti il che porterebbe sicuramente a scivere codice lungo e inefficiente non sarebbe meglio utilizare DOM? Potresti farmi vedere un po di codice d'esempio sul suo utilizzo? Grazie...

[orpheus]

Scusa ma StaX non lavora tipo DOM e quindi non puoi usare quello anche per l'estrazione??

altrimenti puoi vedere qui che c'è un jar apposito x gestire RSS in java..ma forse è troppo per quello che devi fare


https://rome.dev.java.net/


ciao

[thebol]

Potresti al limite anche usare castor.

E un oggetto che da un file schema ti genera degli oggetti che ti rappresento il file XML, e ti genera i metodi per fare il marshal e l'unmarshal.

Pero forse è un po troppo grossa e dispendiosa come soluzione, ti consiglio di usare XPATH

[Angus]

Originariamente inviato da AbuJaffa

uhm... senti a questo punto per non fare dei controlli man mano che il processo di parsing va avanti il che porterebbe sicuramente a scivere codice lungo e inefficiente non sarebbe meglio utilizare DOM? Potresti farmi vedere un po di codice d'esempio sul suo utilizzo? Grazie...

Ribadisco che, prendendo spunto da qui, e te lo riporto per comodità:

XPath xpath = XPathFactory.newInstance().newXPath();
String expression = "/widgets/widget";
InputSource inputSource = new InputSource("widgets.xml");
NodeSet nodes = (NodeSet) xpath.evaluate(expression, inputSource, XPathConstants.NODESET);

puoi fare una cosa del genere:

// assumo che in qualche modo ho effettuato il parsing dell'xml
// e ho costruito un albero DOM

Document xmlDom = ...;

// Definisco l'espressione XPath come più mi conviene
String expression = ...;

XPath xpath = XPathFactory.newInstance().newXPath();

// Ottiengo una "vista" sui nodi filtrati e ci faccio quello che voglio
NodeSet nodes = (NodeSet) xpath.evaluate(
     expression, 
     new DOMSource(xmlDom), 
     XPathConstants.NODESET);

[dupa]

Originariamente inviato da AbuJaffa

ciao a tutti

Devo poter leggere da un file xml (feed rss) titoli, sorgenti e contenuti delle notizie. Ho utilizzato le librerie StAX per effettuare il parsing del file xml, però a me interessa estrapolare solo le parti dette sopra, cioè filtrare dal risultato del parsing solo alcune zone. Devo farlo in maniera grezza, cioè scandendo i risultati oppure c'è una via maestra più veloce?
Grazie a tutti...

usa XPath

[texerasmo]

comunque una trasformazione xml xsl è sempre più semplice ti fai restiuire quello che vuoi.

[Pitonti]

fai il poli?

[dupa]

Originariamente inviato da Pitonti

fai il poli?

io facevo

[Pitonti]

Originariamente inviato da dupa

io facevo

mica tu

[AbuJaffa]

Originariamente inviato da Pitonti

fai il poli?

si!

[Pitonti]

ah ecco è il progetto di Ing Sw
ti posto quello che ho scritto io


public class NewsManager {
protected ArrayList<NewsItem> RSSList;
protected URL RSSURL;

public NewsManager(String U) throws MalformedURLException {
RSSList = new ArrayList<NewsItem>();
RSSURL = new URL(U);
}

public NewsManager() throws MalformedURLException {
RSSList = new ArrayList<NewsItem>();
//RSSURL = new URL("http://www.repubblica.it/rss/homepage/rss2.0.xml");
RSSURL = new URL("http://www.elet.polimi.it/upload/lazaric/ingsw/rss2.0example.xml");
}

public void changeRSSURL(String U) throws MalformedURLException {
RSSURL=new URL(U);
}

public void retrieveNews() throws IOException, XMLStreamException {
//FileInputStream in = new FileInputStream("C:/Documents and Settings/Pitonti/Documenti/Programmazione/RSS-Example.xml");
//InputStream in = RSSURL.openStream();
FileInputStream in = new FileInputStream("D:/rss2.0example.xml");
XMLInputFactory factory = XMLInputFactory.newInstance();
XMLStreamReader parser = factory.createXMLStreamReader(in);

while (true) {
String localName=new String();
NewsItem news = new NewsItem();
int event = parser.next();
if (event == XMLStreamConstants.END_DOCUMENT) {
parser.close();
break;
}
if (event == XMLStreamConstants.START_ELEMENT && parser.getLocalName().equals("item")) {
do {
event=parser.next();
if (event == XMLStreamConstants.START_ELEMENT) {
localName=parser.getLocalName();
if (localName.equals("title")) {
parser.next();
news.setNewsTitle(parser.getText());
}
if (localName.equals("description")) {
parser.next();
news.setNewsText(parser.getText());
}
if (localName.equals("link")) {
parser.next();
news.setNewsLink(parser.getText());
}
if (localName.equals("author")) {
parser.next();
news.setSourceDesc(parser.getText());
}
if (localName.equals("category")) {
for (int i = 0; i < parser.getAttributeCount(); i++)
if (parser.getAttributeLocalName(i).equals("domain"))
news.setSourceLink(parser.getAttributeValue(i));
}
}
if (event == XMLStreamConstants.END_ELEMENT)
if(parser.getLocalName().equals("item")) break;
} while (true);
RSSList.add(news);
}
}
}

public void addCommentToNews(String cnt, String us, int nws) throws UnknownNewsException{
try{RSSList.get(nws).addComment(new Comment(cnt,us));}
catch (Exception e) {throw new UnknownNewsException();}
}

public void printRSS() {
System.out.println("Notizie prese dal feed RSS di " + RSSURL);
for (NewsItem n:RSSList) n.printNews();
}

public String getRSSString() {
String output = "Notizie prese dal feed RSS di " + RSSURL;
for (NewsItem n:RSSList) output=output+n.getNewsString();
return output;
}

public ArrayList<NewsItem> getRSSArray() {
return RSSList;
}

public static void main(String[] args) throws IOException, XMLStreamException {
NewsManager NM = new NewsManager();
NM.printRSS();
NM.retrieveNews();
NM.printRSS();
}

}

ho anche creato
public class RSSServer {
NewsManager NM;
UserManager UM;

public RSSServer() throws MalformedURLException {
NM = new NewsManager();
UM = new UserManager();

insieme alla dichiarazione del socket e degli utenti, visto che non so come gestire i db

[AbuJaffa]

scusa... ma la gestione degli utenti come andrà implementata? Maneggiando db?

[Pitonti]

no non avremo la possibilità di gestire i db ma salveremo gli utenti con le relative informazioni su dei file di txt che ancora non abbimo affrontato
ora sto alla grafica ed è una palla pazzesca

[AbuJaffa]

altra cosa... come hai implementato il protocollo di comunicazione fra client e server?

[Pitonti]

Originariamente inviato da AbuJaffa

altra cosa... come hai implementato il protocollo di comunicazione fra client e server?

io faccio partire il server che scarica le notizie e gestisce i commenti e il client scarica dal server le notizie che gli interessano e tutti i commenti alla notizia questo è il codice di gestione client-server

public class RSSServerThread extends Thread {
private Socket socket = null;
private RSSServer mainHost;
private long ThrID;

public RSSServerThread(Socket socket,RSSServer rss) {
super("RSSServerThread");
this.socket = socket;
mainHost=rss;
ThrID=this.getId();
}

public void run() {
try {
Message inputMessage = null; //Messaggi in arrivo da client
String utente;
boolean connected=true;
boolean uslog;

OutputStream o = socket.getOutputStream();
InputStream i = socket.getInputStream();
ObjectOutputStream outS = new ObjectOutputStream(o);
ObjectInput inS = new ObjectInputStream(i);
//Inizializzati gli stream di ingresso e uscita

System.out.println("Thread "+ThrID+" in esecuzione!");
do { //Ciclo esterno x determinare la modalità di funzionamento

//Ricezione Id che indica il modo di funzionamento
System.out.println(ThrID+": Attendo l'azione da eseguire...");
inputMessage = (Message) inS.readObject();
if (inputMessage.getClass()!=RequestMessage.class) {
outS.writeObject(new ErrorMessage(new UnexpectedMessageException(),1));
outS.flush();
outS.close();
inS.close();
socket.close();
return;
}//Attende un messaggio di richiesta
switch( ((RequestMessage) inputMessage).getContent() ) {

case 0: //Il client vuole disconnettersi
outS.writeObject(new Message("Richiesta accolta, thread in chiusura"));
System.out.println(ThrID+": Ho ricevuto una richiesta di disconnessione...Chiusura in corso");
connected=false;
break;

case 1: //Un utente si vuole loggare e utilizzare i suoi privilegi
outS.writeObject(new Message("Richiesta accolta, attesa di Username e Password"));
System.out.println(ThrID+": Ho ricevuto una richiesta di login, attendo dati utente...");
inputMessage = (Message) inS.readObject(); //Ricezione utente e pwd
if (inputMessage.getClass()!=LoginMessage.class) {
outS.writeObject(new ErrorMessage(new UnexpectedMessageException(),1));
outS.flush();
outS.close();
inS.close();
socket.close();
return;
}//Se il messaggio non è di login, riscontra l'errore e si disconnette
System.out.println(ThrID + ": l'utente "+((LoginMessage) inputMessage).getUser()+" sta provando a connettersi");
uslog=true;
try {mainHost.UM.userLogin(
((LoginMessage) inputMessage).getUser(),
((LoginMessage) inputMessage).getPassword());}
//Tentativo di login
catch (UnknownUserException e) {
System.out.println(ThrID+": l'utente è sconosciuto!");
outS.writeObject(new ErrorMessage(e,10));
outS.flush();
uslog=false;
}//Errore! Utente sconosciuto, riscontra l'errore e torna in attesa
catch (IncorrectLoginException e) {
System.out.println(ThrID+": "+e.getMessage());
outS.writeObject(new ErrorMessage(e,11));
outS.flush();
uslog=false;
}//Errore! Login non effettuato, riscontra l'errore e torna in attesa



utente=((LoginMessage) inputMessage).getUser();
if (uslog) {
System.out.println(utente + " loggato con successo!");
outS.writeObject(new ResponseMessage(1)); //Messaggio di login avvenuto
outS.flush();
}
while (uslog) {
System.out.println(utente + " --> Attesa di un nuovo comando...");
inputMessage = (Message)inS.readObject(); //Ciclo di attesa dei messaggi di richiesta
if (inputMessage.getClass()!=RequestMessage.class) {
outS.writeObject(new ErrorMessage(new UnexpectedMessageException(),1));
outS.flush();
outS.close();
inS.close();
socket.close();
return;
}//Se il messaggio non è di comando, riscontra l'errore e si disconnette
else {
outS.writeObject(new ResponseMessage(1)); //Messaggio di richiesta accolta
outS.flush();
switch ( ((RequestMessage)inputMessage).getContent() ){

case 0: //Richiesto il logout
System.out.println(utente + " --> Richiesto il logout");
uslog=false;
try {mainHost.UM.userLogout(utente);}
catch (Exception e){System.out.println(e);}
System.out.println(utente + " --> Logout effettuato");
break;
case 1: //Richiesta l'intera sequenza delle news
System.out.println(utente + " --> Richiesto l'invio delle news");
outS.reset();
outS.writeObject(mainHost.NM.getRSSArray());
outS.flush();
System.out.println(utente + " --> News inviate");
break;
case 2: //Richiesta di inserimento di un commento
System.out.println(utente + " --> Richiesto l'inserimento di un commento");
outS.writeObject(new ResponseMessage(1));
outS.flush();
inputMessage = (RequestMessage)inS.readObject(); //Attesa del messaggio di commento
int newsToComm = ((RequestMessage)inputMessage).getContent();
String Comm=((RequestMessage)inputMessage).getInformations();
System.out.println(utente + " invia il commento "+Comm+" per la notizia "+newsToComm);
try {
mainHost.NM.addCommentToNews(Comm,utente,newsToComm);
outS.writeObject(new ResponseMessage(1));
outS.flush();
System.out.println(utente + " --> Commento aggiunto");
}
catch(UnknownNewsException e) {
outS.writeObject(new ErrorMessage(e,12));
outS.flush();
System.out.println(utente + " --> Commento non aggiunto: notizia inesistente");
}
break;
}
}
};
break;




case 2: //Il client vuole creare una nuova utenza
outS.writeObject(new Message("Richiesta accolta, attesa dei dati completi"));
System.out.println(ThrID+": Ho ricevuto una richiesta di registrazione, attendo dati utente...");
break;
case 3: //Il client vuole eliminare un'utenza esistente
outS.writeObject(new Message("Richiesta accolta, attesa di Username e Password"));
System.out.println(ThrID+": Ho ricevuto una richiesta di eliminazione, attendo dati utente...");
break;

case 4: //Il client vuole una conferma dell'attività del server
System.out.println(ThrID+": Ho ricevuto una richiesta di ping, confermo attività");
outS.writeObject(new Message("Server attivo!"));
break;

default: //Valore non standard
outS.writeObject(new ErrorMessage(new UnexpectedMessageException(),1));
connected=false;
break;
}
} while(connected);
System.out.println(ThrID + ": Chiusura del thread");
outS.close();
inS.close();
socket.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}

[Fenomeno85]

il poli domina

abu in che scaglione sei?

Io sto in questo momento gestendo il server e devo dire che è un bel puttanaio ma divertente.

~§~ Sempre E Solo Lei ~§~