• 微服务--alpha使用

    alpha使用

    alpha使用

    准备环境

    1. 安装JDK 1.8
    2. 安装Maven 3.x
    3. 安装Docker

    编译

    获取源码：

    $ git clone https://github.com/apache/servicecomb-pack.git
$ cd servicecomb-pack

    • 1
    • 2

    Saga可通过以下任一方式进行构建：

    • 只构建可执行文件：

      $ mvn clean install -DskipTests

      • 1

    • 同时构建可执行文件和docker镜像：

      $ mvn clean install -DskipTests -Pdocker

      • 1

    • 同时构建可执行文件以及Saga发行包

         $ mvn clean install -DskipTests -Prelease

      • 1

    在执行以上任一指令后，可在alpha/alpha-server/target/saga/alpha-server-${version}-exec.jar中找到alpha server的可执行文件。

    如何使用

    引入Pack的依赖

        <dependency>
      <groupId>org.apache.servicecomb.packgroupId>
      <artifactId>omega-spring-starterartifactId>
      <version>${pack.version}version>
    dependency>
    <dependency>
      <groupId>org.apache.servicecomb.packgroupId>
      <artifactId>omega-transport-resttemplateartifactId>
      <version>${pack.version}version>
    dependency>

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10

    注意: 请将${pack.version}更改为实际的版本号。
    版本迁移提示: 从0.3.0 开始，整个项目的代码库名由servicecomb-saga改名为servicecomb-pack, 与此同时我们也更新了对应发布包的组名以及相关包名。
    如果你的项目是从saga 0.2.x 迁移过来，请按照下表所示进行修改。

    name0.2.x0.3.x
    groupIdorg.apache.servicecomb.sagaorg.apache.servicecomb.pack
    Package Nameorg.apache.servicecomb.sagaorg.apache.servicecomb.pack

    Saga 支持

    添加Saga的注解及相应的补偿方法
    以一个转账应用为例：

    1. 在全局事务的起点添加 @SagaStart 的注解。

      import org.apache.servicecomb.pack.omega.context.annotations.SagaStart;

