Erreur "Premature end of file" / ServletFilter

Version imprimable

Bonjour,

J'ai créé un filter sur ma servlet d'Axis pour l'entrée des requêtes Soap de manière à récupérer la requête Soap pour la traiter ailleurs.

Donc j'ai une ServletFilter qui est mappé à ma servlet axis "/services/*" et donc pour chaque appel à un web service elle va rentrer dans le filtre.

Voici le code du DoFilter :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 @Override public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { try { InputStream in=request.getInputStream(); StringBuffer xmlStr=new StringBuffer(); int d; while((d=in.read()) != -1){ xmlStr.append((char)d); } System.out.println("Requête SOAP : "+xmlStr.toString()); chain.doFilter(request,response); } catch (IOException io) { System.out.println ("IOException raised in SimpleFilter"); } catch (ServletException se) { System.out.println ("ServletException raised in SimpleFilter"); } }
Donc je cherche uniquement à afficher ma requête entrante sauf que le problème c'est lorsque je fais appel à mon Web Service via SOAPUI, j'ai ça en réponse :
Code:

1 2 3 4 5 6 7 8 9 10 11 <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> <soapenv:Body> <soapenv:Fault> <faultcode>soapenv:Server.userException</faultcode> <faultstring>org.xml.sax.SAXParseException: Premature end of file.</faultstring> <detail> <ns1:hostname xmlns:ns1="http://xml.apache.org/axis/">EQ-300523178</ns1:hostname> </detail> </soapenv:Fault> </soapenv:Body> </soapenv:Envelope>
J'ai regardé pas mal sur google et malheureusement, je n'ai rien trouvé de convaincant.

Et je précise que si je commente ma boucle qui écrit dans mon buffer, j'ai pas de problème, comme ci il avait pas le temps de tout écrire ou je ne sais quoi.

Merci d'avance

28/11/2012, 18h51
fxrobin

C'est parce qu'un Stream ne peut être lu qu'une seule fois.

Donc, il faut que tu le lises effectivement pour ton propre besoin, et en même temps il faut que tu fasses ta propre "HttpServletRequestWrapper" et faire en sorte que le getInputStream tape sur ton propre flux généré pendant le parcours.

C'est ensuite ce wrapper qui est passé en paramètre du "doFilter(...)" à la place de la vraie request.
29/11/2012, 09h50
flolebreton

Je comprends pas tout mais je le lis pas qu'une fois mon Stream à moins qu'il le lise lors de la requête et lors de la réponse ce qui devrait m'afficher 2 fois ma requête dans ma console ce qui n'est pas le cas :/

Donc pour ne lire qu'une fois, je dois créer un Wrapper donc d'après ce que j'ai vu, ça permet de modifier une requête ou une réponse mais je vois pas comment me servir de celui-ci dans mon cas.

Parce que ce dont j'avais pensé, c'était de récupérer le stream de la request, de le lire, de l'afficher puis ensuite de passer ma requête dans un Wrapper et de la passer au DoFilter.

Mais je pense avoir loupé quelque chose parce qu'au final, je retrouve le même genre de problème.
29/11/2012, 13h29
NoClassDefFound

Dans ton filtre tu lis complètement le flux avec l'instruction while((d=in.read()) != -1).
Lorsque tu arrives sur l'instruction chain.doFilter(request,response), tu as déjà complètement consommé le flux de la request pour les objets suivants.
Plus concrètement, imaginons que tu ais un second filtre chainé à la suite de ton premier filtre.
Si dans ce second filtre tu essaies de lire le flux de la request de la même façon, cela plantera car le flux a déjà été consommé dans ton premier filtre.

Tu consommes le flux de la flux de la requête :

Code:

1
2
3
4
5
6
InputStream in=request.getInputStream();
StringBuffer xmlStr=new StringBuffer();
int d;
while((d=in.read()) != -1){
   xmlStr.append((char)d);
}

Axis2 n'a donc plus rien à lire. Il faut donc "wrapper" le requête pour fournir un nouveau flux basé sur le buffer.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
//Read request input
ByteArrayOutputStream buffer = new ByteArrayOutputStream();
InputStream requestInput = request.getInputStream();
byte[] temp = new byte[4086];
int n;
while ( (n = requestInput.read(temp, 0, temp.length)) >= 0) {
  buffer.write(temp, 0, n);
}
//Discard buffer to limit memory usage
final byte[] bytes = buffer.toByteArray();
buffer = null;
HttpServletRequestWrapper requestWrapper = new HttpServletRequestWrapper(request) {
  InputStream inputStream = null;
  BufferedReader reader = null;
 
  public synchronized InputStream getInputStream() {
    if (reader != null) throw new IllegalStateException("Reader was already opened");
	if (inputStream == null) {
	  inputStream = new ByteArrayInputStream(bytes);
	}
	return inputStream;
  }
 
  public synchronized BufferedReader getReader() {
    if (inputStream != null) throw new IllegalStateException("InputStream was already opened");
    if (reader == null) {
	   ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
	   String encoding = getCharacterEncoding();
	   InputStreamReader isr;
	   if (encoding != null) {
	     isr = new InputStreamReader(bais, encoding);
	   }
	   else {
	     //See specification (Servlet | HTTP) for default encoding
	     isr = new InputStreamReader(bais);
	   }
	   reader = new BufferedReader(isr);
    }
	return reader;
  }
}
chain.doFilter(requestWrapper, response);

PS : Au passage ne fait pas de conversion byte <-> char par toi même.