关于java:seata的TM端启动异常分析

(1): 在试用 seata 的 1.4.1 版本的时候，日志中总有 “no available service found in cluster ‘default’, please make sure registry config correct and keep your seata server running” 这个异样日志打印。在网上翻阅了一下材料，然而不得要领，于是本人翻阅源码，很快解决问题。（阐明：seata 的 1.4.1 版本开始，能够不应用 registry.conf 和 file.conf 文件，应用 springboot 的配置文件即可，而且提供了默认值，能够依据须要配置指定的值）。

(2)：查看源码，是在类 NettyClientChannelManager 的办法 reconnect 中呈现。查看代码，是依据配置的事务组获取无效的服务地址为空所致。
外面参数 transactionServiceGroup 的值是 通过配置 seata.service.vgroup-mapping.xxx 指定。该类的源码如下：

void reconnect(String transactionServiceGroup) {
    List<String> availList = null;
    try {availList = getAvailServerList(transactionServiceGroup);
      } catch (Exception e) {LOGGER.error("Failed to get available servers: {}", e.getMessage(), e);
        return; 
     }
    if (CollectionUtils.isEmpty(availList)) {
        // 疏忽
        if (!(registryService instanceof FileRegistryServiceImpl)) {LOGGER.error("no available service found in cluster'{}', please make sure registry config correct and keep your seata server running", clusterName);
           }
        return;
        }
 // 疏忽
}

(3)：getAvailServerList 办法的实现很简略，就是依据 seata.registry.type 的配置值，找到对应类型的 registry。从对应的服务中获取地址。
本次尝试是配置的值是 eureka，所以是从 eureka 中获取配置的值。

private List<String> getAvailServerList(String transactionServiceGroup) throws Exception {List<InetSocketAddress> availInetSocketAddressList = RegistryFactory.getInstance()
                                                                        .lookup(transactionServiceGroup);
    if (CollectionUtils.isEmpty(availInetSocketAddressList)) {return Collections.emptyList();
    }
    return availInetSocketAddressList.stream().map(NetUtil::toStringAddress).collect(Collectors.toList());
}

(4)：从 EurekaRegistryServiceImpl 类的 lookup 办法中，能够看出是从变量 clusterAddressMap 中获取值。

public List<InetSocketAddress> lookup(String key) throws Exception {String clusterName = getServiceGroup(key);
    if (clusterName == null) {return null;}
    if (!subscribeListener) {refreshCluster();
        subscribe(null, event -> {
            try {refreshCluster();
                } catch (Exception e) {LOGGER.error("Eureka event listener refreshCluster error:{}", e.getMessage(), e);
                }
          });
    }
    return new ArrayList<>(clusterAddressMap.getOrDefault(clusterName.toUpperCase(), Collections.emptySet()));
}

(5)：clusterAddressMap 的值是在函数 refreshCluster 中赋值的。看函数 refreshCluster 的实现能够看到，refreshCluster 的值是把 eureka 中注册的服务及其 IP 地址信息建设一个 MAP 对象。这样就非常明显了，在 seata-server 的 registry.type 配置为 eureka，而且 eureka 的 application 值和客户端的配置 seata.service.vgroup-mapping.xxx= 的值统一即可。代码如下：

private void refreshCluster() {List<Application> applications = getEurekaClient(false).getApplications().getRegisteredApplications(); // 获取 eureka 的注册信息。这里是读取的缓存。if (CollectionUtils.isEmpty(applications)) {clusterAddressMap.clear();
        return;
    }
    ConcurrentMap<String, Set<InetSocketAddress>> collect = new ConcurrentHashMap<>(MAP_INITIAL_CAPACITY);
        for (Application application : applications) {List<InstanceInfo> instances = application.getInstances();
            if (CollectionUtils.isNotEmpty(instances)) {Set<InetSocketAddress> addressSet = instances.stream()
                    .map(instance -> new InetSocketAddress(instance.getIPAddr(), instance.getPort()))
                    .collect(Collectors.toSet());
               collect.put(application.getName(), addressSet);
           }
        }
    clusterAddressMap = collect;
}