Mina向已连接的session主动推送消息

@Override
    public void sessionOpened(IoSession session) throws Exception {

                Thread thread = new Thread(new Runnable() {
            public void run() {
                Random random = new Random();
                try {
                    while(true){
                        int r1 = 1+random.nextInt(10);
                        int r2 = 5+random.nextInt(10);
                        for (int i = 0; i <r1 ; i++) {
                            session.write("hello");
                        }
                        for (int i = 0; i <r2 ; i++) {
                            session.write("well");
                        }

                        Thread.sleep(1200);
                    }
                } catch (Exception e) {
                    System.out.println("Send message error!!!--" + e.getMessage());
                    e.printStackTrace();
                }
            }
        });
        thread.start();
        System.out.println("client handler close session ......");

    }