本站文章除注明转载/出处外,均为本站原创或翻译,转载前请务必署名原文链接~~~

微服务解决方案ServiceComb(6)之开发RPC方式微服务入门程序

微信搜索 zze_coding 或扫描 👉 二维码关注我的微信公众号获取更多资源推送:


通过以 REST 方式入门程序的介绍,我们基本理解了 ServiceComb 中服务的发布和消费。那么现在我们以 RPC 方式同样介绍一下 ServiceComb 的服务发布与消费。它们不一样的就是服务的开发方式,但最终效果都是一样的。

工程架构

工程架构同 【Rest 方式入门程序】。

工程详细

父工程

父工程同【Rest 方式入门程序-父工程】。

接口子工程

接口子工程同【Rest 方式入门程序-接口子工程】。

提供者工程

依赖

在【Rest 方式入门程序-提供者子工程】的基础上再添加如下依赖:

<!--RPC 通信模型-->
<dependency>
    <groupId>org.apache.servicecomb</groupId>
    <artifactId>transport-highway</artifactId>
</dependency>
<!--RPC 编程模型-->
<dependency>
    <groupId>org.apache.servicecomb</groupId>
    <artifactId>provider-pojo</artifactId>
</dependency>

服务实现类

package xyz.zze.servicecomb.service.impl;

import org.apache.servicecomb.provider.pojo.RpcSchema;
import xyz.zze.servicecomb.service.HelloService;

/**
 * RPC 方式服务提供者
 */
@RpcSchema(schemaId = "helloService")
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "hello "+ name;
    }
}

配置文件

在 classpath 下创建配置文件 microservice.yaml

APPLICATION_ID: test-service # 当前服务标识
service_description:
  name: helloServiceProvider # 当前服务名称
  version: 0.0.1 # 当前服务版本号
  properties:
    allowCrossApp: true # 允许跨域访问
servicecomb:
  handler:
    chain:
      Provider: {}
  highway:
    address: 0.0.0.0:9090 # RPC 地址
  service:
    registry:
      address: http://127.0.0.1:30100 # 注册中心地址
      autodiscovery: false # 是否自动发现

启动类

配置文件同【Rest 方式入门程序-提供者子工程】的启动类。

消费者子工程

依赖

在【Rest 方式入门程序-消费者子工程】的基础上再添加如下依赖:

<!--RPC 通信模型-->
<dependency>
    <groupId>org.apache.servicecomb</groupId>
    <artifactId>transport-highway</artifactId>
</dependency>
<!--RPC 编程模型-->
<dependency>
    <groupId>org.apache.servicecomb</groupId>
    <artifactId>provider-pojo</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

服务实现类

创建服务实现类,这里的服务实现类实际上是通过 RPC 方式调用提供者服务实现,如下:

package xyz.zze.servicecomb.service.impl;

import org.apache.servicecomb.provider.pojo.RpcReference;
import org.springframework.stereotype.Service;
import xyz.zze.servicecomb.service.HelloService;

/**
 * RPC 方式服务消费者
 */
@Service
public class HelloServiceImpl implements HelloService {

    // 从注册中心寻找指定应用程序下的微服务
    //  microserviceName:格式为 <提供者服务的 APPLICATION_ID>:<提供者服务的 service_description.name>;
    //  schemaId:提供者服务实现类的 schemaId【@RpcSchema(schemaId = "helloService")】,用来标识 RPC 服务提供实例;
    @RpcReference(microserviceName = "test-service:helloServiceProvider",schemaId = "helloService")
    private HelloService helloService;

    @Override
    public String sayHello(String name) {
        return helloService.sayHello(name);
    }
}

对外控制器

创建消费者子工程对外暴露的控制器:

package xyz.zze.servicecomb.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import xyz.zze.servicecomb.service.HelloService;

@RestController
public class HelloController {

    @Autowired
    private HelloService helloService;

    @GetMapping("/hello")
    public String hello(String name) {
        String result = helloService.sayHello(name);
        return result;
    }
}

配置文件

在 classpath 下创建配置文件 microservice.yaml

APPLICATION_ID: test-service
service_description:
  name: helloServiceConsumer
  version: 0.0.1
  proerties:
    allowCrossApp: true
servicecomb:
  handler:
    chain:
      Provider: {}
  highway:
      address: 0.0.0.0:9091
  service:
    registry:
      address: http://127.0.0.1:30100
      autodiscovery: false

在 classpath 下创建 SpringBoot 配置文件 application.properties

server.port=8088

启动类

启动类同【Rest 方式入门程序-消费者子工程】的启动类。

测试

分别启动提供者服务和消费者服务,访问消费者服务 localhost:8088/hello?name=zhangsan
效果同【Rest 方式入门程序-测试】。

# ServiceComb  

如果这篇文章对您有帮助,可点击下方链接分享给你的朋友们😋,如果遇到问题欢迎评论、留言~~~😇

评论

公众号:zze_coding

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×