如果在第三方接口注册前调用第三方接口 则后续注册之后也无法调用 报错

[Nick-The-Uncharted]

报错日志：
java.lang.IllegalStateException: Probably invoke a service before it is registered, or no instance found for it.
原因：
org.apache.servicecomb.core.registry.ThirdServiceRegister#registerMicroserviceMapping 里使用的是computeIfAbsent
org.apache.servicecomb.registry.RegistrationManager#registerMicroserviceMapping 也是

期望：
注册之后第三方接口能正常调用

[liubao68]

这是一个非正常流程的特殊场景，通常是要求服务调用要发生在注册之后的。 可以基于samples提供一个复现用例吗？ 这样可以帮助问题修改，并将这个特殊场景加入自动化，避免以后变更。

[Nick-The-Uncharted]

我在复现过程中发现这个难以复现，然后仔细看了一下当时的日志，发现是一个并发问题。
org.apache.servicecomb.registry.consumer.MicroserviceManager#getOrCreateMicroserviceVersions 这里使用的lock同步
但是 org.apache.servicecomb.registry.RegistrationManager#registerMicroserviceMapping使用的computeIfAbsent同步 两者同步机制不同。我尝试复现一下 但是这个就比较困难了。

[Nick-The-Uncharted]

这样应该能大概率复现

import lombok.extern.slf4j.Slf4j;

import org.apache.servicecomb.core.BootListener;
import org.apache.servicecomb.provider.pojo.RpcReference;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 * 用于持续注册调用org.apache.servicecomb.registry.consumer.MicroserviceManager#getOrCreateMicroserviceVersions 
 *
 * @author 
 * @since 2021-08-31
 */
@Component
@Slf4j
public class EarlyConsumer implements BootListener {
    @RpcReference(microserviceName = "health", schemaId = "heartbeat")
    private HealthSchema healthSchema;
    @RequestMapping("/v1")
    public interface HealthSchema {
        @GetMapping(value = "/heartbeat")
        void heartbeat();
    }

    private volatile boolean stopped = false;

    @Scheduled(fixedRate = 100)
    public void loop() {
        if (stopped) {
            return;
        }
        LOGGER.info("calling service");
        try {
            healthSchema.heartbeat();
        } catch (Throwable e) {
            // ignore error
        }
    }

    @Override
    public void onAfterRegistry(BootEvent event) {
        stopped = true;
    }
}

/**
 * 正常调用，没有EarlyConsumer肯定百分百成功
 *
 * @author 
 * @since 2021-08-31
 */
@Component
@Slf4j
public class NormalConsumer implements BootListener {
    @RpcReference(microserviceName = "health", schemaId = "heartbeat")
    private HealthSchema healthSchema;
    @RequestMapping("/v1")
    public interface HealthSchema {
        @GetMapping(value = "/heartbeat")
        void heartbeat();
    }

    @Override
    public void onAfterRegistry(BootListener.BootEvent event) {
        LOGGER.info("calling service after register");
        try {
            healthSchema.heartbeat();
            LOGGER.info("heartbeat succ");
        } catch (Throwable e) {
            LOGGER.error("exception occur when calling after register", e);
        }
    }


    @Override
    public int getOrder() {
        // 比ThirdServiceRegister晚
        return 0;
    }
}

@Component
public class Register extends ThirdServiceWithInvokerRegister {
    public Register() {
        super("health");
        addSchema("heartbeat", NormalConsumer.HealthSchema.class);
    }
}

[liubao68]

使用最新版本测试了下， 未能重现问题。 如果在 onAfterRegistry 之前调用服务， 会抛出异常（参考 SCBEngine. ensureStatusUp())：

  public void ensureStatusUp() {
    SCBStatus currentStatus = getStatus();
    if (!SCBStatus.UP.equals(currentStatus)) {
      String message =
          "The request is rejected. Cannot process the request due to STATUS = " + currentStatus;
      LOGGER.warn(message);
      throw new InvocationException(Status.SERVICE_UNAVAILABLE, new CommonExceptionData(message));
    }
  }

这个是一定程度上的保护机制。 然而还是要调整业务代码，保证接口调用发生在 AfterRegistry 之后，这个是使用java-chassis的一个约束条件。

[Nick-The-Uncharted]

@liubao68 我记得 "The request is rejected. Cannot process the request due to STATUS = " 这个异常一直都有，使用我上面的代码也无法复现嘛？

        engine.setStatus(SCBStatus.UP);
        engine.triggerEvent(EventType.AFTER_REGISTRY);

在AFTER_REGISTRY的事件处理者处理的时候 是能正常调用的

[Nick-The-Uncharted]

然而还是要调整业务代码，保证接口调用发生在 AfterRegistry 之后，这个是使用java-chassis的一个约束条件。

正常我们是这样的，难点在于kafka默认在spring启动期间就开始消费了

[liubao68]

我将你的测试代码提交PR了， 目前没重现。 参考上面的评论链接。

[Nick-The-Uncharted]

我这升级之后也无法复现了
#2095 应该是这个pr修复的