public class SafeServlet extends HttpServlet {

    private JID serverAddress;

    private MessageRouter router;

    private UserManager userManager;

    @Override

    public void init() throws ServletException {

        super.init();

    }

    @Override

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {

        super.doGet(request, response);

        // 获取服务器地址

        serverAddress = new JID(XMPPServer.getInstance().getServerInfo().getXMPPDomain());

        router = XMPPServer.getInstance().getMessageRouter();

        userManager = UserManager.getInstance();

        System.out.println("Require SafeServlet GET Method");

        // 创建消息类

        final Message message = new Message();

        message.setFrom(serverAddress);

        message.setSubject("Test subject");

        message.setBody("Test body");

        message.setType(Message.Type.chat);

        // 获取所有用户

        Collection<User> users = userManager.getUsers();

        String xmppdomain = "@" + JiveGlobals.getProperty("xmpp.domain");

        // 对所有用户进行遍历，发送消息

        for (User u : users)

        {

            // 创建需要发送消息的备份，只将发送对象进行修改

            final Message newMessage = message.createCopy();

            newMessage.setTo(u.getUsername() + xmppdomain);

            try {

                TimerTask messageTask = new TimerTask() {

                    @Override

                    public void run() {

                        router.route(newMessage);

                    }

                };

                TaskEngine.getInstance().schedule(messageTask, 5000);

            } catch (Exception e) {

                Log.error(e.getMessage(), e);

            }

        }

    }

    @Override

    public void destroy() {

        super.destroy();

        serverAddress = null;

        router = null;

        userManager = null;

    }

}