cometd注解实现java端代码实例

package com.artrade.cometd; import javax.annotation.PostConstruct; import javax.inject.Inject; import javax.servlet.ServletContext; import org.cometd.annotation.ServerAnnotationProcessor; import org.cometd.bayeux.server.BayeuxServer; import org.cometd.bayeux.server.ConfigurableServerChannel; import org.cometd.server.BayeuxServerImpl; import org.cometd.server.authorizer.GrantAuthorizer; import org.springframework.beans.BeansException; import org.springframework.beans.factory.config.DestructionAwareBeanPostProcessor; import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component; import org.springframework.web.context.ServletContextAware; @Component public class Configurer implements DestructionAwareBeanPostProcessor, ServletContextAware { private BayeuxServer bayeuxServer; private ServerAnnotationProcessor processor; @Inject private void setBayeuxServer(BayeuxServer bayeuxServer) { this.bayeuxServer = bayeuxServer; } @PostConstruct private void init() { this.processor = new ServerAnnotationProcessor(bayeuxServer); bayeuxServer.createChannelIfAbsent("/auction/**", new ConfigurableServerChannel.Initializer() { public void configureChannel(ConfigurableServerChannel channel) { channel.addAuthorizer(GrantAuthorizer.GRANT_ALL); } }); } public Object postProcessBeforeInitialization(Object bean, String name) throws BeansException { processor.processDependencies(bean); processor.processConfigurations(bean); processor.processCallbacks(bean); return bean; } public Object postProcessAfterInitialization(Object bean, String name) throws BeansException { return bean; } public void postProcessBeforeDestruction(Object bean, String name) throws BeansException { processor.deprocessCallbacks(bean); } @Bean(initMethod = "start", destroyMethod = "stop") public BayeuxServer bayeuxServer() { BayeuxServerImpl bean = new BayeuxServerImpl(); bean.setOption(BayeuxServerImpl.LOG_LEVEL, "1"); bean.addTransport(new org.cometd.websocket.server.WebSocketTransport(bean)); return bean; } public void setServletContext(ServletContext servletContext) { servletContext.setAttribute(BayeuxServer.ATTRIBUTE, bayeuxServer); } }