atmosphere - 在 Atmosphere 中广播，要扩展哪个类？

Question

我正在使用大气框架，并且正在运行在 ServletContextListener 中启动的线程。

我想广播这个线程放在上下文中的数据，但是我很困惑我必须扩展什么类来实现 ServletContextAttributeListener。

我目前正在扩展 OnMessage 类，但这似乎还不够。

public class SerialComInit implements ServletContextListener {
        //..
        private static final String SHUTDOWN_REQ = "SHUTDOWN";
        public void attributeAdded(ServletContextAttributeEvent event) {

            queue = (BlockingQueue<String>) event.getServletContext().getAttribute("serialPortData");

            //TODO Use jackson to generate JSON
            //TODO Implement SHUTDOWN command on server side
            //we always get a null here on first try that's why I added null check
            if (queue == null){
                System.out.println("Queue is empty");
            } else {
                String item;
                try {
                    //blocks while queue is empty
                    while ((item = queue.take()) != SHUTDOWN_REQ) {
                        System.out.println("*******WEB*******"+item+"*******");
                        //TODO Broadcast message to connected clients
                    }
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    System.out.println("queue error");
                    //e.printStackTrace();
                }
            }       
        }
   //..
}

Answer 1

我通过扩展 AbstractReflectorAtmosphereHandler 解决了我的问题。

在我的 ServletContextAttributeListener -> attributeAdded 调用它使用

MetaBroadcaster.getDefault().broadcastTo("/", "message");