Сообщение кометы отправлено дважды - PullRequest
Новая
       36

Сообщение кометы отправлено дважды

1 голос
/ 29 января 2012

Я хочу использовать Cometd в своем проекте и пробовал его версию для Jetty 8 на сервере Tomcat 7. Это работает, но сообщение отправляется дважды.

Чтобы проверить, имеет ли это какое-либо отношение к остальной части проекта, я создал автономный проект только с этой функциональностью, и все равно получаю сообщение дважды.

Я не могу понять, почему это может быть.

В проекте 5 файлов:

  • pom.xml
  • web.xml
  • index.html
  • BayeuxInitializer.java
  • FormDataService.java

Вот код для каждого из файлов:

  • web.xml 

     <?xml version="1.0" encoding="UTF-8"?>
 <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee"
          xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
          xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
          id="WebApp_ID" version="2.5">
    <display-name>Sertal Vision</display-name>

    <servlet>
       <servlet-name>cometd</servlet-name>
       <servlet-class>org.cometd.server.CometdServlet</servlet-class>
       <init-param>
          <param-name>timeout</param-name>
          <param-value>60000</param-value>
       </init-param>
       <init-param>
          <param-name>logLevel</param-name>
          <param-value>3</param-value>
       </init-param>
       <load-on-startup>1</load-on-startup>
    </servlet>

    <servlet>
       <servlet-name>bayeux-init</servlet-name>
       <servlet-class>ch.sertal.server.BayeuxInitializer</servlet-class>
       <load-on-startup>2</load-on-startup>
    </servlet>

    <servlet-mapping>
       <servlet-name>cometd</servlet-name>
       <url-pattern>/cometd/*</url-pattern>
    </servlet-mapping>

    <servlet-mapping>
       <servlet-name>bayeux-init</servlet-name>
       <url-pattern>/bayeux/servlet/*</url-pattern>
    </servlet-mapping>

    <filter>
       <filter-name>continuation</filter-name>
       <filter-class>org.eclipse.jetty.continuation.ContinuationFilter</filter-class>
    </filter>

    <filter-mapping>
       <filter-name>continuation</filter-name>
       <url-pattern>/cometd/*</url-pattern>
    </filter-mapping>

    <welcome-file-list>
       <welcome-file>index.html</welcome-file>
    </welcome-file-list>

 </web-app>

  • index.html 

     <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
 <html>
 <head>
    <meta http-equiv="Content-Type" content="text/html;charset=utf-8"/>
    <script type="text/javascript" src="js/dojo/dojo/dojo.js"></script>
    <script type="text/javascript">
       var subscription = undefined;

       dojo.addOnLoad( function () {
          dojo.require( "dojox.cometd" );
          dojo.require("dojox.timing");
          // Disconnect when the page unloads
          dojo.addOnUnload( function () {
             dojox.cometd.disconnect( true );
          } );

          var cometURL = "cometd";
          dojox.cometd.init( cometURL );

          var subscription = dojox.cometd.subscribe( "/sertal/formData", function ( message ) {
             dojo.create( "li", {
                innerHTML:message.data.count
             }, dojo.byId( "message-list" ) );
          } );

          i = 1;
          var t = new dojox.timing.Timer();
          t.setInterval( 1000 );
          t.onTick = function() {
             dojox.cometd.publish( '/sertal/formData', { count: i++ } );
          };
          t.start();

       } );
    </script>
 </head>
 <body>

 <div>
    <ul id="message-list"/>
 </div>
 </body>
 </html>

  • BayeuxInitializer.java 

     package ch.sertal.server;

 import org.cometd.bayeux.server.BayeuxServer;

 import javax.servlet.GenericServlet;
 import javax.servlet.ServletException;
 import javax.servlet.ServletRequest;
 import javax.servlet.ServletResponse;
 import java.io.IOException;

 public class BayeuxInitializer extends GenericServlet {
    private static final long serialVersionUID = -9089442901563633963L;

    @Override
    public void init() throws ServletException {
       BayeuxServer bayeux = ( BayeuxServer ) getServletContext().getAttribute( BayeuxServer.ATTRIBUTE );

 //      new HelloService( bayeux );
       new FormDataService( bayeux, getServletContext() );

    }

    @Override
    public void service( ServletRequest servletRequest, ServletResponse servletResponse ) throws ServletException, IOException {
       throw new ServletException( "sorry :-)" );
    }
 }

  • FormDataService.java 

     package ch.sertal.server;

 import org.cometd.bayeux.Message;
 import org.cometd.bayeux.server.BayeuxServer;
 import org.cometd.bayeux.server.ServerSession;
 import org.cometd.server.AbstractService;

 import javax.servlet.ServletContext;
 import java.util.Map;

 /**
  * Created by IntelliJ IDEA.
  * User: micha.roon
  * Date: 1/16/12
  * Time: 12:25 PM
  * To change this template use File | Settings | File Templates.
  */
 public class FormDataService extends AbstractService {
    private ServletContext context = null;

    public FormDataService( BayeuxServer bayeux, ServletContext context ) {
       super( bayeux, "hello" );
       this.context = context;
       addService( "/sertal/formData", "processFormData" );
       System.out.println( "New FormDataService" );
    }

    public void processFormData( final ServerSession remote, Message message ) {
       Map<String, Object> input = message.getDataAsMap();

       remote.deliver( getServerSession(), "/sertal/formData", input, null );
    }
 }

  • pom.xml 

     <?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>BayeuxTest</groupId>
    <artifactId>BayeuxTest</artifactId>
    <version>1.0</version>

    <build>
       <plugins>
          <!--compiler plugin-->
          <plugin>
             <groupId>org.apache.maven.plugins</groupId>
             <artifactId>maven-compiler-plugin</artifactId>
             <configuration>
                <source>1.6</source>
                <target>1.6</target>
             </configuration>
          </plugin>

          <plugin>
             <groupId>org.codehaus.mojo</groupId>
             <artifactId>tomcat-maven-plugin</artifactId>
             <version>1.1</version>
             <configuration>
                <username>${tomcat.username}</username>
                <password>${tomcat.password}</password>
                <url>${tomcat.manager}</url>
                <path>${tomcat.context}</path>
             </configuration>
          </plugin>

       </plugins>
    </build>

    <dependencies>
       <dependency>
          <groupId>javax.servlet</groupId>
          <artifactId>javax.servlet-api</artifactId>
          <version>3.0.1</version>
          <scope>provided</scope>
       </dependency>

       <!--for cometd support-->
       <dependency>
          <groupId>org.cometd.java</groupId>
          <artifactId>bayeux-api</artifactId>
          <version>2.3.1</version>
       </dependency>
       <dependency>
          <groupId>org.cometd.javascript</groupId>
          <artifactId>cometd-javascript-jquery</artifactId>
          <version>2.3.1</version>
          <type>war</type>
       </dependency>
       <dependency>
          <groupId>org.cometd.java</groupId>
          <artifactId>cometd-java-server</artifactId>
          <version>2.3.1</version>
       </dependency>

       <dependency>
          <groupId>org.eclipse.jetty</groupId>
          <artifactId>jetty-servlets</artifactId>
          <version>8.0.4.v20111024</version>
          <exclusions>
             <exclusion>
                <groupId>org.eclipse.jetty</groupId>
                <artifactId>jetty-client</artifactId>
             </exclusion>
          </exclusions>
       </dependency>
       <dependency>
          <groupId>javax.servlet</groupId>
          <artifactId>servlet-api</artifactId>
          <version>2.5</version>
       </dependency>

    </dependencies>
 </project>

1 Ответ

0 голосов
/ 29 января 2012

Когда вы используете обычный канал ( / sertal / formData ), все опубликованные сообщения будут отправлены всем подписанным клиентам, в вашем случае это сам браузер и служба Bayeux. Поэтому вы получите два ответа: один - опубликованный вами пост, другой - ответ от вашей службы.

Решение: вы не хотите publish ваши данные формы, вы хотите это deliver ed: 

      ...
      t.onTick = function() {
         dojox.cometd.deliver( '/sertal/formData', { count: i++ } );
      };
      ...

Существуют и другие решения, например, используя служебный канал вместо обычного канала. См. Запись часто задаваемых вопросов CometD для дальнейших объяснений.

UPDATE:

Я отменил еще одно изменение, необходимое для этой работы на моем компьютере: dojo.require необходимо вызывать вне обработчика addOnLoad. 

     ...   
     dojo.require("dojox.cometd");
     dojo.require("dojox.timing");

     dojo.addOnLoad(function () {
         ...

Я использую Dojo v1.7.1.

...