@SagaStart(timeout=10)
public boolean transferMoney(String from, String to, int amount) {
  transferOut(from, amount);
  transferIn(to, amount);
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7

      注意: 默认情况下，超时设置需要显式声明才生效。

    2. 在子事务处添加 @Compensable 的注解并指明其对应的补偿方法。

      import javax.transaction.Transactional;
import org.apache.servicecomb.pack.omega.transaction.annotations.Compensable;

@Compensable(timeout=5, compensationMethod="cancel")
@Transactional
public boolean transferOut(String from, int amount) {
  repo.reduceBalanceByUsername(from, amount);
}
 
@Transactional
public boolean cancel(String from, int amount) {
  repo.addBalanceByUsername(from, amount);
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13

      注意: 实现的服务使用相当的参数，实现的服务和补偿必须满足幂等的条件，同时建议使用Spring @Transactional标注提供本地事务保证。

      注意: 默认情况下，超时设置需要显式声明才生效。

      注意: 若全局事务起点与子事务起点重合，需同时声明 @SagaStart 和 @Compensable 的注解。

    3. 增加 alpha.cluster.address 参数

      alpha:
  cluster:
    address: alpha-server.servicecomb.io:8080

      • 1
      • 2
      • 3

    4. 对转入服务重复第二步即可。

    5. 从pack-0.3.0开始, 你可以在服务函数或者取消函数中通过访问 OmegaContext 来获取 gloableTxId 以及 localTxId 信息。

    显式传递事务上下文

    在一般情况下，Omega能够替你处理事务上下文的传递工作（详情见服务间通信流程），因此你的代码并不需要知道事务上下文的存在。而事务上下文的传递实际上是通过在请求方注入、在接受方提取来完成的，下面举一个请例子来说明这个过程：

    Service A:

    @SagaStart
public void foo() {
  restTemplate.postForEntity("http://service-b/bar", ...);
}

    • 1
    • 2
    • 3
    • 4

    Service B:

    @GetMapping("/bar")
@Compensable
public void bar() {
  ...
}

    • 1
    • 2
    • 3
    • 4
    • 5

    我们可以先来看看Omega是怎么传递事务上下文的：

    1. Service A的foo方法会开启一个新的全局事务。
    2. TransactionClientHttpRequestInterceptor会在RestTemplate请求Service B时在Http请求头中注入事务上下文信息。
    3. 当Servce B接收到请求时，TransactionHandlerInterceptor会从请求头中提取事务上下文信息。

    目前Omega支持以下形式的隐式事务上下文传递：

    1. omega-transport-{dubbo,feign,resttemplate,servicecomb}。
    2. 同线程内调用（基于OmegaContext的ThreadLocal字段）。
    3. 标注了@OmegaContextAware的java.util.concurrent.Executor{Service}。

    那么问题来了，如果无法隐式传递事务上下文怎么办？比如Service A使用某种RPC机制件来调用Service B，而你又没有办法注入或提取事务上下文信息。这个时候你只能采用显式的方式把事务上下文传递出去。ServiceComb Pack从0.5.0开始提供了两个类来实现这一点。

    利用TransactionContext传递

    Service A:

    @SagaStart
public void foo(BarCommand cmd) {
  TransactionContext localTxContext = omegaContext.getTransactionContext();
  someRpc.send(cmd, localTxContext);
}

    • 1
    • 2
    • 3
    • 4
    • 5

    Service B:

    public void listen(BarCommand cmd, TransactionContext injectedTxContext) {
  bar(cmd, injectedTxContext);
}
@Compensable
public void bar(BarCommand cmd, TransactionContext injectedTxContext) {
  ...
  // TransactionContext localTxContext = omegaContext.getTransactionContext();
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8

    需要注意的是bar方法接收到的是注入的事务上下文，在进入bar之后从OmegaContext得到的是本地事务上下文（Omega替你开启了新的事务）。如果Service B也需要显式地传递事务上下文，那么应该使用本地事务上下文。

    利用TransactionContextProperties传递

    Service A：

    public class BarCommand {}
public class BarCommandWithTxContext 
  extends BarCommand implements TransactionContextProperties {
  // setter getter for globalTxId
  // setter getter for localTxId
}
@SagaStart
public void foo(BarCommand cmd) {
  BarCommandWithTxContext cmdWithTxContext = new BarCommandWithTxContext(cmd);
  cmdWithTxContext.setGlobalTxId(omegaContext.globalTxId());
  cmdWithTxContext.setLocalTxId(omegaContext.localTxId());
  someRpc.send(cmdWithTxContext);
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13

    Service B:

    public void listen(BarCommandWithTxContext cmdWithTxContext) {
  bar(cmdWithTxContext);
}

@Compensable
public void bar(BarCommandWithTxContext cmdWithTxContext) {
  ...
  // TransactionContext localTxContext = omegaContext.getTransactionContext();
}

    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9

    和前面一种方式类似，TransactionContextProperties.get{Global,Local}TxId()返回的也是注入的事务上下文信息。

    TCC 支持

    在对应的方法中添加TccStart 和 Participate标注
    以一个转账应用为例：

    1. 在全局事务的起点添加 @TccStart 的注解。

      import org.apache.servicecomb.pack.omega.context.annotations.TccStart;
    
@TccStart
public boolean transferMoney(String from, String to, int amount) {
  transferOut(from, amount);
  transferIn(to, amount);
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7

      Note: 当前TCC还不支持Timeout

    2. 在子事务尝试方法处添加 @Participate 的注解并指明其对应的执行以及补偿方法名,

      import javax.transaction.Transactional;
import org.apache.servicecomb.pack.omega.transaction.annotations.Participate;
  
@Participate(confirmMethod = "confirm", cancelMethod = "cancel")
@Transactional
public void transferOut(String from, int amount) {
  // check banalance
}

@Transactional
public void confirm(String from, int amount) {
  repo.reduceBalanceByUsername(from, amount);
}

@Transactional
public void cancel(String from, int amount) {
  repo.addBalanceByUsername(from, amount);
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18

      注意: confirm和cancel方法的参数列表应该与@Participate方法一样，并且它们必须是幂等。我们强烈建议使用Spring的@Transactional来保证本地事务的一致性。

      注意: 若全局事务起点与子事务起点重合，需同时声明 @TccStart 和 @Participate 的注解。

    3. 增加 alpha.cluster.address 参数

      alpha:
  cluster:
    address: alpha-server.servicecomb.io:8080

      • 1
      • 2
      • 3

    4. 对转入服务重复第二步即可。

    5. 从pack-0.3.0开始, 你可以在服务函数或者取消函数中通过访问 OmegaContext 来获取 gloableTxId 以及 localTxId 信息。

    显式传递事务上下文

    与Saga的@Compensable一样，TCC的@Participate也支持显式传递事务上下文，详情可参阅Saga章节。

    如何运行

    1. 运行postgreSQL,

      docker run -d -e "POSTGRES_DB=saga" -e "POSTGRES_USER=saga" -e "POSTGRES_PASSWORD=password" -p 5432:5432 postgres

      • 1

      如果你想使用MySQL做为后台数据库，可以参考 此文档。

    2. 运行alpha。在运行alpha前，请确保postgreSQL已正常启动。可通过docker或可执行文件的方式来启动alpha。

      • 通过docker运行：
        docker run -d -p 8080:8080 -p 8090:8090 -e "JAVA_OPTS=-Dspring.profiles.active=prd -Dspring.datasource.url=jdbc:postgresql://${host_address}:5432/saga?useSSL=false" alpha-server:${saga_version}

        • 1
      • 通过可执行文件运行：
        java -Dspring.profiles.active=prd -D"spring.datasource.url=jdbc:postgresql://${host_address}:5432/saga?useSSL=false" -jar alpha-server-${saga_version}-exec.jar

1、postgresql
java -D"spring.profiles.active=prd" -D"spring.datasource.url=jdbc:postgresql://localhost:5432/saga?useSSL=false" -D"spring.datasource.username=root" -D"spring.datasource.password=root" -jar alpha-server-0.5.0-exec.jar

2、mysql支持
2.1 创建插件目录
2.2 
java -D"spring.profiles.active=mysql" -D"loader.path=./plugins" -D"spring.datasource.url=jdbc:mysql://localhost:3306/saga?useSSL=false&serverTimezone=Asia/Shanghai" -D"spring.datasource.username=root" -D"spring.datasource.password=root" -D"spring.cloud.consul.host=http://127.0.0.1" -D"spring.cloud.consul.port=8500" -D"spring.cloud.consul.enabled=true"  -D"alpha.server.port=8011" -D"server.port=8092"  -jar alpha-server-0.5.0-exec.jar

// 集群支持
-D"alpha.cluster.master.enabled=true" 


        • 1
        • 2
        • 3
        • 4
        • 5
        • 6
        • 7
        • 8
        • 9
        • 10
        • 11
        • 12
        • 13

      注意: 请在执行命令前将${saga_version}和${host_address}更改为实际值。

      注意: 默认情况下，8080端口用于处理omega处发起的gRPC的请求，而8090端口用于处理查询存储在alpha处的事件信息。

    3. 配置omega。在 application.yaml 添加下面的配置项：

      spring:
  application:
    name: {application.name}
alpha:
  cluster:
    address: {alpha.cluster.addresses}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6

    然后就可以运行相关的微服务了，可通过访问http://${alpha-server:port}/saga/events 来获取所有的saga事件信息。

    在Alpha与Omega之间启用SSL

    详情请参考启用 SSL文档.

    注册中心支持

    支持Alpha启动时注册到发现服务，Omega通过发现服务获取Alpha的实例列表和gRPC地址

    Consul 支持

    1. 运行alpha

      运行时增加 spring.cloud.consul.enabled=true 参数

      java -jar alpha-server-${saga_version}-exec.jar \ 
  --spring.datasource.url=jdbc:postgresql://${host_address}:5432/saga?useSSL=false \
  --spring.datasource.username=saga \
  --spring.datasource.password=saga \
  --spring.cloud.consul.enabled=true \
  --spring.cloud.consul.host=${consul_host} \
  --spring.cloud.consul.port=${consul_port} \
  --spring.profiles.active=prd 
  
java -jar alpha-server-${saga_version}-exec.jar \ 
  --spring.datasource.url=jdbc:postgresql://localhost:5432/saga?useSSL=false \
  --spring.datasource.username=root \
  --spring.datasource.password=root \
  --spring.cloud.consul.enabled=true \
  --spring.cloud.consul.host=${consul_host} \
  --spring.cloud.consul.port=${consul_port} \
  --spring.profiles.active=prd   
  

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18

      注意: ${consul_host} 是 consul 地址, ${consul_port} 是 consul 端口

      注意: 更多 Consul 参数请参考 Spring Cloud Consul 2.x Spring Cloud Consul 1.x

    2. 验证是否注册成功

      访问 Consul 的注册实例查询接口curl http://127.0.0.1:8500/v1/agent/services可以看到如下注册信息，在你 Tags 中可以看到 Alpha 的 gRPC 访问地址已经注册

      {
    "servicecomb-alpha-server-0-0-0-0-8090": {
        "ID": "servicecomb-alpha-server-0-0-0-0-8090",
        "Service": "servicecomb-alpha-server",
        "Tags": [
            "alpha-server-host=0.0.0.0",
            "alpha-server-port=8080",
            "secure=false"
        ],
        "Meta": {},
        "Port": 8090,
        "Address": "10.50.7.14",
        "Weights": {
            "Passing": 1,
            "Warning": 1
        },
        "EnableTagOverride": false
    }
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19

      注意: 默认情况下注册的服务名是servicecomb-alpha-server,如果你需要自定义服务名可以在运行Alpha的时候通过命令行参数spring.application.name配置

    3. 配置omega

      在项目中引入依赖包 omega-spring-cloud-consul-starter

      <dependency>
	<groupId>org.apache.servicecomb.packgroupId>
	<artifactId>omega-spring-cloud-consul-starterartifactId>
	<version>${pack.version}version>
dependency>

      • 1
      • 2
      • 3
      • 4
      • 5

      在 application.yaml 添加下面的配置项：

      spring:
  cloud:
    consul:
      discovery:
      	register: false
      host: 127.0.0.1
      port: 8500
      
alpha:
  cluster:
    register:
      type: consul

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12

      • spring.cloud.consul.host 配置 Consul 注册中心的地址，spring.cloud.consul.port 配置 Consul 注册中心的端口，spring.cloud.consul.discovery.register=false 表示不注册自己到注册中心，更多 Consul 客户端配置可以参考Spring Cloud Consul 2.x Spring Cloud Consul 1.x

      • alpha.cluster.register.type=consul 配置Omega获取Alpha的方式是通过 Consul 的注册中心

      • spring boot 版本兼容

        如果你的项目使用的不是spring boot 2.1.1版本，那么请参照此列表增加兼容的spring-cloud-starter-consul-discovery版本

        spring bootspring-cloud-starter-consul-discovery
        2.1.x.RELEASE2.1.1.RELEASE
        2.0.x.RELEASE2.0.2.RELEASE
          <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloudgroupId>
        <artifactId>spring-cloud-starter-consul-discoveryartifactId>
        <version>2.0.2.RELEASEversion>
      dependency>
    dependencies>
  dependencyManagement>

        • 1
        • 2
        • 3
        • 4
        • 5
        • 6
        • 7
        • 8
        • 9

      注意: 如果你在启动Alpha的时候通过命令行参数spring.application.name自定义了服务名，那么你需要在Omega中通过参数alpha.cluster.serviceId指定这个服务名

    Spring Cloud Eureka支持

    1. 编译 eureka 的版本

      使用 -Pspring-cloud-eureka 参数编译支持 eureka 的版本

      git clone https://github.com/apache/servicecomb-pack.git
cd servicecomb-pack
mvn clean install -DskipTests=true -Pspring-cloud-eureka

      • 1
      • 2
      • 3

    2. 运行alpha

      运行时增加 eureka.client.enabled=true 参数

      java -jar alpha-server-${saga_version}-exec.jar \ 
  --spring.datasource.url=jdbc:postgresql://${host_address}:5432/saga?useSSL=false \
  --spring.datasource.username=saga \
  --spring.datasource.password=saga \
  --eureka.client.enabled=true \
  --eureka.client.service-url.defaultZone=http://127.0.0.1:8761/eureka \  
  --spring.profiles.active=prd 

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7

      注意: 更多 eureka 参数请参考 Spring Cloud Netflix 2.x Spring Cloud Netflix 1.x

    3. 验证是否注册成功

      访问Eureka的注册实例查询接口curl http://127.0.0.1:8761/eureka/apps/可以看到如下注册信息，在你metadata中可以看到Alpha的gRPC访问地址0.0.0.0:8080已经注册

      <applications>
  <versions__delta>1versions__delta>
  <apps__hashcode>UP_1_apps__hashcode>
  <application>
    <name>SERVICECOMB-ALPHA-SERVERname>
    <instance>
      <instanceId>0.0.0.0::servicecomb-alpha-server:8090instanceId>
      <hostName>0.0.0.0hostName>
      <app>SERVICECOMB-ALPHA-SERVERapp>
      <ipAddr>0.0.0.0ipAddr>
      <status>UPstatus>
	  ...
      <metadata>
        <management.port>8090management.port>
        <servicecomb-alpha-server>0.0.0.0:8080servicecomb-alpha-server>
      metadata>
      ...
    instance>
  application>
applications>

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20

      注意: 默认情况下注册的服务名是SERVICECOMB-ALPHA-SERVER,如果你需要自定义服务名可以在运行Alpha的时候通过命令行参数spring.application.name配置

    4. 配置omega

      在项目中引入依赖包 omega-spring-cloud-eureka-starter

      <dependency>
	<groupId>org.apache.servicecomb.packgroupId>
	<artifactId>omega-spring-cloud-eureka-starterartifactId>
	<version>${pack.version}version>
dependency>

      • 1
      • 2
      • 3
      • 4
      • 5

      在 application.yaml 添加下面的配置项：

      eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:8761/eureka
alpha:
  cluster:
    register:
      type: eureka

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8

      • eureka.client.service-url.defaultZone 配置Eureka注册中心的地址，更多Eureka客户端配置可以参考Spring Cloud Netflix 2.x 或 Spring Cloud Netflix 1.x

      • alpha.cluster.register.type=eureka 配置Omega获取Alpha的方式是通过Eureka的注册中心

      • spring boot 版本兼容

        如果你的项目使用的不是spring boot 2.1.1版本，那么请参照此列表增加兼容的spring-cloud-starter-consul-discovery版本

        spring bootspring-cloud-starter-netflix-eureka-client
        2.1.x.RELEASE2.1.1.RELEASE
        2.0.x.RELEASE2.0.3.RELEASE
          <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloudgroupId>
        <artifactId>spring-cloud-starter-netflix-eureka-clientartifactId>
        <version>2.0.3.RELEASEversion>
      dependency>
    dependencies>
  dependencyManagement>

        • 1
        • 2
        • 3
        • 4
        • 5
        • 6
        • 7
        • 8
        • 9

      注意: 如果你在启动Alpha的时候通过命令行参数spring.application.name自定义了服务名，那么你需要在Omega中通过参数alpha.cluster.serviceId指定这个服务名

    Spring Cloud Zookeeper 支持

    1. 运行alpha

      运行时增加 spring.cloud.zookeeper.enabled=true 参数

      java -jar alpha-server-${saga_version}-exec.jar \ 
  --spring.datasource.url=jdbc:postgresql://${host_address}:5432/saga?useSSL=false \
  --spring.datasource.username=saga \
  --spring.datasource.password=saga \
  --spring.cloud.zookeeper.enabled=true \
  --spring.cloud.zookeeper.connectString=${zookeeper_host}:${zookeeper_port} \
  --spring.profiles.active=prd 

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7

      注意: ${zookeeper_host} 是 zookeeper 地址, ${zookeeper_port} 是 zookeeper 端口

      注意: 更多 Zookeeper 参数请参考 Spring Cloud Zookeeper 2.x Spring Cloud Zookeeper 1.x

    2. 验证是否注册成功

      访问Zookeeper的实例, 在znode /services/servicecomb-alapha-server 下，查看服务注册znode, 在注册的znode中，存在类似以下值

      {
    "name": "servicecomb-alpha-server",
    "id": "9b2223ae-50e6-49a6-9f3b-87a1ff06a016",
    "address": "arch-office",
    "port": 8090,
    "sslPort": null,
    "payload": {
        "@class": "org.springframework.cloud.zookeeper.discovery.ZookeeperInstance",
        "id": "servicecomb-alpha-server-1",
        "name": "servicecomb-alpha-server",
        "metadata": {
        "servicecomb-alpha-server": "arch-office:8080"
        }
    },
    "registrationTimeUTC": 1558000134185,
    "serviceType": "DYNAMIC",
    "uriSpec": {
        "parts": [
        {
            "value": "scheme",
            "variable": true
        },
        {
            "value": "://",
            "variable": false
        },
        {
            "value": "address",
            "variable": true
        },
        {
            "value": ":",
            "variable": false
        },
        {
            "value": "port",
            "variable": true
        }
        ]
    }
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20
      • 21
      • 22
      • 23
      • 24
      • 25
      • 26
      • 27
      • 28
      • 29
      • 30
      • 31
      • 32
      • 33
      • 34
      • 35
      • 36
      • 37
      • 38
      • 39
      • 40
      • 41

      注意: 默认情况下注册的服务名是servicecomb-alpha-server,如果你需要自定义服务名可以在运行Alpha的时候通过命令行参数spring.application.name配置

    3. 配置omega

      在项目中引入依赖包 omega-spring-cloud-zookeeper-starter

      <dependency>
	<groupId>org.apache.servicecomb.packgroupId>
	<artifactId>omega-spring-cloud-zookeeper-starterartifactId>
	<version>${pack.version}version>
dependency>

      • 1
      • 2
      • 3
      • 4
      • 5

      在 application.yaml 添加下面的配置项：

      spring:
  cloud:
    zookeeper:
      enabled: true
      connectString: 127.0.0.1:2181
      
alpha:
  cluster:
    register:
      type: zookeeper

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10

      • spring.cloud.zookeeper.connectString 配置 Zookeeper 注册中心的地址，更多zookeeper客户端配置可以参考Spring Cloud Zookeeper 2.x Spring Cloud Zookeeper 1.x

      • alpha.cluster.register.type=zookeeper 配置Omega获取Alpha的方式是通过 Zookeeper 的注册中心

      • spring boot 版本兼容

        如果你的项目使用的不是spring boot 2.1.1版本，那么请参照此列表增加兼容的spring-cloud-starter-zookeeper-discovery版本

        spring bootspring-cloud-starter-zookeeper-discovery
        2.1.x.RELEASE2.1.1.RELEASE
        1.5.17.RELEASE1.2.2.RELEASE
          <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloudgroupId>
        <artifactId>spring-cloud-starter-zookeeper-discoveryartifactId>
        <version>2.1.1.RELEASEversion>
      dependency>
    dependencies>
  dependencyManagement>

        • 1
        • 2
        • 3
        • 4
        • 5
        • 6
        • 7
        • 8
        • 9

      注意: 如果你在启动Alpha的时候通过命令行参数spring.application.name自定义了服务名，那么你需要在Omega中通过参数alpha.cluster.serviceId指定这个服务名

    Spring Cloud Nacos Discovery 支持

    1. 运行alpha

      运行时增加 nacos.client.enabled=true 参数

      java -jar alpha-server-${saga_version}-exec.jar \ 
  --spring.datasource.url=jdbc:postgresql://${host_address}:5432/saga?useSSL=false \
  --spring.datasource.username=saga \
  --spring.datasource.password=saga \
  --spring.cloud.nacos.discovery.enabled=true \
  --spring.cloud.nacos.discovery.serverAddr=${nacos_host}:${nacos_port} \
  --nacos.client.enabled=true \
  --spring.profiles.active=prd 

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8

      注意: ${nacos_host} 是 nacos 地址, ${nacos_port} 是 nacos 端口

      注意: 更多 Nacos 参数请参考 Spring Cloud Nacos Discovery

    2. 验证是否注册成功

      访问Nacos的实例, 通过nacos 提供的openapicurl -X GET 'http://127.0.0.1:8848/nacos/v1/ns/instance/list?serviceName=servicecomb-alpha-server‘ 可以看到如下服务注册信息，在metadata 中可以发现gRPC的地址已经被注册

       {
 "metadata": {},
 "dom": "servicecomb-alpha-server",
 "cacheMillis": 3000,
 "useSpecifiedURL": false,
 "hosts": [
     {
     "valid": true,
     "marked": false,
     "metadata": {
         "preserved.register.source": "SPRING_CLOUD",
         "servicecomb-alpha-server": "192.168.2.28:8080"
     },
     "instanceId": "192.168.2.28#8090#DEFAULT#DEFAULT_GROUP@@servicecomb-alpha-server",
     "port": 8090,
     "healthy": true,
     "ip": "192.168.2.28",
     "clusterName": "DEFAULT",
     "weight": 1,
     "ephemeral": true,
     "serviceName": "servicecomb-alpha-server",
     "enabled": true
     }
 ],
 "name": "DEFAULT_GROUP@@servicecomb-alpha-server",
 "checksum": "d9e8deefd1c4f198980f4443d7c1b1fd",
 "lastRefTime": 1562567653565,
 "env": "",
 "clusters": ""
 }

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20
      • 21
      • 22
      • 23
      • 24
      • 25
      • 26
      • 27
      • 28
      • 29
      • 30

      注意: 默认情况下注册的服务名是servicecomb-alpha-server,如果你需要自定义服务名可以在运行Alpha的时候通过命令行参数spring.application.name配置

    3. 配置omega

      在项目中引入依赖包 omega-spring-cloud-nacos-starter

      <dependency>
	<groupId>org.apache.servicecomb.packgroupId>
	<artifactId>omega-spring-cloud-nacos-starterartifactId>
	<version>${pack.version}version>
dependency>

      • 1
      • 2
      • 3
      • 4
      • 5

      在 application.yaml 添加下面的配置项：

      spring:
  cloud:
    nacos:
      discovery:
        enabled: true
        serverAddr: 127.0.0.1:8848
      
alpha:
  cluster:
    register:
      type: nacos

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11

      • spring.cloud.nacos.discovery.serverAddr 配置 Nacos 注册中心的地址，更多Nacos 参数请参考 Spring Cloud Nacos Discovery

      • alpha.cluster.register.type=nacos 配置Omega获取Alpha的方式是通过 Nacos 的注册中心

      • spring boot 版本兼容

        如果你的项目使用的不是spring boot 2.1.1版本，那么请参照此列表增加兼容的spring-cloud-starter-alibaba-nacos-discovery版本

        spring bootspring-cloud-starter-alibaba-nacos-discovery
        2.1.x.RELEASE0.2.2.RELEASE
        1.5.17.RELEASE0.1.2.RELEASE
          <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloudgroupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
        <version>0.2.2.RELEASEversion>
      dependency>
    dependencies>
  dependencyManagement>

        • 1
        • 2
        • 3
        • 4
        • 5
        • 6
        • 7
        • 8
        • 9

      注意: 如果你在启动Alpha的时候通过命令行参数spring.application.name自定义了服务名，那么你需要在Omega中通过参数alpha.cluster.serviceId指定这个服务名

    集群

    Alpha 可以通过部署多实例的方式保证高可用，使用 alpha.cluster.master.enabled=true 参数开启集群支持

  • 相关阅读:
    大厂秋招真题【DP/贪心】字节跳动20230923秋招T1-小红的 01 串【欧弟算法】全网最全大厂秋招题解
    信息学奥赛一本通2062：【例1.3】电影票
    已解决：KeyError: ‘The truth value of a Series is ambiguous‘ 问题
    华为OD机考算法题：篮球比赛
    Design A Dropbox
    Linux网络配置
    2022年9月9号Sprin框架的学习(课时七)Aop
    怎样使用Pyglet库给推箱子游戏画关卡地图
    【深度学习】实验18 自然语言处理
    MySQL事务：事务隔离
  • 原文地址：https://blog.csdn.net/huan13479195089/article/details/128137826