Vertx - 尝试微服务

1.为了解Vertx的微服务，这几天做了点测试，项目地址
https://github.com/peijie1662/vertx-cluser
目录结构

clipboard.png

vertx_cluser_01和vertx_cluser_02模拟集群的二个节点。
maven install时注意修改

<main.verticle>pj.com.cn.vertx_cluser_02.MainVerticle</main.verticle>

分别编译为2个cluser的jar，cluser01.jar,cluser02.jar
运行时分别在2个命令窗口中运行java -jar cluserXX.jar即可。

步骤
2.1 创建简单的服务供测试

public class MyFirstVerticle extends AbstractVerticle {

    public void start() {
        Router router = Router.router(vertx);
        router.get("/").handler(rc -> {
            rc.response().end("Welcome use first-service!");
        });
        vertx.createHttpServer().requestHandler(router).listen(8081);
    }
}

2.2 在cluser01节点，得到集群模式下的clusteredVertx，并在这个vertx实例上发布服务first-service和second-service。
然后将2个服务注册到服务发现(ServiceDiscovery)实例。

public class MainVerticle extends AbstractVerticle {

    public void start() {
        ClusterManager mgr = new HazelcastClusterManager();
        VertxOptions options = new VertxOptions().setClusterManager(mgr);
        Vertx.clusteredVertx(options, res -> {
            if (res.succeeded()) {
                vertx = res.result();
                vertx.deployVerticle(new MyFirstVerticle());
                vertx.deployVerticle(new MySecondVerticle());
                ServiceDiscovery.create(vertx, sd -> {
                    sd.publish(HttpEndpoint.createRecord("first-service", "localhost", 8081, "/"), ar -> {
                        System.out.println("cluser01 - first-service publish success!");
                    });
                    sd.publish(HttpEndpoint.createRecord("second-service", "localhost", 8082, "/"), ar -> {
                        System.out.println("cluser01 - second-service publish success!");
                    });
                });
            } else {
                res.cause().printStackTrace();
            }
        });

    }
}

2.3 在cluser02节点，略微复杂，通过服务发现实例去调用cluser01节点中的first-service。

public class MyThirdVerticle extends AbstractVerticle {

    private CircuitBreaker breaker;

    public void start() {
        breaker = CircuitBreaker
                .create("third-circuit-breaker", vertx, new CircuitBreakerOptions().setMaxFailures(5).setTimeout(2000))
                .openHandler(v -> {
                    System.out.println("Circuit opened");
                }).closeHandler(v -> {
                    System.out.println("Circuit closed");
                });
        // 重试策略
        // .retryPolicy(retryCount -> retryCount * 100L)

        Router router = Router.router(vertx);
        router.get("/").handler(rc -> {
            rc.response().end("Welcome use third-service!");
        });
        router.get("/cluser01/first").handler(rc -> {
            ServiceDiscovery sd = ServiceDiscovery.create(vertx);
            sd.getRecord(new JsonObject().put("name", "first-service"), r -> {
                if (r.succeeded()) {
                    // System.out.println("record:"+r.result().toJson());
                    breaker.execute(f -> {
                        Record rd = r.result();
                        ServiceReference ref = sd.getReference(rd);
                        WebClient wc = ref.getAs(WebClient.class);
                        wc.get("/").send(res -> {
                            if (res.succeeded()) {
                                f.complete("call first-service:" + res.result().body().toString());
                            } else {
                                f.fail("first-service unvalid! " + breaker.failureCount());
                            }
                        });
                        ref.release();
                    }).setHandler(ar -> {
                        if (ar.succeeded()) {
                            rc.response().end(
                                    "breaker status:" + breaker.state().toString() + "   " + ar.result().toString());
                        } else {
                            rc.response().end(
                                    "breaker status:" + breaker.state().toString() + "   " + ar.cause().getMessage());
                        }
                    });
                } else {
                    rc.response().end("could not found first-service!");
                }
            });
            sd.close();
        });
        vertx.createHttpServer().requestHandler(router).listen(8083);
    }
}

另外在这里顺便测试了CircuitBreaker断路器。

结论：
1.运行cluser01.jar和cluser02.jar，会发现二者可以做到实时互相发现，对方上下线都可以及时发现，（因为默认使用了UDP在同网段中组播）

2.通过http://localhost:8083/cluser01/first可以通过third-service访问到first-service。说明服务发现运行正常。

3.此时将cluser01关掉，打印服务发现实例中first-service的状态仍旧是UP，虽然cluser02的窗口已提示cluser01掉线.，所以也不知道说啥好了。

4.断路器还是比较好用的，关掉cluser01后，猛刷几次http://localhost:8083/cluser01/first，即可看到断路效果，要注意的是，必须在指定时间窗口内（默认10秒，可通过setFailuresRollingWindow设置）失败次数超setMaxFailures值才会开路(open)。

5.还少个API Gateway，对于测试来说意义也不大，总体感觉有些简陋，有些点还没覆盖到，做做“小”的微服务应该问题不大：）