 | Mailing List | | Home | | Forum Home | | JBoss - Java Application Server | | Tomcat - JSP/Servlet container | | Struts - A MVC web framework | | iText - An open source PDF Java Library | | JDOM - JDOM XML Parser | | JSP - A mailing list about Java Server Pages specification and reference | | J2EE - A mailing list for Java(tm) 2 Platform, Enterprise Edition | | J2EE Pattern - An interest list for Sun Java Center J2EE Pattern Catalog | | Servlet - A mailing list for discussion about Sun Microsystem's Java Servlet API Technology | |
Struts & Hibernate
|
|
|
| | | multiple comet requests | multiple comet requests 2007-08-15 - By Filip Hanik - Dev Lists
Back
hi Peter, there was a recent large change in TC 6.0 to warn about
misconfigured server.xml
The easiest way to try out the fix is actually to build it from source
Here is how you do it
1. Make sure you have JDK 1.5, ANT and Subversion installed
2. svn co http://svn.apache.org/repos/asf/tomcat/tc6.0.x/trunk
3. cd trunk
4. ant
builds the code out to "cd output/build"
Filip
Peter Warren wrote:
> Filip, thank you for your very prompt response! I replaced the
> tomcat-coyote.jar with yours and now get the following exception on
> startup. Is there another jar that I need to update?
>
> Thanks,
> Peter
>
> Aug 14, 2007 9:02:29 PM org.apache.tomcat.util.digester.Digester startElement
> SEVERE: Begin event threw error
> java.lang.NoSuchMethodError:
> org.apache.tomcat.util.IntrospectionUtils.setProperty(Ljava/lang/Object;Ljava
/lang/String;Ljava/lang/String;)V
> at org.apache.catalina.startup.SetAllPropertiesRule.begin
(SetAllPropertiesRule.java:66)
> at org.apache.tomcat.util.digester.Digester.startElement(Digester.java
:1358)
> at com.sun.org.apache.xerces.internal.parsers.AbstractSAXParser
.startElement(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.parsers.AbstractXMLDocumentParser
.emptyElement(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl
.scanStartElement(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl
$FragmentContentDriver.next(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl.next
(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl
.scanDocument(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse
(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse
(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.parsers.XMLParser.parse(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.parsers.AbstractSAXParser.parse
(Unknown
> Source)
> at com.sun.org.apache.xerces.internal.jaxp.SAXParserImpl$JAXPSAXParser
.parse(Unknown
> Source)
> at org.apache.tomcat.util.digester.Digester.parse(Digester.java:1644)
> at org.apache.catalina.startup.Catalina.load(Catalina.java:504)
> at org.apache.catalina.startup.Catalina.load(Catalina.java:538)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
> at java.lang.reflect.Method.invoke(Unknown Source)
> at org.apache.catalina.startup.Bootstrap.load(Bootstrap.java:260)
> at org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:412)
>
> Filip Hanik - Dev Lists wrote:
> turns out that if the request is comet, the recycling of the
> input/output filter is not happening.
> I have fixed this,
> you can try the tomcat-coyote.jar from
> http://people.apache.org/~fhanik/tomcat/tomcat-coyote.jar
>
> Filip
>
> Filip Hanik - Dev Lists wrote:
>
> hi Peter,
> thanks for the example, I am able to reproduce this error, let me take
> a look and see why it is happening,
>
> Filip
>
> Peter Warren wrote:
> How do you send multiple requests to the same comet servlet?
>
> Sending multiple chunks of a single request is fine. My problem occurs
> after the client ends the chunked transaction by sending "0CRLFCRLF" to the
> server. The comet servlet correctly registers the END event.
>
> But then the client subsequently tries to initiate a new chunked request by
> sending new http headers and a new chunk. The comet servlet receives a
> BEGIN event, immediately followed by an END event. A READ event is never
> generated for the new chunk. No ERROR events are registered either.
>
> Sequence:
> 1st request
> BEGIN
> READ
> END
>
> 2nd request
> BEGIN
> END - why an END event and not a READ?
>
> Below are my test client and test comet servlet. Any thoughts on what I'm
> doing wrong?
>
> (I apologize in advance if this is a lack of understanding of http on my
> part. I have looked at the specs and tried to follow the rules but am still
> running into problems.)
>
> Thanks,
> Peter
>
> -- --
>
> <test servlet>
> import java.io.IOException;
> import java.io.InputStream;
>
> import javax.servlet.ServletException;
> import javax.servlet.http.HttpServlet;
> import javax.servlet.http.HttpServletRequest;
> import javax.servlet.http.HttpServletResponse;
>
> import org.apache.catalina.CometEvent;
> import org.apache.catalina.CometProcessor;
>
> public class CometTestServlet extends HttpServlet implements CometProcessor
> {
> private static final long serialVersionUID = 5472498184127924791L;
>
> public void event(CometEvent cometEvent) throws IOException,
> ServletException {
> HttpServletRequest request = cometEvent.getHttpServletRequest();
> HttpServletResponse response = cometEvent.getHttpServletResponse();
> // don't want timeout events
> cometEvent.setTimeout(1000000);
> if (cometEvent.getEventType() == CometEvent.EventType.BEGIN) {
> log("Begin for session: " + request.getSession(true).getId());
> } else if (cometEvent.getEventType() == CometEvent.EventType.ERROR)
> {
> log("Error for session: " + request.getSession(true).getId() +
> ", " + cometEvent.getEventSubType());
> cometEvent.close();
> } else if (cometEvent.getEventType() == CometEvent.EventType.END) {
> log("End for session: " + request.getSession(true).getId());
> cometEvent.close();
> } else if (cometEvent.getEventType() == CometEvent.EventType.READ) {
> log("Read for session: " + request.getSession(true).getId());
> respond(request, response);
> }
> }
>
> private void respond(HttpServletRequest request, HttpServletResponse
> response) throws IOException {
> String clientMessage = read(request);
>
> if (clientMessage != null && clientMessage.length() > 0) {
> response.getWriter().print(clientMessage);
> response.getWriter().flush();
> }
> }
>
> private String read(HttpServletRequest request) throws IOException {
> InputStream is = request.getInputStream();
> StringBuffer inputBuffer = new StringBuffer();
> byte[] buf = new byte[512];
> while (is.available() > 0) {
> int n = is.read(buf); // can throw an IOException
> if (n > 0) {
> inputBuffer.append(new String(buf, 0, n));
> log("Read " + n + " bytes: " + new String(buf, 0, n) + " for
> session: "
> + request.getSession(true).getId());
> } else if (n < 0) {
> log("comet read error");
> }
> }
> return inputBuffer.toString();
> }
> }
> </test servlet>
>
> -- --
>
> <test client>
> import java.io.IOException;
> import java.io.InputStream;
> import java.io.OutputStream;
> import java.net.Socket;
>
> public class CometTestClient1 {
>
> public static final String ENCODING = "ISO-8859 (See http://ISO-8859.ora-code.com)-1";
>
> private Socket socket;
>
> private OutputStream out;
>
> public static void main(String[] args) throws Exception {
> CometTestClient1 test = new CometTestClient1();
> test.test();
> }
>
> public CometTestClient1() throws IOException {
> initConnection();
> }
>
> private void initConnection() throws IOException {
> socket = new Socket("127.0.0.1", 80);
> socket.setKeepAlive(true);
> out = socket.getOutputStream();
> sendHeaders();
> }
>
> private void sendHeaders() throws IOException {
> println("GET /CometTest HTTP/1.1");
> println("Host: 127.0.0.1");
> println("User-Agent: test");
> println("Transfer-Encoding: chunked");
> println("Connection: keep-alive");
> }
>
> private void test() throws IOException {
> sendChunkedMessage();
> try {
> Thread.sleep(60000);
> } catch (InterruptedException ie) {
> ie.printStackTrace();
> }
> // doesn't seem to matter if I create a new socket connection or not
> //initConnection();
> sendHeaders();
> sendChunkedMessage();
>
> }
>
> private void sendChunkedMessage() throws IOException {
> println();
> println("10");
> print("test data test 1");
> out.flush();
>
> String line = read();
> System.out.println(line);
>
> println();
> println("0");
> println();
> out.flush();
>
> line = read();
> System.out.println(line);
> }
>
> private void print(String chars) throws IOException {
> out.write(chars.getBytes(ENCODING));
> }
>
> private void println(String chars) throws IOException {
> out.write((chars + "\r\n").getBytes(ENCODING));
> }
>
> private void println() throws IOException {
> out.write(("\r\n").getBytes(ENCODING));
> }
>
> private String read() throws IOException {
> InputStream in = socket.getInputStream();
> StringBuffer inputBuffer = new StringBuffer();
> byte[] buf = new byte[512];
> do {
> int n = in.read(buf); // can throw an IOException
> if (n > 0) {
> inputBuffer.append(new String(buf, 0, n));
> } else if (n < 0) {
> return ("read error");
> }
> } while (in.available() > 0);
> return inputBuffer.toString();
> }
> }
> </test client>
>
> -- --
>
> <test results>
> HTTP/1.1 200 OK
> Server: Apache-Coyote/1.1
> Set-Cookie: JSESSIONID=775B71AFC0066AA45224A4F00309D101; Path=/
> Transfer-Encoding: chunked
> Date: Tue, 14 Aug 2007 20:00:49 GMT
>
> 10
> test data test 1
>
> 0
>
>
> HTTP/1.1 200 OK
> Server: Apache-Coyote/1.1
> Set-Cookie: JSESSIONID=BF0C8B7A0D27CDCA6A285F9C4C598613; Path=/
> Content-Length: 0
> Date: Tue, 14 Aug 2007 20:00:49 GMT
>
>
> read error
> </test results>
>
> -- --
>
> connector configuration for tomcat 6.0.14 on windows xp:
> <Connector port="80" protocol="org.apache.coyote.http11.Http11NioProtocol"
> maxThreads="150" connectionTimeout="120000" keepAliveTimeout="300000"
> maxKeepAliveRequests="-1" socket.soKeepAlive="true" acceptorThreadCount="2"
> redirectPort="8443" />
>
> -- --
>
> Catalina log registering begin, read, and end events for initial request,
> followed by begin and end events for subsequent request:
>
> Aug 14, 2007 1:02:37 PM org.apache.catalina.core.ApplicationContext log
> INFO: CometTest: Begin for session: 910EA1A41AB07465D61585930564AFD0
> Aug 14, 2007 1:02:37 PM org.apache.catalina.core.ApplicationContext log
> INFO: CometTest: Read for session: 910EA1A41AB07465D61585930564AFD0
> Aug 14, 2007 1:02:37 PM org.apache.catalina.core.ApplicationContext log
> INFO: CometTest: End for session: 910EA1A41AB07465D61585930564AFD0
> Aug 14, 2007 1:02:37 PM org.apache.catalina.core.ApplicationContext log
> INFO: CometTest: Begin for session: 22A5A802D4A201A024939BE724A1F530
> Aug 14, 2007 1:02:37 PM org.apache.catalina.core.ApplicationContext log
> INFO: CometTest: End for session: 22A5A802D4A201A024939BE724A1F530
>
> -- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ----
>
> No virus found in this incoming message.
> Checked by AVG Free Edition. Version: 7.5.476 / Virus Database:
> 269.11.17/951 - Release Date: 8/13/2007 10:15 AM
>
>
> -- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ------
> To start a new topic, e-mail: users@(protected)
> To unsubscribe, e-mail: users-unsubscribe@(protected)
> For additional commands, e-mail: users-help@(protected)
>
>
>
>
>
> -- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ------
> To start a new topic, e-mail: users@(protected)
> To unsubscribe, e-mail: users-unsubscribe@(protected)
> For additional commands, e-mail: users-help@(protected)
>
> -- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ------
> To start a new topic, e-mail: users@(protected)
> To unsubscribe, e-mail: users-unsubscribe@(protected)
> For additional commands, e-mail: users-help@(protected)
>
>
>
>
-- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ---- ------
To start a new topic, e-mail: users@(protected)
To unsubscribe, e-mail: users-unsubscribe@(protected)
For additional commands, e-mail: users-help@(protected)
|
|
|
