对Item中定时器的理解

一、Diamond介绍

Diamond主要提供持久配置的发布和订阅服务，最大特点是结构简单，稳定可靠。

主要的使用场景：TDDL使用Diamond动态切换数据库，动态扩容等；业务使用Diamond推送系统开关配置。

架构如下：

发布或者更新配置数据时，步骤如下：

• 写入MySql数据库
• 写本地磁盘
• 通知集群其他机器去数据库dump更新的数据

订阅方获取配置数据时，直接读取服务端本地磁盘文件，尽量减少对数据库压力。 这种架构用短暂的延时换取最大的性能和一致性，一些配置不能接受延时的情况下，通过API可以获取数据库中的最新配置。

数据获取模型：

客户端采用推拉结合的策略在长连接和短连接之间取得一个平衡，让服务端不用太关注连接的管理，又可以获得长连接的及时性。

• 客户端发起一个对比请求到服务端，请求中包含客户端订阅的数据的指纹
• 服务端检查客户端的指纹是否与最新数据匹配
  • 如果匹配，服务端持有连接
  • 如果30秒内没有相关数据变化，服务端持有连接30秒后释放
  • 如果30秒内有相关数据变化，服务端立即返回变化数据的ID
• 如果不匹配，立即返回变化数据的ID
• 客户端根据变化数据的ID去服务端获取最新的内容

Diamond通过这种推拉结合的方式，让客户端逻辑尽量简单，而且高效。

二、Diamond和DTS接入

接入步骤：

0.生成dts的groupId

在[国内测试集群] 日常、二套：http://ops.jm.taobao.net/dts-console/中创建dts分组

1.引入diamond-client和dts-client的maven依赖

<dependency>
   <groupId>com.taobao.diamond</groupId>
   <artifactId>diamond-client</artifactId>
   <version>3.6.9.2</version>
</dependency>

<dependency>
  <groupId>com.alibaba.dts</groupId>
  <artifactId>dts-client</artifactId>
  <version>0.0.3.9</version>
</dependency>

2.spring中配置Diamond

<bean id="jobSwitch" class="com.taobao.cun.item.diamond.JobSwitch"></bean>
<!-- diamond配置 -->
<bean id="deleteLogConfigManager" class="com.taobao.cun.item.diamond.ConfigManager"
        init-method="init">
        <property name="dataId" value="cuntaoic-timer-configure"></property>
        <property name="groupId" value="timer-group"></property>
        <property name="receivers">
            <map>
                <entry key="allSellerCheckOpen" value-ref="jobSwitch"></entry>
                <entry key="pullDownAllProductOpen" value-ref="jobSwitch"></entry>
            </map>
        </property>
</bean>

初始化SpringContext时，执行ConfigManager的init方法初始化Diamond，通过Diamond.addListener(dataId, groupId, managerListener)注册监听器,监听器的作用是用于监听服务端数据的变化，client端会定时的向服务端检测数据的变化，当数据变化时，会及时返回给client。监听器中，提供了处理新数据的回调方法receiveConfigInfo。

Diamond.addListener(dataId, groupId, new ManagerListener() {
                public void receiveConfigInfo(String configInfo) {
                    try {
                        processConfig(configInfo);
                    } catch (IOException e) {
                        log.error("processConfig error", e);
                    }
                }

                public Executor getExecutor() {
                    return null;
                }
            });

processConfig(configInfo)方法处理配置服务中心更新的配置信息，这里获取的是作业开关的关闭状态

3.spring中配置DTS任务调度框架

<bean id="dtsClient" class="com.alibaba.dts.client.DtsClient"
        init-method="init">
        <property name="groupId">
            <value>${cuntao.ic.timer.dts.group.id}</value><!--此处填写控制台创建分组后生成的分组ID -->
        </property>
</bean>    

三、Job任务开发

1.在这里定时钟任务开发只需实现SimpleJobProcessor接口，如下文的删除日志Job

public class DeleteLogJob implements SimpleJobProcessor {

    public ProcessResult process(SimpleJobContext context) {
        try {
            Runtime.getRuntime().exec("rm -rf /home/admin/logs/*.log");
        } catch (IOException e) {
            e.printStackTrace();
        }
        return new ProcessResult(true);//true表示执行成功，false表示失败
    }

}

2.在后台进行Job配置

在定时表达式中输入：0 0 1 * * ?，这样就可以在每天的凌晨1点执行删除任务了

四、测试与发布

参照杨威的文档cuntaoic定时钟开发规范