完整微服务化示例：使用 Apache ServiceComb 进行微服务开发、容器化、弹性伸缩（二）_语言 & 开发_ServiceComb

【ArchSummit】如何通过AIOps推动可量化的业务价值增长和效率提升？>>> 了解详情 



 写点什么

完整微服务化示例：使用 Apache ServiceComb 进行微服务开发、容器化、弹性伸缩（二）

技工 (Worker)

因为技工最为简单，对其他部门人员依赖最少，我们首先搭建这个部门。

黄金分割运算服务

技工的主要工作是提供黄金分割数列计算服务，当用户需要知道第 n 个黄金分割数时，技工以最快的速度计算出数值并返回给用户。我们可以把这个工作简化为如下数学方程:

value = fibo(n)

复制代码

在暂时不考虑性能的情况下，我们可以迅速实现黄金分割数列的计算。


interface FibonacciService {  long term(int n);}

@Serviceclass FibonacciServiceImpl implements FibonacciService {  @Override  public long term(int n) {    if (n == 0) {      return 0;    } else if (n == 1) {      return 1;    }

    return term(n - 1) + term(n - 2);  }}

复制代码

技工服务端点

黄金分割数量运算已经实现，现在我们需要将服务提供给用户，首先我们定义端点接口：


public interface FibonacciEndpoint {  long term(int n);}

复制代码

引入 ServiceComb 依赖：


<dependency>  <groupId>org.apache.servicecomb</groupId>  <artifactId>spring-boot-starter-provider</artifactId></dependency>

复制代码

接下来我们同时暴露黄金分割运算服务的 Restful 和 RPC 端点：

@RestSchema(schemaId = "fibonacciRestEndpoint")@RequestMapping("/fibonacci")@Controllerpublic class FibonacciRestEndpoint implements FibonacciEndpoint {
  private final FibonacciService fibonacciService;
  @Autowired  FibonacciRestEndpoint(FibonacciService fibonacciService) {    this.fibonacciService = fibonacciService;  }
  @Override  @RequestMapping(value = "/term", method = RequestMethod.GET)  @ResponseBody  public long term(int n) {    return fibonacciService.term(n);  }}
@RpcSchema(schemaId = "fibonacciRpcEndpoint")public class FibonacciRpcEndpoint implements FibonacciEndpoint {
  private final FibonacciService fibonacciService;
  @Autowired  public FibonacciRpcEndpoint(FibonacciService fibonacciService) {    this.fibonacciService = fibonacciService;  }
  @Override  public long term(int n) {    return fibonacciService.term(n);  }}

复制代码

这里用 @RestSchema 和 @RpcSchema 注释两个端点后，ServiceComb 会自动生成对应的服务端点契约，根据如下 microsevice.yaml 配置端点端口，并将契约和服务一起注册到 Service Center(https://github.com/apache/servicecomb-service-center)：

# all interconnected microservices must belong to an application wth the same IDAPPLICATION_ID: companyservice_description:# name of the declaring microservice  name: worker  version: 0.0.1# service center addresscse:  service:    registry:      address: http://sc.servicecomb.io:30100  highway:    address: 0.0.0.0:7070  rest:    address: 0.0.0.0:8080

复制代码

最后，提供技工服务应用启动入口，并加上 @EnableServiceComb 注释启用 ServiceComb ：

@SpringBootApplication@EnableServiceCombpublic class WorkerApplication {
  public static void main(String[] args) {    SpringApplication.run(WorkerApplication.class, args);  }}

复制代码