java钩子使用实例

/**

* 初始化加载快照数据，此处注意加载最新的快照数据和优先加载快照

* @throws MetaClientException

*/

public void init() throws MetaClientException{

//先加载快照数据

initSnapshotData();

//从消息获取更新数据

MetaClientConfig metaClientConfig=new MetaClientConfig();

ZKConfig zkConfig = new ZKConfig();

zkConfig.zkConnect=zkConnect;

metaClientConfig.setZkConfig(zkConfig);

final BroadcastMessageSessionFactory  sessionFactory = new MetaBroadcastMessageSessionFactory(metaClientConfig);

        consumer = sessionFactory.createBroadcastConsumer(new ConsumerConfig(group));

        /* 本地测试时使用

        final MessageSessionFactory sessionFactory = new MetaMessageSessionFactory(metaClientConfig);

  ConsumerConfig consumerConfig=new ConsumerConfig(group);

        consumer = sessionFactory.createConsumer(consumerConfig); */

       

        //启动消费

        consumer();

        //设置关闭钩子

        Runtime.getRuntime().addShutdownHook(new Thread() { 

            public void run() { 

            try {

consumer.shutdown();//关闭消息消费

saveSnapshot();

businessLog.info("consumer shutdown Hook new snapshot");

} catch (MetaClientException e) {

businessLog.error("consumer shutdown error",e);

}

            } 

        });

       

        businessLog.info("mahoutDataModelManager init ok");

}