当前位置: 首页 > 文档资料 > Apus 中文文档 >

1.2.2 使用手册

优质
小牛编辑
127浏览
2023-12-01

下面通过代码说明该 SDK 的使用方法,一个完整的示例在这里获取
在这个简单的示例中,服务端的入口在 server 包下的类 Server 中,客户端的入口在 client 包下的类 Client 中,无需任何额外的配置就能直接运行它

Server

1. 接口定义:

示例:

public class EchoServer {
    @ThriftService("EchoServer")
    public interface Iface {
        @ThriftMethod("echo")
        String echo(String input);
    }

    // 异步接口,如果不需要可以不定义
    @ThriftService("EchoServer")
    public interface AsyncIface {
        @ThriftMethod("echo")
        ListenableFuture<String> echo(String input);    
    }
}

定义了两个接口 Iface AsyncIface,一个用于同步 Client,一个用于异步 Client

2. 接口实现:

示例:

public class EchoServerImpl implements EchoServer.Iface {
    @Override
    public String echo(String input) {
        return input;
    }
}

3. 服务启动:

示例:

public class Server {
    public static void main(String[] args) {
        ServerConfig<EchoServerImpl> config = new ServerConfig.Builder<>(EchoServerImpl.class)
                .registryFactory(new ServiceCenterRegistryFactory(EchoServerImpl.class))
                .port(12346).build();
        Bootstrap<EchoServerImpl> bootstrap = new Bootstrap<>(config);
        bootstrap.start();
    }
}

如上所示,通常情况下 ServerConfig 我们只需配置端口号,线程数和 ServiceCenterRegistryFactory

ServerConfig 可以配置的参数可以看看 builder 里面的代码:

private Class<T> clazz; // 实现 Server 的 Class
private Endpoint endpoint; // 包含 Server 信息的 Endpoint,可以不配置,默认是本机 ip
private int threadPoolSize; // Server 处理业务的线程池大小,建议按需配置,默认大小为 5
private List<ThriftEventHandler> eventHandlers; // Swift 的 Event Handler,建议默认值
private RegistryFactory registryFactory; // 注册工厂,需要使用 ServiceCenterRegistryFactory
private InvocationHandler serviceProxy; // 如果用户需要对 Server impl 用反射再封装,可以用这个
private ThriftServerConfig thriftServerConfig; // Swift 的 Server 配置,建议默认值
private String portKey; // 端口号的 properties key,默认 port,需要在 Registry 读取端口号
private String threadPoolSizeKey; // 线程数的 properties key,如果需要在 registry 读取线程数
private MetricsFactory metricsFactory; // metricsFactory,用户监控
private int port; // 端口号

然后我们可以用 Bootstrap 启动 Server:

Bootstrap<EchoServerImpl> bootstrap = new Bootstrap<>(config);
bootstrap.start();

Bootstrap 有两个构造函数,上面例子会自己去反射调用实例化 ServerImpl,如果有自己特殊的需求,可以把实例化好的对象放到第二个参数

new Bootstrap<>(config, serverImpl);

Client

示例:

public class Client {
    public static void main(String[] args) throws InterruptedException {
        // client 调用同步接口
        String request = "Hello Xiaomi!";
        ClientConfig<EchoServer.Iface> syncClientConfig =
                new ClientConfig.ClientConfigBuilder<>(EchoServer.Iface.class)
                        .registryFactory(new ServiceCenterRegistryFactory(EchoServer.Iface.class))
                        .build();
        EchoServer.Iface newSyncClient = new SwiftClientManager<>(syncClientConfig).createClient();
        String response = newSyncClient.echo(request);
        System.out.println(response);

        // client 调用异步接口
        String asyncRequest = "Hello Xiaomi!(async)";
        ClientConfig<EchoServer.AsyncIface> asyncIfaceClientConfig =
                new ClientConfig.ClientConfigBuilder<>(EchoServer.AsyncIface.class)
                        .registryFactory(new ServiceCenterRegistryFactory(EchoServer.Iface.class))
                        .build();
        EchoServer.AsyncIface newAsyncClinet = new SwiftClientManager<>(asyncIfaceClientConfig).createClient();
        ListenableFuture<String> future = newAsyncClinet.echo(asyncRequest);
        Futures.addCallback(future, new FutureCallback<String>() {
            @Override
            public void onSuccess(String result) {
                System.out.println(result);
            }

            @Override
            public void onFailure(Throwable t) {
                t.printStackTrace();
            }
        });
        Thread.sleep(1000);
    }
}

如上所示, 通常情况下 ClientConfig 我们只需要配置 ServiceCenterRegistryFactory,其他使用默认值即可

ClientConfig 可配置参数可以看 CliengConfig builder 代码:

