{"id":2967,"date":"2023-07-14T16:57:38","date_gmt":"2023-07-14T08:57:38","guid":{"rendered":"https:\/\/xinchewhd.com.cn\/?p=2967"},"modified":"2023-07-14T16:57:39","modified_gmt":"2023-07-14T08:57:39","slug":"springboot%e5%af%b9%e6%8e%a5kafka%e6%89%b9%e9%87%8f%e3%80%81%e5%b9%b6%e5%8f%91%e3%80%81%e5%bc%82%e6%ad%a5%e8%8e%b7%e5%8f%96%e6%b6%88%e6%81%af%e5%b9%b6%e5%8a%a8%e6%80%81%e3%80%81%e6%89%b9%e9%87%8f-2","status":"publish","type":"post","link":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/springboot%e5%af%b9%e6%8e%a5kafka%e6%89%b9%e9%87%8f%e3%80%81%e5%b9%b6%e5%8f%91%e3%80%81%e5%bc%82%e6%ad%a5%e8%8e%b7%e5%8f%96%e6%b6%88%e6%81%af%e5%b9%b6%e5%8a%a8%e6%80%81%e3%80%81%e6%89%b9%e9%87%8f-2\/","title":{"rendered":"springBoot\u5bf9\u63a5kafka,\u6279\u91cf\u3001\u5e76\u53d1\u3001\u5f02\u6b65\u83b7\u53d6\u6d88\u606f,\u5e76\u52a8\u6001\u3001\u6279\u91cf\u63d2\u5165\u5e93\u8868"},"content":{"rendered":"

\u00a0<\/span>\u00a0 \u00a0 \u00a0 \u00a0 <\/span>\u00a0<\/span>

<\/section>\n

\u4e00\u3001\u80cc\u666f<\/span><\/strong><\/p>\n

\u56e0\u4e1a\u52a1\u53d1\u5c55\u9700\u8981\uff0c\u9700\u8981\u5bf9\u63a5kafka\uff0c\u5feb\u901f\u6279\u91cf\u63a5\u6536\u6d88\u606f\u65e5\u5fd7\uff0c\u907f\u514d\u6d88\u606f\u65e5\u5fd7\u7d2f\u79ef\u8fc7\u591a\uff0c\u5fc5\u987b\u505a\u5230\u6570\u636e\u5904\u7406\u540e\uff0c\u52a8\u6001\u63d2\u5165\u5230\u5e93\u8868(\u76f8\u540c\u8868\u7ed3\u6784\uff0c\u4e0d\u540c\u8868\u540d)<\/span>\u4e0b\uff0c\u5e76\u4e14\u8fd8\u8981\u652f\u6301\u6279\u91cf\u4e8b\u52a1<\/span>\u63d0\u4ea4,\u5b9e\u73b0\u6d88\u606f\u5feb\u901f\u6d88\u8d39\u3002(\u6ce8\u610f\uff1a\u6e90\u7801\u6587\u7ae0\u6700\u540e\u6709\u83b7\u53d6\u65b9\u5f0f<\/span>)<\/p>\n

\u4e8c\u3001\u6838\u5fc3\u4ee3\u7801<\/span><\/strong><\/p>\n

2.1\u3001\u5f00\u542f\u6279\u91cf\u3001\u5e76\u53d1\u6d88\u8d39<\/strong><\/span><\/p>\n

\n
kafka<\/span>:<\/span><\/code>\n    bootstrap-servers<\/span>: 10.1<\/span>.*.*:9092<\/span>     #\u670d\u52a1\u5668\u7684ip<\/span>\u53ca\u7aef\u53e3\uff0c\u53ef\u4ee5\u5199\u591a\u4e2a\uff0c\u670d\u52a1\u5668\u4e4b\u95f4\u7528\u201c\uff1a\u201d\u95f4\u9694<\/span><\/code>\n\u00a0\u00a0\u00a0\u00a0producer<\/span>:\u00a0#\u751f\u4ea7\u8005\u914d\u7f6e\u00a0<\/span><\/code>\n      key-serializer<\/span>: org<\/span>.apache<\/span>.kafka<\/span>.common<\/span>.serialization<\/span>.StringSerializer<\/span><\/span><\/code>\n      value-serializer<\/span>: org<\/span>.apache<\/span>.kafka<\/span>.common<\/span>.serialization<\/span>.StringSerializer<\/span><\/span><\/code>\n    consumer<\/span>: #\u6d88\u8d39\u8005\u914d\u7f6e<\/span><\/code>\n      #\u6307\u5b9a\u9ed8\u8ba4\u6d88\u8d39\u8005group<\/span> id<\/span> --<\/span>> \u7531\u4e8e\u5728kafka<\/span>\u4e2d\uff0c\u540c\u4e00\u7ec4\u4e2d\u7684consumer<\/span>\u4e0d\u4f1a\u8bfb\u53d6\u5230\u540c\u4e00\u4e2a\u6d88\u606f\uff0c\u4f9d\u9760groud<\/span>.id<\/span>\u8bbe\u7f6e\u7ec4\u540d<\/span><\/code>\n      group-id<\/span>: myGroup<\/span>                 #\u8bbe\u7f6e\u6d88\u8d39\u8005\u7684\u7ec4id<\/span> default<\/span>\uff1aGroup<\/span><\/span><\/code>\n      enable-auto-commit<\/span>: true<\/span>  #\u8bbe\u7f6e\u81ea\u52a8\u63d0\u4ea4offset<\/span><\/span><\/code>\n      auto-commit-interval<\/span>: 2000  #\u9ed8\u8ba4\u503c\u4e3a5000<\/span><\/code>\n      key-deserializer<\/span>: org<\/span>.apache<\/span>.kafka<\/span>.common<\/span>.serialization<\/span>.StringDeserializer<\/span><\/span><\/code>\n      #\u503c\u7684\u53cd\u5e8f\u5217\u5316\u65b9\u5f0f<\/span><\/code>\n      value-serializer<\/span>: org<\/span>.apache<\/span>.kafka<\/span>.common<\/span>.serialization<\/span>.StringSerializer<\/span><\/span><\/code>\n      auto-offset-reset<\/span>: latest<\/span><\/span><\/code>\n      max-poll-records<\/span>: 2000  #\u6279\u91cf\u4e00\u6b21\u6700\u5927\u62c9\u53d6\u6570\u636e\u91cf \u9ed8\u8ba4500<\/span><\/code>\n    listener<\/span>:<\/span><\/code>\n      # poll-timeout<\/span>: 1000<\/span><\/code>\n      type<\/span>: batch<\/span>  # \u5f00\u542f\u6279\u91cf\u6d88\u8d39<\/span><\/code>\n      concurrency<\/span>: 3  #\u6307\u5b9alistener<\/span> \u5bb9\u5668\u4e2d\u7684\u7ebf\u7a0b\u6570\uff0c\u7528\u4e8e\u63d0\u9ad8\u5e76\u53d1\u91cf<\/span><\/code>\n    properties<\/span>:<\/span><\/code>\n      session<\/span>:<\/span><\/code>\n        timeout<\/span>:<\/span><\/code>\n          ms<\/span>: 120000  #\u9ed8\u8ba410000<\/span><\/code>\n        max<\/span>:<\/span><\/code>\n          poll<\/span>:<\/span><\/code>\n            interval<\/span>:<\/span><\/code>\n              ms<\/span>: 600000  #\u9ed8\u8ba4300000(5\u5206\u949f)<\/span><\/code><\/pre>\n<\/section>\n
\u00a0\u00a0\u00a0 \u00a0\u8bf4\u660e<\/strong>\uff1atype: batch \u00a0# \u5f00\u542f\u6279\u91cf\u6d88\u8d39\uff0c max-poll-records: 2000\uff0c\u6279\u91cf\u6d88\u8d39\u6bcf\u6b21\u6700\u591a\u6d88\u8d39\u8bb0\u5f55\u6570\u3002\u8fd9\u91cc\u8bbe\u7f6e max-poll-records\u662f2000\uff0c\u5e76\u4e0d\u662f\u8bf4\u5982\u679c\u6ca1\u6709\u8fbe\u52302000\u6761\u6d88\u606f\uff0c\u6211\u4eec\u5c31\u4e00\u76f4\u7b49\u5f85\u3002\u800c\u662f\u8bf4\u4e00\u6b21poll\u6700\u591a\u8fd4\u56de\u7684\u8bb0\u5f55\u6570\u4e3a2000\u3002concurrency: 3 \u00a0#\u6307\u5b9alistener \u5bb9\u5668\u4e2d\u7684\u7ebf\u7a0b\u6570\uff0c\u7528\u4e8e\u63d0\u9ad8\u5e76\u53d1\u91cf\u3002\u6ce8\u610f\uff1a\u5e76\u53d1\u91cf\u6839\u636e\u5b9e\u9645\u5206\u533a\u6570\u51b3\u5b9a\uff0c\u5fc5\u987b\u5c0f\u4e8e\u7b49\u4e8e\u5206\u533a\u6570\uff0c\u5426\u5219\u4f1a\u6709\u7ebf\u7a0b\u4e00\u76f4\u5904\u4e8e\u7a7a\u95f2\u72b6\u6001\u3002\u4f8b\u5982:\u8bbe\u7f6econcurrency\u4e3a3\uff0c\u4e5f\u5c31\u662f\u5c06\u4f1a\u542f\u52a83\u6761\u7ebf\u7a0b\u8fdb\u884c\u76d1\u542c\uff0c\u800c\u8981\u76d1\u542c\u7684topic\u67095\u4e2apartition\uff0c\u610f\u5473\u7740\u5c06\u67092\u6761\u7ebf\u7a0b\u90fd\u662f\u5206\u914d\u52302\u4e2apartition\uff0c\u8fd8\u67091\u6761\u7ebf\u7a0b\u5206\u914d\u52301\u4e2apartition\u3002<\/p>\n
2.2\u3001\u591a\u7ebf\u7a0b\u5f02\u6b65\u914d\u7f6e<\/strong><\/span><\/p>\n
\u00a0\u00a0\u00a0\u00a0\u5177\u4f53\u914d\u7f6e\u53c2\u52a0\u524d\u9762\u6587\u7ae0\uff1a<\/strong><\/span>SpringBoot\u4f7f\u7528@Async\u5b9e\u73b0\u591a\u7ebf\u7a0b\u5f02\u6b65<\/a><\/p>\n
\u00a0\u00a0\u00a0\u00a0\u6ce8\u610f<\/strong>\uff1a\u5728\u542f\u52a8\u7c7b\u4e0a\u9700\u8981\u52a0\u4e0a\u6ce8\u89e3@EnableAsync\uff0c\u5f00\u542f\u5f02\u6b65\u3002<\/p>\n
2.3\u3001redis\u76f8\u5173\u914d\u7f6e<\/strong><\/span><\/p>\n
1\u3001yml\u76f8\u5173\u914d\u7f6e\uff1a<\/strong><\/span><\/p>\n
\n
spring<\/span>:<\/span><\/code>\n  redis<\/span>:<\/span><\/code>\n    # \u5730\u5740<\/span><\/span><\/code>\n    host<\/span>: 127.0.0.1<\/span><\/span><\/code>\n    # \u7aef\u53e3\uff0c\u9ed8\u8ba4\u4e3a6379<\/span><\/span><\/code>\n    port<\/span>: 6379<\/span><\/span><\/code>\n    # \u5bc6\u7801<\/span><\/span><\/code>\n    # \u8fde\u63a5\u8d85\u65f6\u65f6\u95f4<\/span><\/span><\/code>\n    timeout<\/span>: 10s<\/span><\/span><\/code>\n    lettuce<\/span>:<\/span><\/code>\n      pool<\/span>:<\/span><\/code>\n        # \u8fde\u63a5\u6c60\u4e2d\u7684\u6700\u5c0f\u7a7a\u95f2\u8fde\u63a5<\/span><\/span><\/code>\n        min-idle<\/span>: 0<\/span><\/span><\/code>\n        # \u8fde\u63a5\u6c60\u4e2d\u7684\u6700\u5927\u7a7a\u95f2\u8fde\u63a5<\/span><\/span><\/code>\n        max-idle<\/span>: 8<\/span><\/span><\/code>\n        # \u8fde\u63a5\u6c60\u7684\u6700\u5927\u6570\u636e\u5e93\u8fde\u63a5\u6570<\/span><\/span><\/code>\n        max-active<\/span>: 8<\/span><\/span><\/code>\n        # #\u8fde\u63a5\u6c60\u6700\u5927\u963b\u585e\u7b49\u5f85\u65f6\u95f4\uff08\u4f7f\u7528\u8d1f\u503c\u8868\u793a\u6ca1\u6709\u9650\u5236\uff09<\/span><\/span><\/code>\n        max-wait<\/span>: -1ms<\/span><\/span><\/code><\/pre>\n<\/section>\n
2\u3001RedisConfig\u914d\u7f6e<\/strong><\/span><\/p>\n
\n
package<\/span> com.wonders.config;<\/span><\/code>\n<\/span><\/code>import<\/span> com.fasterxml.jackson.annotation<\/span>.JsonAutoDetect;<\/span><\/code>import<\/span> com.fasterxml.jackson.annotation<\/span>.PropertyAccessor;<\/span><\/code>import<\/span> com.fasterxml.jackson.databind.ObjectMapper;<\/span><\/code>import<\/span> org.springframework.cache.annotation<\/span>.CachingConfigurerSupport;<\/span><\/code>import<\/span> org.springframework.context.annotation<\/span>.Bean;<\/span><\/code>import<\/span> org.springframework.context.annotation<\/span>.Configuration;<\/span><\/code>import<\/span> org.springframework.data<\/span>.redis.connection.RedisConnectionFactory;<\/span><\/code>import<\/span> org.springframework.data<\/span>.redis.core.RedisTemplate;<\/span><\/code>import<\/span> org.springframework.data<\/span>.redis.serializer.Jackson2JsonRedisSerializer;<\/span><\/code>import<\/span> org.springframework.data<\/span>.redis.serializer.StringRedisSerializer;<\/span><\/code>\n<\/span><\/code>\/**<\/span><\/span><\/code>\n * \u3008\u81ea\u5b9a\u4e49redis\u5e8f\u5217\u5316\u65b9\u5f0f\u3009<\/span><\/span><\/code>\n * @author<\/span> yangyalin<\/span><\/span><\/code>\n * @create<\/span> 2018\/11\/1<\/span><\/span><\/code>\n * @since<\/span> 1.0.0<\/span><\/span><\/code>\n *\/<\/span><\/span><\/code>\n@Configuration<\/span><\/span><\/code>\npublic<\/span> class<\/span> RedisConfig<\/span> extends<\/span> CachingConfigurerSupport<\/span> <\/span>{<\/span><\/code>\n    \/**<\/span><\/span><\/code>\n     * @Author<\/span> yangyalin<\/span><\/span><\/code>\n     * @Description<\/span> redisTemplate\u5e8f\u5217\u5316\u4f7f\u7528\u7684jdkSerializeable, \u5b58\u50a8\u4e8c\u8fdb\u5236\u5b57\u8282\u7801\uff08\u9ed8\u8ba4\uff09, \u6240\u4ee5\u81ea\u5b9a\u4e49\u5e8f\u5217\u5316\u7c7b<\/span><\/span><\/code>\n     * \u7528\u4e8e\u5b58\u50a8\u53ef\u89c6\u5316\u5185\u5bb9<\/span><\/span><\/code>\n     * @Date<\/span> 15:07 2018\/11\/1<\/span><\/span><\/code>\n     * @Param<\/span> [redisConnectionFactory]<\/span><\/span><\/code>\n     * @return<\/span> org.springframework.data.redis.core.RedisTemplate<java.lang.Object,java.lang.Object><\/span><\/span><\/code> \n    **\/<\/span><\/span><\/code>\n    @Bean<\/span><\/span><\/code>\n    public<\/span> RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){<\/span><\/code>\n        RedisTemplate<Object,Object> redisTemplate=new RedisTemplate();<\/span><\/code>\n        redisTemplate.setConnectionFactory(redisConnectionFactory);<\/span><\/code>\n        \/\/\u4f7f\u7528jackson2JsonRedisSerializer\u66ff\u6362\u9ed8\u8ba4\u5e8f\u5217\u5316<\/span><\/span><\/code>\n        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer=new Jackson2JsonRedisSerializer(Object.class<\/span>);<\/span><\/code>\n        ObjectMapper objectMapper=new ObjectMapper();<\/span><\/code>\n        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);<\/span><\/code>\n        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);<\/span><\/code>\n        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);<\/span><\/code>\n        \/\/\u8bbe\u7f6ekey\u548cvalue\u7684\u5e8f\u5217\u5316\u89c4\u5219<\/span><\/span><\/code>\n        redisTemplate.setKeySerializer(new StringRedisSerializer());<\/span><\/code>\n        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);<\/span><\/code>\n        redisTemplate.setHashKeySerializer(jackson2JsonRedisSerializer);<\/span><\/code>\n        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);<\/span><\/code>\n        redisTemplate.afterPropertiesSet();<\/span><\/code>\n        return<\/span> redisTemplate;<\/span><\/code>\n    }<\/span><\/code>\n}<\/span><\/code>\n<\/span><\/code><\/pre>\n<\/section>\n
2.4\u3001\u52a8\u6001\u8868\u540d<\/strong><\/span><\/p>\n
\n
    <!--\u63d2\u5165\u5230kafka\u65e5\u5fd7\u4e34\u65f6\u8868\u4e2d--><\/span><\/code>\n    <insert id=\"insertMsgInfoTemp\"<\/span> parameterType=\"com.wonders.entity.KafkaMsgConfig\"<\/span>><\/span><\/code>\n      INSERT INTO ${logTableName}<\/span>(\"EVN_LOG_ID\"<\/span>, \"TABLE_NAME\"<\/span>, \"OPERATION\"<\/span>, \"PK_VALUE1\"<\/span>, \"PK_VALUE2\"<\/span>,<\/span><\/code>\n           \"PK_VALUE3\"<\/span>, \"PK_VALUE4\"<\/span>, \"PK_VALUE5\"<\/span>, \"TRANS_FLAG\"<\/span>, \"PKS\"<\/span>, \"BASE_CODE\"<\/span>, \"PLA_BRANCH_CODE\"<\/span>,<\/span><\/code>\n           \"CREATE_TIME\"<\/span>,\"MSG_PRODUCE_TIME\"<\/span>)<\/span><\/code>\n      VALUES (#{id,jdbcType=VARCHAR}, #{tableName,jdbcType=VARCHAR}, #{operation,jdbcType=VARCHAR},<\/span><\/span><\/code>\n            #{pk1,jdbcType=VARCHAR}, #{pk2,jdbcType=VARCHAR},#{pk3,jdbcType=VARCHAR},<\/span><\/span><\/code>\n            #{pk4,jdbcType=VARCHAR},#{pk5,jdbcType=VARCHAR}, 'Y',<\/span><\/span><\/code>\n            #{pks,jdbcType=VARCHAR}, #{baseCode,jdbcType=VARCHAR},<\/span><\/span><\/code>\n            #{plaBranchCode,jdbcType=VARCHAR},sysdate,#{msgProduceTime,jdbcType=VARCHAR})<\/span><\/span><\/code>\n    <\/insert><\/span><\/code><\/pre>\n<\/section>\n
\u00a0\u00a0\u00a0\u00a0\u8bf4\u660e<\/strong>\uff1a1\u3001#{} \uff1a\u4f1a\u6839\u636e\u53c2\u6570\u7684\u7c7b\u578b\u8fdb\u884c\u5904\u7406\uff0c\u5f53\u4f20\u5165String\u7c7b\u578b\uff0c\u5219\u4f1a\u4e3a\u53c2\u6570\u52a0\u4e0a\u53cc\u5f15\u53f7(\u5360\u4f4d\u7b26);2\u3001${} \uff1a\u5c06\u53c2\u6570\u53d6\u51fa\u4e0d\u505a\u4efb\u4f55\u5904\u7406\uff0c\u76f4\u63a5\u653e\u5165\u8bed\u53e5\u4e2d\uff0c\u5c31\u662f\u7b80\u5355\u7684\u5b57\u7b26\u4e32\u66ff\u6362(\u66ff\u6362\u7b26)\u3002<\/p>\n
2.5\u3001sql\u6279\u91cf\u63d0\u4ea4<\/strong><\/p>\n
\n
    public<\/span> void<\/span> batchInsert<\/span>(List<KafkaMsgInfo> kafkaMsgInfoList<\/span>) throws Exception<\/span>{<\/span><\/code>\n        \/\/\u5982\u679c\u81ea\u52a8\u63d0\u4ea4\u8bbe\u7f6e\u4e3atrue,\u5c06\u65e0\u6cd5\u63a7\u5236\u63d0\u4ea4\u7684\u6761\u6570\uff0c\u6539\u4e3a\u6700\u540e\u7edf\u4e00\u63d0\u4ea4<\/span><\/span><\/code>\n        \/\/ \u521b\u5efasession\u5b9e\u5217<\/span><\/span><\/code>\n        SqlSessionFactory sqlSessionFactory = ApplicationContextUtils.getBean(\"sqlSessionFactory\"<\/span>);<\/span><\/code>\n        \/\/ \u5f00\u542f\u6279\u91cf\u5904\u7406\u6a21\u5f0f BATCH \u3001\u5173\u95ed\u81ea\u52a8\u63d0\u4ea4\u4e8b\u52a1 false<\/span><\/span><\/code>\n        SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false<\/span>);<\/span><\/code>\n        KafkaMsgConfigMapper KafkaMsgMapper = sqlSession.getMapper(KafkaMsgConfigMapper.class);<\/span><\/code>\n        int<\/span> BATCH = 1000<\/span>;<\/span><\/code>\n        for<\/span> (int<\/span> i = 0<\/span>,size=kafkaMsgInfoList.size(); i < size; i++) {<\/span><\/code>\n            \/\/\u5faa\u73af\u63d2\u5165 + \u5f00\u542f\u6279\u5904\u7406\u6a21\u5f0f<\/span><\/span><\/code>\n            KafkaMsgMapper.insertKafkaMsgInfo(kafkaMsgInfoList.get<\/span>(i));<\/span><\/code>\n            if<\/span> (i != 0<\/span> && i % BATCH == 0<\/span>) {<\/span><\/code>\n                sqlSession .commit();<\/span><\/code>\n            }<\/span><\/code>\n        }<\/span><\/code>\n        \/\/ \u4e00\u6b21\u6027\u63d0\u4ea4\u4e8b\u52a1<\/span><\/span><\/code>\n        sqlSession.commit();<\/span><\/code>\n        \/\/ \u5173\u95ed\u8d44\u6e90<\/span><\/span><\/code>\n        sqlSession.close();<\/span><\/code>\n    }<\/span><\/code>\n<\/span><\/code><\/pre>\n<\/section>\n
\u00a0<\/strong><\/strong><\/p>\n
2.6\u3001\u4e1a\u52a1\u4ee3\u7801<\/strong><\/strong><\/p>\n
\n
    @KafkaListener(topics = {\"${mykafka.topics:mytopic}\"<\/span>})<\/span><\/code>\n    public<\/span> void<\/span> myMQConsumer<\/span>(List<String> msgList)<\/span><\/span>{<\/span><\/code>\n        log<\/span>.info(\"\u63a5\u6536\u5230\u7684\u6d88\u606f\u6761\u6570size\uff1a\"<\/span>+msgList.size());<\/span><\/code>\n        \/\/\u8ba1\u7b97\u7a0b\u5e8f\u8017\u65f6\u65f6\u95f4<\/span><\/span><\/code>\n        StopWatch stopWatch = new<\/span> StopWatch();<\/span><\/code>\n        \/\/ \u5f00\u59cb\u8ba1\u65f6<\/span><\/span><\/code>\n        stopWatch.start();<\/span><\/code>\n        this<\/span>.getKafkaMsgAndDel(msgList);  \/\/2\u3001\u63a5\u6536kafka\u65e5\u5fd7\u5e76\u89e3\u6790<\/span><\/span><\/code>\n        stopWatch.stop();<\/span><\/code>\n        log<\/span>.info(\"\u672c\u6b21\u4efb\u52a1\u8017\u65f6(\u79d2)\uff1a\"<\/span> + stopWatch.getLastTaskTimeMillis()\/1000<\/span> + \"s\"<\/span>);<\/span><\/code>\u00a0\u00a0\u00a0\u00a0}<\/span><\/code><\/pre>\n<\/section>\n
\u4e09\u3001\u6d4b\u8bd5\u7ed3\u679c<\/span><\/strong><\/p>\n