{"id":316307,"date":"2021-02-04T03:44:54","date_gmt":"2021-02-03T19:44:54","guid":{"rendered":"http:\/\/4563.org\/?p=316307"},"modified":"2021-02-04T03:44:54","modified_gmt":"2021-02-03T19:44:54","slug":"%e5%bc%82%e6%ad%a5%e4%bb%bb%e5%8a%a1%e9%97%ae%e9%a2%98","status":"publish","type":"post","link":"http:\/\/4563.org\/?p=316307","title":{"rendered":"\u5f02\u6b65\u4efb\u52a1\u95ee\u9898"},"content":{"rendered":"
\n
\n
\n

\u5f02\u6b65\u4efb\u52a1\u95ee\u9898 <\/h1>\n

<\/p>\n

\n
\u8cc7\u6df1\u5927\u4f6c : qm332207252 <\/span> <\/i> 7<\/span> <\/div>\n
<\/div>\n<\/p><\/div>\n<\/p><\/div>\n<\/p><\/div>\n
<\/p>\n

\u4e00\u4e2a\u63a5\u53e3,\u63a5\u6536\u5230\u4e00\u6b21\u8bf7\u6c42,\u8c03\u7528 service \u6267\u884c\u5f02\u6b65\u4efb\u52a1,\u5f02\u6b65\u4efb\u52a1\u6267\u884c\u4e2d,\u76f4\u63a5\u8fd4\u56de\u54cd\u5e94,\u518d\u6b21\u8bf7\u6c42\u8be5\u63a5\u53e3\u6216\u8005\u5176\u4ed6\u7528\u6237\u8bf7\u6c42\u8be5\u63a5\u53e3(\u66f4\u6216\u8005\u662f\u81ea\u52a8\u4efb\u52a1\u6267\u884c),\u8c03\u7528 service,\u4e0a\u6b21\u8bf7\u6c42\u8fd9\u4e2a\u4efb\u52a1\u8fd8\u5728\u6267\u884c\u4e2d,\u56e0\u6b64\u8fd4\u56de\u5904\u7406\u4e2d,\u8fd9\u79cd java \u540e\u53f0\u6709\u6bd4\u8f83\u597d\u7684\u5b9e\u73b0\u5417?<\/p>\n<\/p><\/div>\n

\u5927\u4f6c\u6709\u8a71\u8aaa<\/b> (15<\/span>) <\/div>\n
<\/div>\n<\/p><\/div>\n<\/p><\/div>\n
    \n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : dqzcwxb <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u52a0\u4e2a\u9501 <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : stonewu <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u6700\u7b80\u5355\u7684\u65b9\u5f0f\u5c31\u662f\u5b9a\u4e49\u4e00\u4e2a\u5168\u5c40\u53d8\u91cf <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : qm332207252 <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    @dqzcwxb \u80fd\u8be6\u7ec6\u70b9\u8bf4\u660e\u4e0b\u4e0d <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : zoharSoul <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u8bb0\u5230\u4efb\u52a1\u8868. <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : qm332207252 <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    @stonewu \u6211\u4e5f\u60f3\u8fc7\u5728\u8c03\u7528\u5f02\u6b65\u65b9\u6cd5\u5916\u9762\u7528\u4e2a\u4ec0\u4e48\u53d8\u91cf\u6807\u8bb0\u6267\u884c\u72b6\u6001 <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : MicroGalaxy <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u8fd9\u79cd\u9700\u6c42\u8fd8\u662f\u5168\u5c40\u53d8\u91cf\u6700\u7b80\u5355\u597d\u7528 <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u4e3b<\/span> \u8cc7\u6df1\u5927\u4f6c : qm332207252 <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    @MicroGalaxy \u7c7b\u4f3c\u524d\u7aef\u505a\u767b\u5f55\u6309\u94ae,\u8bf7\u6c42\u8868\u683c\u6570\u636e\u4ec0\u4e48\u7684\u5f02\u6b65\u8bf7\u6c42\u52a0\u72b6\u6001\u6807\u8bb0\u90a3\u6837\u54af? <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : killergun <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    Ticket \uff1f\u6839\u636e Ticket \u6765\u83b7\u53d6\u8fdb\u5c55 <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : guoyuchuan <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u5f02\u6b65\u4efb\u52a1\u53ef\u4ee5\u914d\u7f6e\u7ebf\u7a0b\u6c60\uff0c\u8fd9\u6837\u5c31\u4e0d\u4f1a\u5b58\u5728\u4f60\u8bf4\u7684\u8fd9\u4e2a\u95ee\u9898\u4e86 <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : guoyuchuan <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    @guoyuchuan #9 \u4e0d\u5bf9\uff0c\u8bf4\u9519\u4e86 <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : liian2019 <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u5355\u673a\u5c31\u6574\u4e2a AtomicBoolean\uff0c\u5206\u5e03\u5f0f\u5c31\u6574\u4e2a redis \u8bb0\u4e00\u4e0b <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : RedBeanIce <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    java \u5f02\u6b65\u4efb\u52a1\u6709\u5f88\u591a\u65b9\u6cd5\uff0cCompletableFuture.runAsync<\/p>\n

    \u81f3\u4e8e\u7b2c\u4e8c\u6b21\u8fdb\u6765\u7684\u95ee\u9898\uff0c\u52a0\u4e2a\u9501\u5c31\u884c\uff0c\u4e0a\u6709\u8bf4\u660e\uff0c\u5355\u673a\u548c\u5206\u5e03\u5f0f <\/p><\/div>\n<\/p><\/div>\n<\/li>\n

  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : oneisall8955 <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u5355\u673a\u8fd8\u662f\u96c6\u7fa4\uff0c\u5355\u673a\u914d\u53ea\u9759\u6001\u53d8\u91cf\uff0c\u96c6\u7fa4\u641e redis\uff0c\u52a0\u4e2a key \u6807\u8bc6 <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : siweipancc <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    \u5360\u5751# <\/div>\n<\/p><\/div>\n<\/li>\n
  • \n
    \n
    \n
    \u8cc7\u6df1\u5927\u4f6c : siweipancc <\/span> <\/div>\n
    <\/i> <\/span> <\/div>\n<\/p><\/div>\n
    @Log
    @RestController
    @SpringBootApplication
    public class WebApplication {<\/p>\n

    public static void main(String[] args) {
    SpringApplication.run(WebApplication.class, args);
    }<\/p>\n

    static final String CREATED = “create”;
    static final String PROCESS = “process”;
    static final String COMPLETE = “complete”;<\/p>\n

    @PostMapping(“generate”)
    public ResponseEntity<Response> generate(@RequestBody Request request) {
    return ResponseEntity.ok(generate(request.input, request.taskId));
    }<\/p>\n

    @Autowired
    private RedisTemplate<Object, Object> redisTemplate;
    @Autowired
    private ThreadPoolTaskExecutor executor;<\/p>\n

    @PostConstruct
    public void init() {
    redisTemplate.setKeySerializer(RedisSerializer.string());
    redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    }<\/p>\n

    Function<UUID, String> valKeyFunc = uuid -> “value::” + uuid;
    Duration expire = Duration.ofMinutes(30L);<\/p>\n

    public Response generate(Integer input, UUID taskId) {<\/p>\n

    if (taskId == null) {
    check(input != null, “\u8bf7\u8f93\u5165\u503c”);
    UUID uuid = createTask(input);
    return new Response(CREATED, null, uuid, expire.getSeconds());
    }<\/p>\n

    String key = valKeyFunc.apply(taskId);
    Long expire = redisTemplate.getExpire(key);
    Entity value;
    try {
    value = (Entity) redisTemplate.opsForValue().get(key);
    } catch (ClassCastException e) {
    log.warning(e.getMessage());
    e.printStackTrace();
    throw new RuntimeException(“\u670d\u52a1\u5668\u5185\u90e8\u9519\u8bef”);
    }
    check(value != null, “\u4efb\u52a1 ” + taskId + ” \u4e0d\u5b58\u5728\u6216\u8005\u5df2\u7ecf\u8fc7\u671f”);
    assert value != null;
    check(value.complete != null, “\u670d\u52a1\u5668\u5185\u90e8\u9519\u8bef”);
    if (!value.complete) {
    return new Response(PROCESS, null, taskId, expire);
    }<\/p>\n

    return new Response(COMPLETE, value, taskId, expire);
    }<\/p>\n

    private static void check(Boolean condition, String msg) {
    if (!Boolean.TRUE.equals(condition)) {
    throw new RuntimeException(msg);
    }
    }<\/p>\n

    private UUID createTask(Integer input) {
    UUID uuid = UUID.randomUUID();
    executor.execute(() -> {
    try {
    Entity entity = new Entity(uuid, false, new Date(), null, input, null);
    log.info(String.format(“begin task: %s, input: %s”, uuid, input));
    String key = valKeyFunc.apply(uuid);
    redisTemplate.opsForValue().set(key, entity, expire);
    log.info(String.format(“set task: %s, input: %s, key: %s”, uuid, input, key));
    TimeUnit.SECONDS.sleep(RandomUtil.randomInt(10, 20));
    String value = RandomUtil.randomString(Math.abs(input));
    entity.complete = true;
    entity.completeTime = new Date();
    entity.output = value;
    log.info(String.format(“end task: %s, input: %s, generated: %s”, uuid, input, value));
    redisTemplate.opsForValue().set(key, entity, expire);
    } catch (InterruptedException e) {
    log.warning(e.getMessage());
    e.printStackTrace();
    }
    });
    return uuid;
    }<\/p>\n

    @Data
    static class Request {
    Integer input;
    UUID taskId;
    }<\/p>\n

    @AllArgsConstructor
    @NoArgsConstructor
    @Data
    static class Response {
    String status;
    Object data;
    UUID taskId;
    Long expire;
    }<\/p>\n

    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    static class Entity {
    UUID taskId;
    Boolean complete;
    Date beginTime;
    Date completeTime;<\/p>\n

    Integer input;
    String output;
    }<\/p>\n

    } <\/p><\/div>\n<\/p><\/div>\n<\/li>\n

  • \n","protected":false},"excerpt":{"rendered":"

    \u5f02\u6b65\u4efb\u52a1\u95ee\u9898 \u8cc7\u6df1\u5927\u4f6c : qm3…<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[],"tags":[],"_links":{"self":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/316307"}],"collection":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=316307"}],"version-history":[{"count":0,"href":"http:\/\/4563.org\/index.php?rest_route=\/wp\/v2\/posts\/316307\/revisions"}],"wp:attachment":[{"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=316307"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=316307"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/4563.org\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=316307"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}