[alibaba/nacos]"naming_persistent_service_v2" nacos raft 集群一直报错（并且无法干预）

我尝试在本地复现了它。生成原因是连续发送两次注销请求。 虽然nacos在服务端做了判断，但显然在并发情况下并没有生效 InstanceOperatorClientImpl 108 行

public void removeInstance(String namespaceId, String serviceName, Instance instance) {
    boolean ephemeral = instance.isEphemeral();
    String clientId = IpPortBasedClient.getClientId(instance.toInetAddr(), ephemeral);
    if (!clientManager.contains(clientId)) { //这里并发情况下，两条注销请求都会通过
        Loggers.SRV_LOG.warn("remove instance from non-exist client: {}", clientId);
        return;
    }
    Service service = getService(namespaceId, serviceName, ephemeral);
    clientOperationService.deregisterInstance(service, instance, clientId);
}

然后两条消息都被raft同步 最后调用PersistentClientOperationServiceImpl#onInstanceDeregister

第一条请求 将clientManager 中删除 第二条请求 出现空指针异常

private void onInstanceDeregister(Service service, String clientId) { Service singleton = ServiceManager.getInstance().getSingleton(service); Client client = clientManager.getClient(clientId); client.removeServiceInstance(singleton); client.setLastUpdatedTime(); if (client.getAllPublishedService().isEmpty()) { clientManager.clientDisconnected(clientId); } NotifyCenter.publishEvent(new ClientOperationEvent.ClientDeregisterServiceEvent(singleton, clientId)); }

这种情况发生后导致无法接受新请求了，有什么办法恢复集群

这种情况需要修改状态机中的逻辑。保证状态机正常应用raft log. 在应用raft log中加上一些检查逻辑避免这种情况，

@Cczzzz 能提一个 pr 来修复吗，在 onInstanceDeregister 方法中判断一下。

raft下 一条日志的应用失败要导致整个集群失败并无法接受新请求，太可怕了吧。我觉得一条消息只要能确认写入成功就必须应用也成功

这个是 sofa-jraft 的限制。一旦状态机出问题了，就不能让 raft 继续工作了，不然就不能保证整个集群的 raft 数据强一致。

任意一个raft协议都是这么要求的，状态机的apply如果出现意料之外的情况，是不能继续apply raft log，如果依旧无视这种意料之外的情况继续apply，那么这个状态机的数据，已经和别的节点不一致了

而且raft协议是保证日志一致，而不是保证数据一致，他只是共识协议，不是一致性协议

那错误的log数据是需要rollback吗？比如我遇到的状态机错误ERROR_TYPE_STATE_MACHINE， 不可恢复，只能清理log，重启服务

这个问题有进展了吗？我们这边的服务也挂掉几次了，每次都是需要重启所有节点才能恢复，运行一段时间后，又会挂掉。

将 PersistentClientOperationServiceImpl onInstanceDeregister 方法修改为 ： 可以避免上面的问题

private void onInstanceDeregister(Service service, String clientId) {
    Service singleton = ServiceManager.getInstance().getSingleton(service);
    Client client = clientManager.getClient(clientId);
    if (client == null) {
        Loggers.RAFT.warn("client not exist onInstanceDeregister，clientId : {} ", clientId);
        return;
    }
    client.removeServiceInstance(singleton);
    client.setLastUpdatedTime();
    if (client.getAllPublishedService().isEmpty()) {
        clientManager.clientDisconnected(clientId);
    }
    NotifyCenter.publishEvent(new ClientOperationEvent.ClientDeregisterServiceEvent(singleton, clientId));
}

2.1.0beta还是没有这个判空，得自行加上

这个官方是不是可以 合并下CR~ 最近正在合并官方master的代码~