spring-cloud-starter-thrift提供SpringCloud对可伸缩的跨语言服务调用框架Apache Thrift的封装和集成。
spring-cloud-starter-thrift提供
Spring Cloud对可伸缩的跨语言服务调用框架
Apache Thrift的封装和集成。
spring-cloud-starter-thrift包括客户端
spring-cloud-starter-thrift-client和服务端
spring-cloud-starter-thrift-server两个模块。
服务端: 1. 支持
Apache Thrift的各种原生服务线程模型,包括单线程阻塞模型(
simple)、单线程非阻塞模型(
nonBlocking)、线程池阻塞模型(
threadPool)、半同步半异步模型(
hsHa)和半同步半异步线程选择器模型(
threadedSelector)。 2. 支持
Apache Thrift 0.10.0版本后提供的多路复用处理器,提供服务的统一注册管理功能。 3. 支持由服务签名(服务
ID+ 客户端
Stub接口名称 + 服务版本号)唯一标识服务
Stub的具体实现类,支持服务版本的平滑升级。 4. 支持
Server Group形式的启动方式,每个服务实例可以开启多台
Thrift Server,通过不同的端口号暴露给客户端。
客户端: 1. 支持由服务签名(服务
ID+ 客户端
Stub接口名称 + 服务版本号)唯一标识和调用服务端的
Stub具体实现类。 2. 支持
Apache Thrift的
Transport层的连接池管理,减少了客户端与服务端之间连接的频繁创建和销毁。 3. 支持与
Spring Cloud Consul的无缝集成,客户端通过心跳检测与服务注册中心
Consul保持连接,动态定时的刷新服务列表、监测服务的启用、关闭和健康状态。 4. 支持客户端负载均衡,包括随机、轮询的负载均衡策略,客户端的
Thrift程序通过本地的服务缓存列表实现调用的动态转发。
spring-cloud-starter-thrift使用的是
0.10.0版本的
thrift。
首先,通过
Apache Thrift的
IDL(接口描述语言)编写客户端桩
Stub和服务端骨架
Skeleton,通过
.thrift文件定义接口规范。
calculator.thrift
namespace java io.ostenant.rpc.thrift.examplesservice CalculatorService { i32 add(1: i32 arg1, 2: i32 arg2) i32 subtract(1: i32 arg1, 2: i32 arg2) i32 multiply(1: i32 arg1, 2: i32 arg2) i32 division(1: i32 arg1, 2: i32 arg2) }
下载并安装
0.10.0的
Thrift IDL编译器,下载地址http://thrift.apache.org/docs/install。通过编译器生成
.java接口的类文件。
thrift-0.10.0.exe -r -gen ./CalculatorService.thrift
编译器生成
CalculatorService.java文件。
CalculatorService.java有成千上万行代码。 对于开发人员而言,使用原生的
Thrift框架,仅仅需要关注以下四个核心接口/类:Iface, AsyncIface, Client和AsyncClient。
CalculatorService.java
public class CalculatorService {public interface Iface {
public int add(int arg1, int arg2) throws org.apache.thrift.TException; public int subtract(int arg1, int arg2) throws org.apache.thrift.TException; public int multiply(int arg1, int arg2) throws org.apache.thrift.TException; public int division(int arg1, int arg2) throws org.apache.thrift.TException;
}
public interface AsyncIface {
public void add(int arg1, int arg2, org.apache.thrift.async.AsyncMethodCallback<integer> resultHandler) throws org.apache.thrift.TException; public void subtract(int arg1, int arg2, org.apache.thrift.async.AsyncMethodCallback<integer> resultHandler) throws org.apache.thrift.TException; public void multiply(int arg1, int arg2, org.apache.thrift.async.AsyncMethodCallback<integer> resultHandler) throws org.apache.thrift.TException; public void division(int arg1, int arg2, org.apache.thrift.async.AsyncMethodCallback<integer> resultHandler) throws org.apache.thrift.TException;
}
public static class Client extends org.apache.thrift.TServiceClient implements Iface { public static class Factory implements org.apache.thrift.TServiceClientFactory { public Factory() {} public Client getClient(org.apache.thrift.protocol.TProtocol prot) { return new Client(prot); } public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { return new Client(iprot, oprot); } }
public Client(org.apache.thrift.protocol.TProtocol prot) { super(prot, prot); } public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { super(iprot, oprot); }
} public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { public static class Factory implements org.apache.thrift.async.TAsyncClientFactory { private org.apache.thrift.async.TAsyncClientManager clientManager; private org.apache.thrift.protocol.TProtocolFactory protocolFactory; public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { this.clientManager = clientManager; this.protocolFactory = protocolFactory; } public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { return new AsyncClient(protocolFactory, clientManager, transport); } }
public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { super(protocolFactory, clientManager, transport); }
} }
// ... 省略
在
pom.xml文件中引入服务端依赖
spring-cloud-starter-thrift-server:
io.ostenant.rpc.thrift spring-cloud-starter-thrift-server 1.0.0
pom.xml
io.ostenant.rpc.thrift spring-cloud-starter-thrift-example 1.0.0 4.0.0<artifactid>spring-cloud-starter-thrift-example-server</artifactid> <packaging>jar</packaging> <dependencies> <dependency> <groupid>io.ostenant.rpc.thrift</groupid> <artifactid>spring-boot-starter-thrift-server</artifactid> <version>1.0.0</version> </dependency> <dependency> <groupid>io.ostenant.rpc.thrift</groupid> <artifactid>spring-cloud-starter-thrift-example-iface</artifactid> <version>1.0.0</version> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-actuator</artifactid> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> </dependencies> <build> <plugins> <plugin> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-maven-plugin</artifactid> </plugin> </plugins> </build>
application.yml
## 服务所在的HTTP端口号 server: port: 8080用于Consul健康检查
endpoints: actuator: sensitive: false enabled: true management: security: enabled: false
Spring Thrift服务端配置
spring: thrift: server: service-id: thrift-rpc-calculator ## 服务ID service-model: hsHa ## 服务线程模型simple/nonBlocking/threadPool/hsHa/threadedSelector port: 25000 ## 服务所在的RPC端口号 worker-queue-capacity: 1000 ## 工作队列大小 hs-ha: min-worker-threads: 5 max-worker-threads: 20 keep-alived-time: 3
Application.java
@SpringBootApplication public class Application {public static void main(String[] args) { SpringApplication.run(Application.class, args); }
}
实现
Thrift IDL生成的
Stub类
CalculatorService中的
Iface接口,编写具体的业务逻辑:
RpcCalculatorService.java
@ThriftService(name = "rpcCalculatorService", version = 2.0) public class RpcCalculatorService implements CalculatorService.Iface {@Override public int add(int arg1, int arg2) { BigDecimal arg1Decimal = new BigDecimal(arg1); BigDecimal arg2Decimal = new BigDecimal(arg2); return arg1Decimal.add(arg2Decimal).intValue(); } @Override public int subtract(int arg1, int arg2) { BigDecimal arg1Decimal = new BigDecimal(arg1); BigDecimal arg2Decimal = new BigDecimal(arg2); return arg1Decimal.subtract(arg2Decimal).intValue(); } @Override public int multiply(int arg1, int arg2) { BigDecimal arg1Decimal = new BigDecimal(arg1); BigDecimal arg2Decimal = new BigDecimal(arg2); return arg1Decimal.multiply(arg2Decimal).intValue(); } @Override public int division(int arg1, int arg2) { BigDecimal arg1Decimal = new BigDecimal(arg1); BigDecimal arg2Decimal = new BigDecimal(arg2); return arg1Decimal.divide(arg2Decimal).intValue(); }
}
编写
Dockerfile文件:
FROM openjdk:8-jdk-alpine ADD target/spring-boot-thrift-server-1.0.0jar calculator-server.jar ENTRYPOINT ["java", "-jar", "calculator-server.jar"]
将
Dockerfile和
target/spring-boot-thrift-server-0.0.1-SNAPSHOT.jar拷贝到服务器上,构建
Thrift Server的服务镜像:
docker docker build . -t ostenant/calculator-server
启动三个
Thrift Server的
docker容器,分别指定对应的端口号和
Consul注册信息:
Thrift Server实例1(25001端口):
docker run -d -p 8081:8080 -p 25001:25000 --name calculator-server-01 \ -e "SERVICE_25000_NAME=thrift-rpc-calculator" \ -e "SERVICE_25000_CHECK_TCP=/" \ -e "SERVICE_25000_CHECK_INTERVAL=30s" \ -e "SERVICE_25000_CHECK_TIMEOUT=3s" \ -e "SERVICE_25000_TAGS=thrift-rpc-calculator-25001" \ ostenant/calculator-server
Thrift Server实例2(25002端口):
docker run -d -p 8081:8080 -p 25002:25000 --name calculator-server-01 \ -e "SERVICE_25000_NAME=thrift-rpc-calculator" \ -e "SERVICE_25000_CHECK_TCP=/" \ -e "SERVICE_25000_CHECK_INTERVAL=30s" \ -e "SERVICE_25000_CHECK_TIMEOUT=3s" \ -e "SERVICE_25000_TAGS=thrift-rpc-calculator-25002" \ ostenant/calculator-server
Thrift Server实例3(25003端口):
docker run -d -p 8081:8080 -p 25003:25000 --name calculator-server-01 \ -e "SERVICE_25000_NAME=thrift-rpc-calculator" \ -e "SERVICE_25000_CHECK_TCP=/" \ -e "SERVICE_25000_CHECK_INTERVAL=30s" \ -e "SERVICE_25000_CHECK_TIMEOUT=3s" \ -e "SERVICE_25000_TAGS=thrift-rpc-calculator-25003" \ ostenant/calculator-server
启动
Consul和
Registrator容器,
Thrift Server的三个服务实例成功注册到Consul服务列表:
这里有关
Consul和
Registrator的安装配置以及使用,请参考官方文档,这里就不加以累述了!
观察各个容器的启动日志,如果包含以下几行输出信息,则表明
Thrift Server成功启动并正常提供
RPC服务。
2017-11-19 22:28:47.779 INFO 12960 --- [ main] c.i.r.t.s.context.ThriftServerContext : Build thrift server from HsHaServerContext 2017-11-19 22:28:47.820 INFO 12960 --- [ main] c.i.r.t.s.p.TRegisterProcessorFactory : Processor bean org.os[email protected]445bce9a with signature [thrift-rpc-calculator$org.ostenant.springboot.learning.examples.CalculatorService$2.0] is instantiated 2017-11-19 22:28:47.822 INFO 12960 --- [ main] c.i.r.t.s.p.TRegisterProcessorFactory : Single processor org.os[email protected]445bce9a register onto multiplexed processor with signature [thrift-rpc-calculator$org.ostenant.springboot.learning.examples.CalculatorService$2.0] 2017-11-19 22:28:47.822 INFO 12960 --- [ main] c.i.r.t.s.p.TRegisterProcessorFactory : Multiplexed processor totally owns 1 service processors
至此,
Thrift服务端程序正常运行,可供客户端
Thrift程序调用!
在
pom.xml文件中引入客户端依赖
spring-cloud-starter-thrift-client:
io.ostenant.rpc.thrift spring-cloud-starter-thrift-client 1.0.0
pom.xml
io.ostenant.rpc.thrift spring-cloud-starter-thrift-example 1.0.0 4.0.0<artifactid>spring-cloud-starter-thrift-example-client</artifactid> <dependencies> <dependency> <groupid>io.ostenant.rpc.thrift</groupid> <artifactid>spring-cloud-starter-thrift-client</artifactid> <version>1.0.0</version> </dependency> <dependency> <groupid>io.ostenant.rpc.thrift</groupid> <artifactid>spring-cloud-starter-thrift-example-iface</artifactid> <version>1.0.0</version> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-actuator</artifactid> </dependency> <dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-web</artifactid> </dependency> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-starter-consul-discovery</artifactid> </dependency> </dependencies> <dependencymanagement> <dependencies> <dependency> <groupid>org.springframework.cloud</groupid> <artifactid>spring-cloud-dependencies</artifactid> <version>${spring-cloud.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencymanagement> <build> <plugins> <plugin> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-maven-plugin</artifactid> </plugin> </plugins> </build>
application.yml
## 客户端的HTTP端口号 server: port: 8080用于Consul健康检查
endpoints: actuator: sensitive: false enabled: true management: security: enabled: false
Spring Thrift客户端配置(Thrift Client的自动配置取决于Spring Cloud Consul的正确配置)
spring: cloud: consul: host: 127.0.0.1 ## Consul的IP地址 port: 8500 ## Consul的端口号 discovery: register: false ## 是否将自身注册为服务 register-health-check: true health-check-interval: 30s ## HTTP服务健康检查时间间隔 retry: max-attempts: 3 max-interval: 2000 thrift: client: package-to-scan: io.ostenant.rpc.thrift.example.rpc ## 标记由有注解@ThriftClient接口的包路径 service-model: hsHa ## 服务线程模型(这里必须与服务端保持一致, 默认都是hsHa) pool: ## 客户端连接池配置 retry-times: 3 pool-max-total-per-key: 200 pool-min-idle-per-key: 10 pool-max-idle-per-key: 40 pool-max-wait: 1000 connect-timeout: 2000
Application.java
@SpringBootApplication @EnableDiscoveryClient public class Application {public static void main(String[] args) { SpringApplication.run(Application.class, args); }
}
编写
Thrift Client的客户端代理接口,这里有两点注意事项: 1. 接口需要继承于父接口
ThriftClientAware,且
ThriftClientAware里的泛型参数填写为
Thrift IDL生成的
Stub类
CalculatorService中的
Client内部类。
接口中有一个抽象方法T thriftClient()可以获取具体的
Thrift Client的代理对象。
Thrift服务端的服务注册ID(与服务端保持一致)。 > (b). refer:
Thrift服务端具体的
Stub生成类。 > (c). version:
Stub生成类具体业务实现类的版本号(不填写默认为1.0),需要与服务端保持一致。
@ThriftClient(serviceId = "thrift-rpc-calculator", refer = CalculatorService.class, version = 2.0) public interface CalculatorThriftClient extends ThriftClientAware { }</calculatorservice.client>
在
Controller中注入ThriftClientAware<? extend TServiceClient>子接口,使用注解@ThriftReferer标识即可成功注入。 使用时,通过XxxxThriftClient.thriftClient()即可调用远程
Thrift Server的服务方法。
RpcCalculatorController.java
@RestController @RequestMapping("/rpc") public class RpcCalculatorController {@ThriftReferer CalculatorThriftClient calculators; @GetMapping("/add") public int add(@RequestParam("arg1") int arg1, @RequestParam("arg2") int arg2) throws Exception { return calculators.thriftClient().add(arg1, arg2); } @GetMapping("/subtract") public int subtract(@RequestParam("arg1") int arg1, @RequestParam("arg2") int arg2) throws Exception { return calculators.thriftClient().subtract(arg1, arg2); } @GetMapping("/multiply") public int multiply(@RequestParam("arg1") int arg1, @RequestParam("arg2") int arg2) throws Exception { return calculators.thriftClient().multiply(arg1, arg2); } @GetMapping("/division") public int division(@RequestParam("arg1") int arg1, @RequestParam("arg2") int arg2) throws Exception { return calculators.thriftClient().division(arg1, arg2); }
}
在本地
8080端口号启动
Thrift客户端,正常启动后观察启动日志如下:
2017-11-20 11:00:20.025 INFO 4052 --- [ main] .r.t.c.ThriftClientBeanScannerConfigurer : Base package org.ostenant.springboot.learning.examples.rpc is to be scanned with [email protected]37496720 2017-11-20 11:00:20.029 INFO 4052 --- [ main] c.i.r.t.c.s.ThriftClientBeanScanner : Packages scanned by thriftClientBeanDefinitionScanner is [org.ostenant.springboot.learning.examples.rpc] 2017-11-20 11:00:20.029 INFO 4052 --- [ main] c.i.r.t.c.s.ThriftClientBeanScanner : Scanned and found thrift client, bean calculatorThriftClient assigned from org.ostenant.springboot.learning.examples.rpc.CalculatorThriftClient 2017-11-20 11:00:20.050 INFO 4052 --- [ main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring 2017-11-20 11:00:20.134 INFO 4052 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.ostenant.springboot.learning.examples.rest.CalculatorFeignClient' of type [org.springframework.cloud.netflix.feign.FeignClientFactoryBean] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) 2017-11-20 11:00:20.136 WARN 4052 --- [ main] c.i.r.t.c.s.ThriftClientFactoryBean : Bean class is not found 2017-11-20 11:00:20.142 INFO 4052 --- [ main] c.i.r.t.c.s.ThriftClientFactoryBean : Succeed to instantiate an instance of ThriftClientFactoryBean: [email protected]7bac686b 2017-11-20 11:00:20.142 INFO 4052 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'calculatorThriftClient' of type [com.icekredit.rpc.thrift.client.scanner.ThriftClientFactoryBean] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) 2017-11-20 11:00:20.411 INFO 4052 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.netflix.metrics.MetricsInterceptorConfiguration$MetricsRestTemplateConfiguration' of type [org.springframework.cloud.netflix.metrics.MetricsInterceptorConfiguration$MetricsRestTemplateConfiguration$$EnhancerBySpringCGLIB$$a9ef18dc] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) 2017-11-20 11:00:20.423 INFO 4052 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration' of type [org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration$$EnhancerBySpringCGLIB$$93dc7598] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying) 2017-11-20 11:00:21.592 INFO 4052 --- [ main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat initialized with port(s): 8080 (http)
启动过程中,所有的标记有注解@ThriftClient的接口都生成了代理对象,并通过注解@ThriftReferer注入到Controller中。
同时,
客户端启动时开启了一个
ServerUpdater,定时动态的去
Consul服务注册列表抓取健康的服务信息,缓存到本地服务列表中。
2017-11-20 11:02:26.726 INFO 4052 --- [erListUpdater-0] t.c.l.ThriftConsulServerListLoadBalancer : Refreshed thrift serverList: [thrift-rpc-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25001], host='192.168.91.128', port=25001, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25002], host='192.168.91.128', port=25002, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25003], host='192.168.91.128', port=25003, address='192.168.91.128', isHealth=true}], consul-8301: [ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=8301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=9301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=10301, address='192.168.91.128', isHealth=true}], consul-8302: [ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=8302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=9302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=10302, address='192.168.91.128', isHealth=true}], thrift-rest-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8081], host='192.168.91.128', port=8081, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8082], host='192.168.91.128', port=8082, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8083], host='192.168.91.128', port=8083, address='192.168.91.128', isHealth=true}]] 2017-11-20 11:02:56.752 INFO 4052 --- [erListUpdater-0] t.c.l.ThriftConsulServerListLoadBalancer : Refreshed thrift serverList: [thrift-rpc-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25001], host='192.168.91.128', port=25001, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25002], host='192.168.91.128', port=25002, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25003], host='192.168.91.128', port=25003, address='192.168.91.128', isHealth=true}], consul-8301: [ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=8301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=9301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=10301, address='192.168.91.128', isHealth=true}], consul-8302: [ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=8302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=9302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=10302, address='192.168.91.128', isHealth=true}], thrift-rest-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8081], host='192.168.91.128', port=8081, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8082], host='192.168.91.128', port=8082, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8083], host='192.168.91.128', port=8083, address='192.168.91.128', isHealth=true}]] 2017-11-20 11:03:26.764 INFO 4052 --- [erListUpdater-0] t.c.l.ThriftConsulServerListLoadBalancer : Refreshed thrift serverList: [thrift-rpc-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25001], host='192.168.91.128', port=25001, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25002], host='192.168.91.128', port=25002, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25003], host='192.168.91.128', port=25003, address='192.168.91.128', isHealth=true}], consul-8301: [ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=8301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=9301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=10301, address='192.168.91.128', isHealth=true}], consul-8302: [ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=8302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=9302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=10302, address='192.168.91.128', isHealth=true}], thrift-rest-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8081], host='192.168.91.128', port=8081, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8082], host='192.168.91.128', port=8082, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8083], host='192.168.91.128', port=8083, address='192.168.91.128', isHealth=true}]] 2017-11-20 11:03:56.778 INFO 4052 --- [erListUpdater-0] t.c.l.ThriftConsulServerListLoadBalancer : Refreshed thrift serverList: [thrift-rpc-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25001], host='192.168.91.128', port=25001, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25002], host='192.168.91.128', port=25002, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rpc-calculator', tags=[thrift-rpc-calculator-25003], host='192.168.91.128', port=25003, address='192.168.91.128', isHealth=true}], consul-8301: [ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=8301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=9301, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8301', tags=[udp], host='192.168.91.128', port=10301, address='192.168.91.128', isHealth=true}], consul-8302: [ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=8302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=9302, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='consul-8302', tags=[udp], host='192.168.91.128', port=10302, address='192.168.91.128', isHealth=true}], thrift-rest-calculator: [ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8081], host='192.168.91.128', port=8081, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8082], host='192.168.91.128', port=8082, address='192.168.91.128', isHealth=true}, ThriftServerNode{node='node1', serviceId='thrift-rest-calculator', tags=[thrift-rest-calculator-8083], host='192.168.91.128', port=8083, address='192.168.91.128', isHealth=true}]]
访问本地
Thrift客户端:
| 访问地址 | 参数arg1 | 参数arg2 | 页面输出结果 | | :------------- |:-------------:|:-------------:|:-------------:| | /rpc/add | 200 | 100 | 300 | | /rpc/subtract | 200 | 100 | 100 | | /rpc/multiply | 200 | 100 | 20000 | | /rpc/division | 200 | 100 | 2 |