cometd后端直接publish消息给client

package testcomet
import org.cometd.client.*;
import org.eclipse.jetty.client.HttpClient;
class TestcometdService {

    static transactional = true

    def serviceMethod() {
       HttpClient _httpClient;
     _httpClient = new HttpClient();
        _httpClient.setMaxConnectionsPerAddress(20000);
        _httpClient.setIdleTimeout(15000);
        _httpClient.start();
  BayeuxClient client = new BayeuxClient(_httpClient, "http://localhost:8082/cometd");
  client.start();

  Map<String, Object> data = new HashMap<String, Object>();
  // Fill in the data
  data.msg="test msg";
  client.publish("/chat/membersd", data, null);

    }
}

评论

1 楼 bcw104 2012-02-18  

官方推荐的方式为采用LocalSession:

@Named
@Singleton
@Service("ExternalEventBroadcaster")
public class ExternalEventBroadcaster {
	private final static Logger log = LoggerFactory
			.getLogger(ExternalEventBroadcaster.class);

	@Inject
	private BayeuxServer bayeux;

	private LocalSession localSession;

	@PostConstruct
	public void init() {
		this.localSession = bayeux.newLocalSession("external");
		this.localSession.handshake();
		
		log.info("Web服务器广播服务初始化完毕.");

	}

	public void onExternalEvent() {

		ServerChannel channel = bayeux.getChannel("/chat/hello");
		if (channel != null) {
			// Broadcast the data
			channel.publish(localSession, "你好", null);
		}
	}

}