private Class<Iface> ifaceClazz;
private EndpointPoolProviderFactory endpointPoolProviderFactory; // 建议默认值,用于提供和更新 Server 信息
private EndpointGroupingStrategyFactory endpointGroupingStrategyFactory; // 建议默认值,用于 Server 分组
private LoadBalancerFactory loadBalancerFactory; // 建议默认值,用于 Loadbalancer
private DefaultInvokerFactory invokerFactory; // 建议默认值
private ConnectionManagerFactory connectionManagerFatory; // 建议默认值,管理连接
private ConnectionConfigFactory connectionConfigFactory; // 建议默认值
private RegistryFactory registryFactory; // 请使用 ServiceCenterRegistryFactory
private MetricsFactory metricsFactory; //  监控

然后我们可以开始创建 Client 对象:

EchoServer.Iface newSyncClient = new SwiftClientManager<>(syncClientConfig).createClient();
String response = newSyncClient.echo(request);
System.out.println(response);

Registry 服务注册与发现

前面不管 Server 还是 Client 都提到了 ServiceCenterRegistryFactory,需要在 application.conf 配置中配置如下参数,比如:

# 机构认证标识 ak(必填)
registry.zookeeper.accesskey=""
# 机构认证标识 sk(必填)
registry.zookeeper.secretkey=""
# 注册中心监控周期,建议默认值 10s(选填)
registry.scheduler.step.seconds=10
# 注册超时时间,建议默认值 5000ms(选填)
registry.connection.timeout.milliseconds=5000
# 注册中心 URL(必填)
# aws-北京的 URL 为 https://cnbj-sc.rpc.cloud.mi.com,金山云的 URL 为 https://cnbj6-sc.rpc.cloud.mi.com
registry.servicecenter.domain="https://cnbj6-sc.rpc.cloud.mi.com"

注:client必须使用和server同一个用户组的AK/SK才能够发现服务。

ak 和 sk 的获取方式参见获取 ak 和 sk

服务启动成功后,Client 也会在这里读取相关的 Server 信息, Server 需要与注册中心同一机房

Metrics 监控中心

Metrics 作为系统的监控中心, 主要监控指标有调用方法时间、次数及异常次数等, 已经实现的监控系统有 Open-Falcon , 如下所示,我们还可以通过实现 Metrics 实现自己的监控中心

Metrics

public void count(Counter counter)
public void countDuration(Method method, long duration): 统计方法执行时间,次数
public void countException(Method method, Throwable throwable):统计异常次数

Counter

private String name:Counter name,表示统计的一个指标 Key
private long longValue:调用次数
private String tags:标签
private long time:执行时间
....

使用监控中心,只需要在初始化 ClientConfig 时传入相应的工厂类, 如下所示

ClientConfig<EchoServer.Iface> syncClientConfig =
                new ClientConfig.ClientConfigBuilder<>(EchoServer.Iface.class)
                        .registryFactory(new ZookeeperRegistryFactory(EchoServer.Iface.class))
                        .metricsFactory(new OpenFalconMetricsFactory(SwiftMetricsUtil.getClientCounterPrefix(EchoServer.Iface.class), '-'))
                        .build();
EchoServer.Iface newSyncClient = new SwiftClientManager<>(syncClientConfig).createClient();

目前支持的监控项有:

Client

thriftcli-${ifaceClassName}-${methodName}:client 调用 methodname 方法的时间,次数
thriftcli-${ifaceClassName}-${methodName}_fail:namethodName 调用失败次数
thriftcli-${ifaceClassName}-exception-${exceptionName}:exceptionName 异常的调用次数

Server

method/${methodName}:methodName 调用次数,时间
method/ALL_THRIFT_METHODS:所有 method 调用次数,时间
method/${methodName}_fail:methodName 调用失败次数
exception/${exceptionName}: exception 次数 
method/ALL_THRIFT_METHODS_FAIL: 所有 method 调用失败次数

使用监控中心需要以下配置:

  • 用户使用 Open-Falcon :
metric.falcon.agent.collection.url="http://127.0.0.1:1988/v1/push" //数据采集 URL,默认值为 "http://127.0.0.1:1988/v1/push"
metric.falcon.agent.push.period.time.second=300  //数据采集汇报周期,默认值为300
metric.falcon.agent.pushon=true  //推送开关,是否推送数据到 Agent,默认值为 true
metric.falcon.agent.http.connection.timeout.milliseconds=300 //通过 Http 协议推送数据到本地 Agent 连接超时时间,默认值为300
metric.falcon.agent.jobtags="" //jobtag

如果上述默认值不满足要求,用户可以在类路径下的 application.conf 中配置上述参数