<web-app xmlns="http://java.sun.com/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
         http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
         version="2.5"> 

    <servlet> 
        <servlet-name>cometd</servlet-name> 
        <servlet-class> 
 org.cometd.server.continuation.ContinuationCometdServlet 
 </servlet-class> 
        <init-param> 
            <param-name>timeout</param-name> 
            <param-value>60000</param-value> 
        </init-param> 
    </servlet> 
    <servlet-mapping> 
        <servlet-name>cometd</servlet-name> 
        <url-pattern>/cometd/*</url-pattern> 
    </servlet-mapping> 

    <filter> 
        <filter-name>cross-origin</filter-name> 
        <filter-class>org.eclipse.jetty.servlets.CrossOriginFilter</filter-class> 
    </filter> 
    <filter-mapping> 
        <filter-name>cross-origin</filter-name> 
        <url-pattern>/cometd/*</url-pattern> 
    </filter-mapping> 

 </web-app>

 <servlet> 
 <servlet-name>cometd</servlet-name> 
 <servlet-class>org.cometd.java.annotation.AnnotationCometdServlet</servlet-class> 
 <init-param> 
 <param-name>logLevel</param-name> 
 <param-value>1</param-value> 
 </init-param> 
 <init-param> 
 <param-name>services</param-name> 
 <param-value>org.cometd.examples.ChatService</param-value> 
 </init-param> 
 <load-on-startup>1</load-on-startup> 
 </servlet> 
 <servlet-mapping> 
 <servlet-name>cometd</servlet-name> 
 <url-pattern>/cometd/*</url-pattern> 
 </servlet-mapping> 

 <servlet> 
 <servlet-name>cometdDemo</servlet-name> 
 <servlet-class>org.cometd.examples.CometdDemoServlet</servlet-class> 
 <load-on-startup>2</load-on-startup> 
 </servlet>

 public void init() throws ServletException 
 { 
 final BayeuxServerImpl bayeux = 
 (BayeuxServerImpl)getServletContext().getAttribute(BayeuxServer.ATTRIBUTE); 
 if (bayeux==null) 
 throw new UnavailableException("No BayeuxServer!"); 
 ................. 
 // 创建扩展点
 bayeux.addExtension(new TimesyncExtension()); 
 bayeux.addExtension(new AcknowledgedMessagesExtension()); 
 // 设定握手连接权限
 bayeux.getChannel(ServerChannel.Meta_HANDSHAKE).addAuthorizer( 
  GrantAuthorizer.GRANT_PUBLISH); 
 // 启动服务渠道
 ServerAnnotationProcessor processor = new ServerAnnotationProcessor(bayeux); 
 processor.process(new EchoRPC()); 
 processor.process(new Monitor()); 
 //processor.process(new ChatService()); 

 bayeux.createIfAbsent("/foo/bar/baz",new ConfigurableServerChannel.Initializer() 
 { 
 public void configureChannel(ConfigurableServerChannel channel) 
 { 
 channel.setPersistent(true); 
 } 
 }); 
 if (bayeux.getLogger().isDebugEnabled()) 
 System.err.println(bayeux.dump()); 
 ................. 
 }

 @Service("echo")
public static class EchoRPC
{
	@Session
	private ServerSession _session;

	@SuppressWarnings("unused")
	@Configure("/service/echo")
	private void configureEcho(ConfigurableServerChannel channel)
	{
		channel.addAuthorizer(GrantAuthorizer.GRANT_SUBSCRIBE_PUBLISH);
	}

	@Listener("/service/echo")
	public void doEcho(ServerSession session,ServerMessage message)
	{
		Map<String,Object> data = message.getDataAsMap();
		Log.info("ECHO from "+session+" "+data);
		
		for(int i = 0; i < 50; i++){
			session.deliver(_session,message.getChannel(),data,null);
		}
	}
}

 @Service("monitor") 
 public static class Monitor 
 { 
 @Listener("/Meta/subscribe") 
 public void monitorSubscribe(ServerSession session,ServerMessage message) 
 { 
 Log.info("Monitored Subscribe from "+session+" for "
           +message.get(Message.SUBSCRIPTION_FIELD)); 
 } 

 @Listener("/Meta/unsubscribe") 
 public void monitorUnsubscribe(ServerSession session,ServerMessage message) 
 { 
 Log.info("Monitored Unsubscribe from "+session+" for "
           +message.get(Message.SUBSCRIPTION_FIELD)); 
 } 

 @Listener("/Meta/*") 
 public void monitorMeta(ServerSession session,ServerMessage message) 
 { 
 if (Log.isDebugEnabled()) 
 Log.debug(message.toString()); 
 } 
 }

 <servlet> 
 ............... 
 <init-param> 
 <param-name>services</param-name> 
 <param-value>org.cometd.examples.ChatService</param-value> 
 </init-param> 
 <load-on-startup>1</load-on-startup> 
 </servlet>

 @Service("chat") 
 public class ChatService 
 { 
 .......................................... 
    @Listener("/service/members") 
    public void handleMembership(ServerSession client,ServerMessage message) 
    { 
        Map<String,Object> data = message.getDataAsMap(); 
        final String room = ((String)data.get("room")).substring("/chat/".length()); 
        Map<String,String> roomMembers = _members.get(room); 
        if (roomMembers == null) 
        { 
            Map<String,String> new_room = new ConcurrentHashMap<String,String>(); 
            roomMembers = _members.putIfAbsent(room,new_room); 
            if (roomMembers == null) roomMembers = new_room; 
        } 
        final Map<String,String> members = roomMembers; 
        String userName = (String)data.get("user"); 
        members.put(userName,client.getId()); 
        client.addListener(new ServerSession.RemoveListener() 
        { 
            public void removed(ServerSession session,boolean timeout) 
            { 
                members.values().remove(session.getId()); 
                broadcastMembers(room,members.keySet()); 
            } 
        }); 
        broadcastMembers(room,members.keySet()); 
    } 
    private void broadcastMembers(String room,Set<String> members) 
    { 
        // Broadcast the new members list 
        ClientSessionChannel channel = 
                 _session.getLocalSession().getChannel("/members/"+room); 
        channel.publish(members); 
    } 
 .......................................... 
    @Listener("/service/privatechat") 
    protected void privateChat(ServerSession client,Object> data = message.getDataAsMap(); 
        String room = ((String)data.get("room")).substring("/chat/".length()); 
        Map<String,String> membersMap = _members.get(room); 
        if (membersMap==null) 
        { 
            Map<String,String>new_room=new ConcurrentHashMap<String,String>(); 
            membersMap=_members.putIfAbsent(room,new_room); 
            if (membersMap==null) 
                membersMap=new_room; 
        } 
        String[] peerNames = ((String)data.get("peer")).split(","); 
        ArrayList<ServerSession> peers = new ArrayList<ServerSession>(peerNames.length); 
 ................. 
    } 
 }