代码之家 › 专栏 › 技术社区 › clay

垂直。x链异步逻辑?

vert.x asynchronous

clay · 技术社区 · 8 年前

有没有更明智的方法来编写以下超级简单的set/get/close测试程序?注意,我必须复制Redis close代码,并将其包含在set error path和get complete path中。

import io.vertx.core.Vertx;
import io.vertx.redis.RedisClient;
import io.vertx.redis.RedisOptions;

public class RedisTest {
    public static void main(String[] args) throws Exception {
        Vertx vertx = Vertx.vertx();

        String host = "localhost";

        final RedisClient client = RedisClient.create(vertx,
                new RedisOptions().setHost(host));

        client.set("key", "value", r -> {
            if (r.succeeded()) {
                System.out.println("key stored");

                client.get("key", s -> {
                    if (s.succeeded()) {
                        System.out.println("Retrieved value: " + s.result());
                    } else {
                        System.out.println("Connection or Operation Failed " + s.cause());
                    }

                    System.out.println("Closing Redis connection");
                    client.close(t -> {
                        if (s.succeeded()) {
                            System.out.println("Redis closed successfully.");
                        } else {
                            System.out.println("Connection or Operation Failed " + t.cause());
                        }

                        System.out.println("Closing vertx");
                        vertx.close();
                    });
                });
            } else {
                System.out.println("Connection or Operation Failed " + r.cause());

                System.out.println("Closing Redis connection");
                client.close(s -> {
                    if (s.succeeded()) {
                        System.out.println("Redis closed successfully.");
                    } else {
                        System.out.println("Connection or Operation Failed " + s.cause());
                    }

                    System.out.println("Closing vertx");
                    vertx.close();
                });
            }
        });

        System.out.println("Exiting main");
    }
}

1 回复 | 直到 8 年前

zella 8 年前

我建议看反应式api io.vertx.rxjava.redis.RedisClient

例如(我没有测试过这段代码):

    client.rxSet("key", "value")
      .flatMap(r -> client.rxGet("key"))
      //calls on error or success
      .doAfterTerminate(() -> {
          client.rxClose();
          vertx.close();
      }) 
      .subscribe(
        success -> System.out.println("Chain completed"),
        //all errors will be there
        error -> System.out.println(error.getMessage())
      );

推荐文章

Jan Kück · 如何避免在等待未来完成时循环?

2 年前

Gero Mendy · 如何为一个类分配兵变的结果。查询

2 年前

Anthony Heaney · Quarkus测试失败:无法调用“io.vertx.ext.web.RoutingContext.get(String)”,因为“context”为null

2 年前

badnun872 · 通过注释在Quarkus中进行转发(启用客户端路由)的请求或响应过滤器

2 年前

til_b · 在vert.x中,有没有一种方法可以将replyAddress()转发到另一个服务,使其响应原始请求?

3 年前

Lokesh Pandey haseeb · 使用Chime Scheduler每隔5分钟执行一次

8 年前

Francesco · 模拟顶点。io异步处理程序

8 年前

elPsyChris · Vertx Eventbus无法发送节点间

8 年前

epiyugu · 在Vertx中加载SQL脚本

8 年前

Fernando · 增加deployVerticle超时

8 年前