网站的建设费用预算策划书建设快卡额度查询网站

当前位置： 首页 > news >正文

网站的建设费用预算策划书,建设快卡额度查询网站,淘宝商城网上购物网,wordpress 三主题Nacos服务端服务注册源码分析 服务端调用接口 我们已经知道客户端在注册服务的时候实际上是调用的NamingService.registerInstance这个方法来完成实例的注册#xff0c;而且在最后我们也告诉了大家实际上从本质上讲服务注册就是调用的对应接口nacos/v1/ns/instance#xff…Nacos服务端服务注册源码分析 服务端调用接口 我们已经知道客户端在注册服务的时候实际上是调用的NamingService.registerInstance这个方法来完成实例的注册而且在最后我们也告诉了大家实际上从本质上讲服务注册就是调用的对应接口nacos/v1/ns/instance那咱们现在就在服务端先找到这个接口然后来看具体服务端的操作。 这是从Nacos官网上我们看到的Nacos架构图其实在这里我们已经就能分析出我们要找的接口应该在NamingService这个服务中从源码角度来看其实通过一下这个项目结构图中我们也能清楚的看见naming这个子模块这个naming实际上就是实现服务的注册的。 那我们接着来向下看这个项目中的controller因为我们知道所有的接口其实都在controller中从这些Controller中我们就会明显的看到一个InstanceController所以很明显注册实例一定和它有关 所以我们打开InstanceController来深入研究一下这个时候会发现RequestMapping注解中的值就是我们访问的注册接口 接下来我们再来寻找RESTful API接口POST请求类型的方法register在这个方法中实际上就是接受用户请求把收到的信息进行解析还原成Instance然后调用registerInstance方法来完成注册这个方法才是服务端注册的核心 CanDistro PostMapping Secured(parser NamingResourceParser.class, action ActionTypes.WRITE) public String register(HttpServletRequest request) throws Exception {final String namespaceId WebUtils.optional(request, CommonParams.NAMESPACE_ID, Constants.DEFAULT_NAMESPACE_ID);final String serviceName WebUtils.required(request, CommonParams.SERVICE_NAME);NamingUtils.checkServiceNameFormat(serviceName);final Instance instance HttpRequestInstanceBuilder.newBuilder().setDefaultInstanceEphemeral(switchDomain.isDefaultInstanceEphemeral()).setRequest(request).build();//注册服务实例getInstanceOperator().registerInstance(namespaceId, serviceName, instance);return ok; }我们注意一下的这个方法 getInstanceOperator().registerInstance(namespaceId, serviceName, instance);其中的getInstanceOperator()就是判断是否采用Grpc协议很明显这个位置走的是instanceServiceV2 private InstanceOperator getInstanceOperator() {return upgradeJudgement.isUseGrpcFeatures() ? instanceServiceV2 : instanceServiceV1;服务注册 instanceServiceV2.registerInstance 实际上instanceServiceV2就是InstanceOperatorClientImpl所以我们来看这里面的registerInstance方法. Override public void registerInstance(String namespaceId, String serviceName, Instance instance) {//判断是否为瞬时对象临时客户端boolean ephemeral instance.isEphemeral();//获取客户端IDString clientId IpPortBasedClient.getClientId(instance.toInetAddr(), ephemeral);//通过客户端ID创建客户端连接createIpPortClientIfAbsent(clientId);//获取服务Service service getService(namespaceId, serviceName, ephemeral);//具体注册服务clientOperationService.registerInstance(service, instance, clientId); }在这里我们要分析一些细节其实Nacos2.0以后新增Client模型。一个客户端gRPC长连接对应一个Client每个Client有自己唯一的idclientId。Client负责管理一个客户端的服务实例注册Publish和服务订阅Subscribe。我们可以看一下这个模型其实就是一个接口为了大家看着方便注释改成了中文 public interface Client {// 客户端id/gRPC的connectionIdString getClientId();// 是否临时客户端boolean isEphemeral();// 客户端更新时间void setLastUpdatedTime();long getLastUpdatedTime();// 服务实例注册/注销/查询boolean addServiceInstance(Service service, InstancePublishInfo instancePublishInfo);InstancePublishInfo removeServiceInstance(Service service);InstancePublishInfo getInstancePublishInfo(Service service);CollectionService getAllPublishedService();// 服务订阅/取消订阅/查询订阅boolean addServiceSubscriber(Service service, Subscriber subscriber);boolean removeServiceSubscriber(Service service);Subscriber getSubscriber(Service service);CollectionService getAllSubscribeService();// 生成同步给其他节点的client数据ClientSyncData generateSyncData();// 是否过期boolean isExpire(long currentTime);// 释放资源void release(); }EphemeralClientOperationServiceImpl.registerInstance EphemeralClientOperationServiceImpl实际负责处理服务注册那我们来看具体方法 Override public void registerInstance(Service service, Instance instance, String clientId) {//确保Service单例存在Service singleton ServiceManager.getInstance().getSingleton(service);//根据客户端id找到客户端Client client clientManager.getClient(clientId);if (!clientIsLegal(client, clientId)) {return;}//客户端Instance模型转换为服务端Instance模型InstancePublishInfo instanceInfo getPublishInfo(instance);//将Instance储存到Client里client.addServiceInstance(singleton, instanceInfo);client.setLastUpdatedTime();//建立Service与ClientId的关系NotifyCenter.publishEvent(new ClientOperationEvent.ClientRegisterServiceEvent(singleton, clientId));NotifyCenter.publishEvent(new MetadataEvent.InstanceMetadataEvent(singleton, instanceInfo.getMetadataId(), false)); }ServiceManager Service的容器是ServiceManager但是在com.alibaba.nacos.naming.core.v2包下容器中Service都是单例。 public class ServiceManager {private static final ServiceManager INSTANCE new ServiceManager();//单例Service可以查看Service的equals和hasCode方法private final ConcurrentHashMapService, Service singletonRepository;//namespace下的所有serviceprivate final ConcurrentHashMapString, SetService namespaceSingletonMaps;…..​ 所以从这个位置可以看出当调用这个注册方法的时候ServiceManager负责管理Service单例 //通过Map储存单例的Service public Service getSingleton(Service service) {singletonRepository.putIfAbsent(service, service);Service result singletonRepository.get(service);namespaceSingletonMaps.computeIfAbsent(result.getNamespace(), (namespace) - new ConcurrentHashSet());namespaceSingletonMaps.get(result.getNamespace()).add(result);return result; }clientManager 这是一个接口这里我们要看它对应的一个实现类ConnectionBasedClientManager这个实现类负责管理长连接clientId与Client模型的映射关系 // 根据clientId查询Client public Client getClient(String clientId) {return clients.get(clientId); }Client实例AbstractClient 负责存储当前客户端的服务注册表即Service与Instance的关系。注意对于单个客户端来说同一个服务只能注册一个实例。 Override public boolean addServiceInstance(Service service, InstancePublishInfo instancePublishInfo) {if (null publishers.put(service, instancePublishInfo)) {MetricsMonitor.incrementInstanceCount();}NotifyCenter.publishEvent(new ClientEvent.ClientChangedEvent(this));Loggers.SRV_LOG.info(Client change for service {}, {}, service, getClientId());return true; }ClientOperationEvent.ClientRegisterServiceEvent 这里的目的是为了过滤目标服务得到最终Instance列表建立Service与Client的关系建立Service与Client的关系就是为了加速查询。 ​ 发布ClientRegisterServiceEvent事件ClientServiceIndexesManager监听ClientServiceIndexesManager维护了两个索引 Service与发布clientIdService与订阅clientId private final ConcurrentMapService, SetString publisherIndexes new ConcurrentHashMap();private final ConcurrentMapService, SetString subscriberIndexes new ConcurrentHashMap();private void handleClientOperation(ClientOperationEvent event) {Service service event.getService();String clientId event.getClientId();if (event instanceof ClientOperationEvent.ClientRegisterServiceEvent) {addPublisherIndexes(service, clientId);} else if (event instanceof ClientOperationEvent.ClientDeregisterServiceEvent) {removePublisherIndexes(service, clientId);} else if (event instanceof ClientOperationEvent.ClientSubscribeServiceEvent) {addSubscriberIndexes(service, clientId);} else if (event instanceof ClientOperationEvent.ClientUnsubscribeServiceEvent) {removeSubscriberIndexes(service, clientId);} }//建立Service与发布Client的关系 private void addPublisherIndexes(Service service, String clientId) {publisherIndexes.computeIfAbsent(service, (key) - new ConcurrentHashSet());publisherIndexes.get(service).add(clientId);NotifyCenter.publishEvent(new ServiceEvent.ServiceChangedEvent(service, true)); }这个索引关系建立以后还会触发ServiceChangedEvent代表服务注册表变更。对于注册表变更紧接着还要做两个事情1.通知订阅客户端 2.Nacos集群数据同步。