ostenant

spring-cloud-starter-thrift提供SpringCloud对可伸缩的跨语言服务调用框架Apache Thrift的封装和集成。

136 Stars 75 Forks Last release: Not found 46 Commits 0 Releases

Available items

No Items, yet!

The developer of this repository has not created any items for sale yet. Need a bug fixed? Help with integration? A different license? Create a request here:

Readme

spring-cloud-starter-thrift

Name: spring-cloud-starter-thrift
Brand: spring-cloud-starter-thrift
SKU: //ostenant/spring-cloud-starter-thrift
Rating: 2.09 (136 reviews)

简介

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.examples

service 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。

Iface：服务端通过实现CalculatorService.Iface接口，向客户端的提供具体的同步业务逻辑。
AsyncIface：服务端通过实现CalculatorService.Iface接口，向客户端的提供具体的异步业务逻辑。
Client：客户端通过CalculatorService.Client的实例对象，以同步的方式访问服务端提供的服务方法。
AsyncClient：客户端通过CalculatorService.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
的代理对象。

接口标识注解@ThriftClient： > (a). serviceId：此客户端代理接口绑定的
```
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);
}
}

在本地

端口号启动

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 |