基础知识

一、框架基本调用流程

overview

  1. 服务提供者向服务注册中心注册对外暴露的服务信息，服务信息包括接口名，分组，版本号等。框架默认使用zookeeper注册中心， 存储节点以临时顺序节点实现，当服务提供者挂掉或与注册中心断开连接时，临时节点会被zookeeper删除， 以保障服务注册信息的可用与实时性。
  2. 服务消费者启动时会连接注册中心，将所有的远程服务地址缓存到本地，并监听注册中心，获取实时的数据。
  3. 一旦有新的服务提供者加入到集群或者退出集群，注册中心就会通知服务消费者，服务消费者接到通知后，会拉取最新的服务数据，更新本地缓存。
  4. 一旦发生远程调用，服务消费者会根据接口，分组，版本号去缓存中匹配可用的服务提供者地址，并通过负载均衡策略，选择其中一个进行远程调用。
  5. 服务提供者执行完远程调用后将结果或者异常返回给服务消费者。

二、框架所包含的子系统

  • SerializeManager:序列化子系统
  • RegistryManager:服务注册子系统
  • BalanceManager:负载均衡子系统
  • TransportManager:传输层子系统

三、在非Spring应用中使用

该框架在设计模式上采用了Facade外观模式，FastcallManager的默认实现类DefaultFastcallManager是系统的外观，封装了所有子系统的功能，对外提供统一的接口。 在非Spring应用中使用时，我们只需要通过FastcallManager的工厂类，生成DefaultFastcallManager单例对象，就可以通过该对象，调用框架的所有功能。

1. 添加依赖
<dependency>
    <groupId>net.stackoverflow.fastcall</groupId>
    <artifactId>fastcall-core</artifactId>
    <version>${fastcall.version}</version>
</dependency>
2. 生成外观对象
//实例化配置类（亦可通过FastcallConfigBuilder建造者，一步一步生成配置类）
FastcallConfig config = new FastcallConfig();
//如有必要，修改默认配置（序列化方式，负载均衡策略，注册中心类型地址等）
...

//生成工厂类，并由工厂类生成DefaultFastcallManager的单例对象
FastcallManagerFactory factory = new ConfigFastcallManagerFactory(config);
FastcallManager manager = factory.getInstance();

//接下来可以使用FastcallManager对象，调用框架提供的功能

四、在Spring应用中使用，以Spring boot为例

该框架提供了fastcall-spring-boot-autoconfigure和fastcall-spring-boot-starter两个模块，以便对Spring boot应用进行支持。在Spring boot应用中添加框架 的starter后，只需要少量的配置就可以使用该框架，完美体现了Spring boot的约定优于配置的理念。

1. 添加依赖
<dependency>
    <groupId>net.stackoverflow.fastcall</groupId>
    <artifactId>fastcall-spring-boot-starter</artifactId>
    <version>${fastcall.version}</version>
</dependency>
2. 配置（大多可以采用默认配置）
#序列化方式
fastcall.serialize=json
#rpc处理并发线程数
fastcall.threads=10000
#负载均衡策略
fastcall.balance=poll
#重试次数
fastcall.retry=0

#应用层协议，及服务地址与端口
fastcall.transport.proto=fastcall
fastcall.transport.host=0.0.0.0
fastcall.transport.port=9966

#注册中心类型，及地址与端口
fastcall.registry.type=zookeeper
fastcall.registry.zookeeper.host=127.0.0.1
fastcall.registry.zookeeper.port=2181
fastcall.registry.zookeeper.session-timeout=5000
3. 在启动类上添加注解（只使用服务消费功能可以不加此注解，此注解的功能类似于@ComponentScan，basePackages属性标识了注解扫描的包路径）
@EnableFastcall(basePackages = {"net.stackoverflow.fastcall.demo.provider"})

results matching ""

    No results matching ""