zoukankan      html  css  js  c++  java
  • 定时任务集群部署

    <dubbo:monitor protocol="registry"/>
    <dubbo:application name="oolp">
    <!--设置dubbo优雅停机,超时30秒,缺省为10秒-->
    <dubbo:parameter key="shutdown.timeout" value="30000"/>
    </dubbo:application>
    <!-- 注册中心的ip地址 -->
    <dubbo:registry protocol="zookeeper" address="${zkservers}"/>
    <!--&lt;!&ndash; 扫描注解包路径,多个包用逗号分隔,不填pacakge表示扫描当前ApplicationContext中所有的类 &ndash;&gt;-->
    <dubbo:annotation package="com.hispeed.teamcontract.service.impl" />
    <dubbo:consumer check="false" retries="0" timeout="12000"/>
    <dubbo:protocol name="dubbo" port="20789"/>
    <!--<dubbo:provider delay="-1" timeout="6000" retries="0"/>-->
    <dubbo:provider timeout="12000" retries="0"/>
    @Configuration
    @ImportResource({ "classpath:config/*.xml" })
    public class DubboConfig {
    }


    private ZKLeaderLatch zkLeaderLatch;

    @Autowired
    public ScheduledTaskServiceImpl(ZKLeaderLatch zkLeaderLatch) {
    this.zkLeaderLatch = zkLeaderLatch;
    }

    @Scheduled(fixedRate = 1 * 60 * 1000)
    @Override
    public void teamContractScheduledTask() {
    if(this.zkLeaderLatch.isLeader()){
        //定时执行任务
      }
    }
    com.boot.zookeeper.ZKLeaderLatch-|-[leaderLatch start....]
  • 相关阅读:
    python 多个变量赋值
    python标准数据类型
    Python 变量类型
    H3C 扩展ACL与基于时间的ACL
    H3C BGP-filter-policy
    H3C 标准ACL
    H3C BGP实验集合
    H3C IS-IS实验大集合(ipv6)
    H3C ISIS实验大集合(IPv4)
    JS 封装一个显示时间的函数
  • 原文地址:https://www.cnblogs.com/liangmm/p/11652031.html
Copyright © 2011-2022 走看看