Thanks Rasik. But my solution serves for any kind of output through Cocoon, not just for XML output, both readers and generators
After testing a litlle more, I will shortly make it available though the Wiki. I don't know why but now it works ok. -------- David -----Mensaje original----- De: Rasik Pandey [mailto:[EMAIL PROTECTED] Enviado el: martes, 13 de enero de 2004 15:40 Para: [EMAIL PROTECTED] Asunto: RE : Gzip pipeline processor Maybe this would be useful: http://wiki.cocoondev.org/Wiki.jsp?page=Gzip_XML_Serializer See the endDocument() method in the attached java class. >-----Message d'origine----- >De : Carmona Perez, David [mailto:[EMAIL PROTECTED] >Envoyé : mardi 13 janvier 2004 12:52 >À : Cocoon (E-mail) >Objet : Gzip pipeline processor > > >Hi everybody, > >I've created a new ProcessingPipeline, in order to compress >with gzip. I want finer control and integration with Cocoon >that the standard servlet filters may offer. > >It works ok, but the problem I have with it, is that the >browser is terribly slow when getting the different >components of a page (images, CSS sheets, scripts, ...). >Does someone know if there is any detail I have left off? >I suspect of not flushing the ouput stream. Where is it >flushed or closed? > >Any help will be greatly appreciated. > >Here is the full source code: > >/** Creado en 12-ene-2004 */ >package fcc.ima.cocoon; > >import java.io.ByteArrayOutputStream; >import java.io.IOException; >import java.io.OutputStream; >import java.net.SocketException; >import java.util.Map; >import java.util.zip.GZIPOutputStream; > >import org.apache.cocoon.ConnectionResetException; >import org.apache.cocoon.ProcessingException; >import >org.apache.cocoon.components.pipeline.impl.NonCachingProcessin >gPipeline; >import org.apache.cocoon.environment.Environment; >import org.apache.cocoon.environment.ObjectModelHelper; >import org.apache.cocoon.environment.Request; >import org.apache.cocoon.environment.Response; > >/**Pipeline that may compress the content with gzip. > * @author dperezcar */ >public class GzipNonCachingProcessingPipeline extends >NonCachingProcessingPipeline { > static protected class StreamHandler { > protected OutputStream getStream(Environment >environment, int outputBufferSize, boolean >shouldSetContentLength) throws IOException { > // Copy parameters > this.environment = environment; > > OutputStream result; > if (shouldSetContentLength) { > bufferStream = new >ByteArrayOutputStream(); > if (shouldCompress()) { > result = gs = new >GZIPOutputStream(bufferStream); > } else { > result = bufferStream; > } > } else { > if (shouldCompress()) { > result = gs = new >GZIPOutputStream(environment.getOutputStream(0)); > } else { > result = >environment.getOutputStream(outputBufferSize); > } > } > if (gs != null) { > Response resp = >ObjectModelHelper.getResponse(environment.getObjectModel()); > >resp.addHeader("Content-Encoding", "gzip"); > } > return result; > } > protected void end() throws IOException { > if (gs != null) { > gs.finish(); > } > if (bufferStream != null) { > byte[] data = >bufferStream.toByteArray(); > >environment.setContentLength(data.length); > OutputStream out = >environment.getOutputStream(0); > out.write(data); > out.flush(); > out.close(); > } else if (gs != null) { > gs.flush(); > gs.close(); > } > } > protected boolean shouldCompress() { > Map objModel = environment.getObjectModel(); > Request req = >ObjectModelHelper.getRequest(objModel); > if (req != null) { > String ae = >req.getHeader("accept-encoding"); > if (ae != null && >ae.indexOf("gzip") != -1) { > Response resp = >ObjectModelHelper.getResponse(objModel); > if (resp != null && >!resp.containsHeader("content-encoding")) { > >//getLogger().debug("GZIP supported, compressing."); > return true; > } else { > >//getLogger().debug("Content-encoding already set."); > } > } > } > return false; > } > protected Environment environment; > protected ByteArrayOutputStream bufferStream; > protected GZIPOutputStream gs; > } > /** @see >org.apache.cocoon.components.pipeline.AbstractProcessingPipeli >ne#processReader(org.apache.cocoon.environment.Environment) */ > protected boolean processReader(Environment >environment) throws ProcessingException { > try { > getLogger().info("Ini reader"); > StreamHandler sh = new StreamHandler(); > >reader.setOutputStream(sh.getStream(environment, >outputBufferSize, reader.shouldSetContentLength())); > reader.generate(); > sh.end(); > getLogger().info("End reader"); > } catch ( SocketException se ) { > if (se.getMessage().indexOf("reset") > 0 > || >se.getMessage().indexOf("aborted") > 0 > || >se.getMessage().indexOf("connection abort") > 0) { > throw new >ConnectionResetException("Connection reset by peer", se); > } else { > throw new >ProcessingException("Failed to execute reader pipeline.", se); > } > } catch ( ProcessingException e ) { > throw e; > } catch ( Exception e ) { > throw new ProcessingException("Error >executing reader pipeline.",e); > } > return true; > } > > /** @see >org.apache.cocoon.components.pipeline.AbstractProcessingPipeli >ne#processXMLPipeline(org.apache.cocoon.environment.Environment) */ > protected boolean processXMLPipeline(Environment >environment) throws ProcessingException { > try { > getLogger().info("Ini XML"); > if (this.serializer != this.lastConsumer) { > // internal processing > this.generator.generate(); > } else { > StreamHandler sh = new StreamHandler(); > >serializer.setOutputStream(sh.getStream(environment, >outputBufferSize, serializer.shouldSetContentLength())); > // execute the pipeline: > generator.generate(); > sh.end(); > } > getLogger().info("End XML"); > } catch ( ProcessingException e) { > throw e; > } catch ( Exception e ) { > throw new ProcessingException("Failed >to execute pipeline.", e); > } > return true; > } >} > > > >-------- >David > > >--------------------------------------------------------------------- >To unsubscribe, e-mail: [EMAIL PROTECTED] >For additional commands, e-mail: [EMAIL PROTECTED] > --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED] --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
