【BlossomRPC】接入注册中心

news/2024/6/15 16:17:38/文章来源:https://blog.csdn.net/Zhangsama1/article/details/137184670

文章目录

  • Nacos
  • Zookeeper
  • 自研配置中心

RPC项目

配置中心项目

网关项目

这是BlossomRPC项目的最后一篇文章了,接入完毕注册中心,一个完整的RPC框架就设计完成了。
对于项目对注册中心的整合,其实我们只需要再服务启动的时候将ip/port/servicename注册到注册中心上即可。
注册中心这里只是一个简单的ip/port信息的存储器而已。
那么我们就需要考虑用什么样的一种方式来引入注册中心。
这里可以考虑使用Spring的AutoConfiguration然后配合Conditional类型的注解进行判断使用那个注册中心。
这里我提供了一个RegisterService接口提供抽象的注册方法,只需要实现这个接口就可以再项目中引入自己实现的注册中心了。

public interface RegisterService {default void init(){}void register(RpcServiceInstance instance);default void unregister(RpcServiceInstance instance){}RpcServiceInstance discovery(RpcServiceInstance instance);
}

Nacos

我们首先以Nacos为例。实现所有的接口方法。

package blossom.project.rpc.nacos;import blossom.project.rpc.common.register.RegisterService;
import blossom.project.rpc.common.register.RpcServiceInstance;
import blossom.project.rpc.common.loadbalance.LoadBalanceStrategy;
import blossom.project.rpc.common.loadbalance.PollLoadBalance;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingFactory;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
import lombok.extern.slf4j.Slf4j;import java.util.List;
import java.util.Objects;/*** @author: ZhangBlossom* @date: 2023/12/19 23:46* @contact: QQ:4602197553* @contact: WX:qczjhczs0114* @blog: https://blog.csdn.net/Zhangsama1* @github: https://github.com/ZhangBlossom* NacosRegisterService类*/
@Slf4j
public class NacosRegisterService implements RegisterService {private NamingService namingService;private LoadBalanceStrategy<Instance> loadBalanceStrategy= new PollLoadBalance<>();public NacosRegisterService(){}public NacosRegisterService(String serverAddress) {try {this.namingService = NamingFactory.createNamingService(serverAddress);} catch (NacosException e) {throw new RuntimeException(e);}}public NacosRegisterService(String serverAddress, LoadBalanceStrategy loadBalanceStrategy) {try {this.namingService = NamingFactory.createNamingService(serverAddress);this.loadBalanceStrategy = loadBalanceStrategy;} catch (NacosException e) {throw new RuntimeException(e);}}@Overridepublic void register(RpcServiceInstance instance) {if (Objects.isNull(instance)) {log.info("the Reigster Service Info can not be null!!!");return;}log.info("start to register instance to Nacos: {}",instance);try {//注册服务  服务名称:blossom.project.rpc.core.service.RpcServicenamingService.registerInstance(instance.getServiceName(), instance.getServiceIp(),instance.getServicePort());} catch (NacosException e) {log.error("register the ServiceInstance to Nacos failed!!!");throw new RuntimeException(e);}}@Overridepublic void unregister(RpcServiceInstance instance) {if (Objects.isNull(instance)) {log.info("the Reigster Service Info can not be null!!!");return;}log.info("start to unregister instance to Nacos: {}",instance);try {//进行服务注销namingService.deregisterInstance(instance.getServiceName(), instance.getServiceIp(),instance.getServicePort());} catch (NacosException e) {log.error("unregister the ServiceInstance from Nacos failed!!!");throw new RuntimeException(e);}}@Overridepublic RpcServiceInstance discovery(RpcServiceInstance instance) {try {List<Instance> instances = namingService.selectInstances(instance.getServiceName(),instance.getGroupName(), true);Instance rpcInstance = loadBalanceStrategy.choose(instances);if (Objects.nonNull(rpcInstance)) {return RpcServiceInstance.builder().serviceIp(rpcInstance.getIp()).servicePort(rpcInstance.getPort()).serviceName(rpcInstance.getServiceName()).build();}return null;} catch (NacosException e) {log.error("discovery the ServiceInstance from Nacos failed!!!");throw new RuntimeException(e);}}}

之后,我们得考虑,如何让用户无感知的只需要启动项目和引入依赖,就可以完成服务的注册。
我们考虑使用@AutoConfiguration的方式来进行。
同时,还得预留一种情况,就是用于自研的注册中心。

package blossom.project.rpc.nacos;import blossom.project.rpc.common.constants.RpcCommonConstants;
import blossom.project.rpc.common.loadbalance.LoadBalanceStrategy;
import blossom.project.rpc.common.loadbalance.PollLoadBalance;
import blossom.project.rpc.common.register.RegisterService;
import org.springframework.beans.BeansException;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.AutoConfigureOrder;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.EnvironmentAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Conditional;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.env.Environment;import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.Map;
import java.util.Objects;/*** @author: ZhangBlossom* @date: 2023/12/22 18:50* @contact: QQ:4602197553* @contact: WX:qczjhczs0114* @blog: https://blog.csdn.net/Zhangsama1* @github: https://github.com/ZhangBlossom* NacosAutoConfiguration类*/
@Configuration
//@AutoConfiguration
//@AutoConfigureBefore(value = RegisterService.class)
@AutoConfigureOrder(value = Integer.MAX_VALUE)
//@Conditional(OnNacosClientClassCondition.class)
public class NacosAutoConfiguration implementsApplicationContextAware, EnvironmentAware {/*** 这个bean只会在存在nacos的依赖的时候才会创建** @return*/@Primary@Bean(name = "nacosRegisterService")@ConditionalOnMissingBean(name = "spiRegisterService")public RegisterService nacosRegisterService() {//创建注册中心// 优先检查是否存在 SPI 实现类// 获取Nacos相关配置,例如服务器地址等//String serverAddress = "localhost:8848"; // 从配置中读取Nacos服务器地址// ... 其他所需配置String registerAddress = environment.getProperty(RpcCommonConstants.REGISTER_ADDRESS);try {// 使用反射创建NamingService实例//Class<?> namingFactoryClass =//        Class.forName("com.alibaba.nacos.api.naming.NamingFactory");//Method createNamingServiceMethod =//        namingFactoryClass.getMethod("createNamingService", String.class);//Object namingServiceInstance = createNamingServiceMethod.invoke(null, serverAddress);// 创建NacosRegisterService实例Class<?> nacosRegisterServiceClass = Class.forName(RpcCommonConstants.NACOS_REGISTER_CLASS);Constructor<?> constructor = nacosRegisterServiceClass.getConstructor(String.class,LoadBalanceStrategy.class);return (RegisterService) constructor.newInstance(registerAddress, new PollLoadBalance<>());} catch (ClassNotFoundException | NoSuchMethodException | IllegalAccessException | InstantiationException |InvocationTargetException e) {throw new IllegalStateException("Failed to create NacosRegisterService", e);}}private ApplicationContext applicationContext;@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext = applicationContext;}private Environment environment;@Overridepublic void setEnvironment(Environment environment) {this.environment = environment;}
}

通过这种方式,只要引入了Nacos的依赖,在项目启动的时候就会使用Nacos作为项目的注册中心。
同时,如果用户也提供了自己的注册中心,那么会优先使用用户自己的注册中心来进行服务注册。
而用户自己的注册中心的实现,使用的是SPI的方式。

package blossom.project.rpc.core.proxy.spring;import blossom.project.rpc.common.constants.RpcCommonConstants;
import blossom.project.rpc.common.loadbalance.LoadBalanceStrategy;
import blossom.project.rpc.common.loadbalance.PollLoadBalance;
import blossom.project.rpc.common.register.RegisterService;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.beans.factory.support.BeanDefinitionRegistryPostProcessor;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.EnvironmentAware;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;import java.util.Map;
import java.util.ServiceLoader;@Configuration
public class SpringRegisterServicePostProcessor implementsBeanDefinitionRegistryPostProcessor ,EnvironmentAware,ApplicationContextAware {private Environment environment;@Overridepublic void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {ServiceLoader<RegisterService> serviceLoader = ServiceLoader.load(RegisterService.class);if (!serviceLoader.iterator().hasNext()) {// 没有通过SPI找到实现,加载Nacos或Zookeeper的实现String registerAddress = environment.getProperty(RpcCommonConstants.REGISTER_ADDRESS);registerServiceBeanDefinition(registry, registerAddress);} else {// 通过SPI找到了实现,将其注册到Spring容器registerServiceViaSpi(serviceLoader, registry);}}private void registerServiceViaSpi(ServiceLoader<RegisterService> serviceLoader, BeanDefinitionRegistry registry) {// 获取SPI的RegisterService实现RegisterService registerService = serviceLoader.iterator().next();// 创建BeanDefinitionBeanDefinition beanDefinition = BeanDefinitionBuilder.genericBeanDefinition(registerService.getClass()).getBeanDefinition();// 注册BeanDefinition到Spring容器registry.registerBeanDefinition("spiRegisterService", beanDefinition);}private void registerServiceBeanDefinition(BeanDefinitionRegistry registry, String registerAddress) {try {registerReflectiveService(registry, RpcCommonConstants.NACOS_REGISTER_CLASS, registerAddress);} catch (Exception e) {registerReflectiveService(registry, RpcCommonConstants.ZK_REGISTER_CLASS, registerAddress);}}private void registerReflectiveService(BeanDefinitionRegistry registry, String className, String registerAddress) {try {Class<?> registerServiceClass = Class.forName(className);BeanDefinition beanDefinition =BeanDefinitionBuilder.genericBeanDefinition(registerServiceClass).getBeanDefinition();registry.registerBeanDefinition(className, beanDefinition);System.out.println(registry.getBeanDefinition(className));} catch (Exception e) {throw new RuntimeException("Failed to register " + className, e);}}@Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {// No implementation required for this method in this context}@Overridepublic void setEnvironment(Environment environment) {this.environment = environment;}private ApplicationContext applicationContext;@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext = applicationContext;}}

好的,这里我们已Nacos为例,对服务进行启动。
成功完成服务实例的注册
在这里插入图片描述启动多个服务实例也可以
在这里插入图片描述
同理,对于zk,也是一样的方法。

Zookeeper

@Slf4j
public class ZookeeperRegisterService implements RegisterService {private static final String REGISTRY_PATH = "/rpc_registry";/*** zk注册中心*/private final ServiceDiscovery<RpcServiceInstance> serviceDiscovery;private LoadBalanceStrategy<ServiceInstance<RpcServiceInstance>> loadBalanceStrategy;public ZookeeperRegisterService(String serverAddress,LoadBalanceStrategy loadBalanceStrategy) throws Exception {CuratorFramework client = CuratorFrameworkFactory.newClient(serverAddress,new ExponentialBackoffRetry(2000, 3));client.start();JsonInstanceSerializer<RpcServiceInstance> serializer = new JsonInstanceSerializer<>(RpcServiceInstance.class);this.serviceDiscovery =ServiceDiscoveryBuilder.builder(RpcServiceInstance.class).client(client).serializer(serializer).basePath(REGISTRY_PATH).build();this.serviceDiscovery.start();this.loadBalanceStrategy = loadBalanceStrategy;}@Overridepublic void register(RpcServiceInstance instance) {if (Objects.isNull(instance)) {log.info("the Reigster Service Info can not be null!!!");return;}log.info("start to register instance to Zookeeper: {}",instance);try {ServiceInstance<RpcServiceInstance> serviceInstance =ServiceInstance.<RpcServiceInstance>builder().name(instance.getServiceName()).address(instance.getServiceIp()).port(instance.getServicePort()).payload(instance).build();this.serviceDiscovery.registerService(serviceInstance);} catch (Exception e) {throw new RuntimeException(e);}}@Overridepublic RpcServiceInstance discovery(RpcServiceInstance instance) {Collection<ServiceInstance<RpcServiceInstance>> serviceInstances = null;try {serviceInstances = this.serviceDiscovery.queryForInstances(instance.getServiceName());ServiceInstance<RpcServiceInstance> serviceInstance =this.loadBalanceStrategy.choose((List<ServiceInstance<RpcServiceInstance>>) serviceInstances);if (serviceInstance != null) {return serviceInstance.getPayload();}return null;} catch (Exception e) {throw new RuntimeException(e);}}}public class OnZookeeperClientClassCondition implements Condition {@Overridepublic boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) {try {Class.forName(ZK_DISCOVERY_CLASS);return true;} catch (ClassNotFoundException e) {return false;}}

自研配置中心

上文提到,有可能用户会使用自己的注册中心。所以我提供了基于spi机制的方式,来让用户引入自己的注册中心。
在这里插入图片描述
用户在项目启动的时候通过SPI的方式提供自己实现的注册中心代码即可。
如果不存在会扫描是否存在Nacos/Zk,如果都不存在,就报错,否则优先使用用户自定义的配置中心。

到此为止,一个简单的自研配置中心就完成了。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.luyixian.cn/news_show_1035293.aspx

如若内容造成侵权/违法违规/事实不符,请联系dt猫网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

安全测试重点思考(上)--AWVS使用/XSS漏洞复现

AWVS使用/XSS漏洞复现 AWVS功能使用Dashboard功能Targets功能Vulnerabilities功能Scans功能Reports功能Discovery功能Users功能Scan ProfilesNetwork Scanner功能Issue Trackers功能WAFs功能Proxy Settings功能 漏洞测试实操DVWA介绍XSS分类反射型xss解决存储型xss解决 安全测试…

手搓 Docker Image Creator(DIC)工具(02):预备知识

此节主要简单介绍一下 Docker、Dockerfile 的基本概念&#xff0c;Dockerfile 对的基本语法&#xff0c;Windows 和 macOS 下 Docker 桌面的安装&#xff0c;Docker 镜像的创建和运行测试等。 1 关于 Docker Docker 是一个开源的应用容器引擎&#xff0c;它允许开发者打包应用…

从“量子”到分子:探索计算的无限可能 | 综述荐读

在2023年年末&#xff0c;两篇划时代的研究报告在《科学》&#xff08;Science&#xff09;杂志上引发了广泛关注。这两篇论文分别来自两个研究小组&#xff0c;它们共同揭示了单氟化钙分子间相互作用的研究成果&#xff0c;成功地在这些分子间创造出了分子量子比特。这一成就不…

C++的字节对齐

什么是字节对齐 参考什么是字节对齐&#xff0c;为什么要对齐? 现代计算机中&#xff0c;内存空间按照字节划分&#xff0c;理论上可以从任何起始地址访问任意类型的变量。但实际中在访问特定类型变量时经常在特定的内存地址访问&#xff0c;这就需要各种类型数据按照一定的规…

基于SpringBoot的在线答疑系统的研究与实现

摘 要 社会的发展和科学技术的进步&#xff0c;互联网技术越来越受欢迎。网络计算机的生活方式逐渐受到广大师生的喜爱&#xff0c;也逐渐进入了每个学生的使用。互联网具有便利性&#xff0c;速度快&#xff0c;效率高&#xff0c;成本低等优点。 因此&#xff0c;构建符合自…

【数字图像处理】二值图和灰度图的形态学处理

文章目录 形态学处理二值图形态学处理二值图形态学基本算子二值图连通分量提取、区域标记二值图细化算法 灰度图形态学处理灰度图形态学基本算子灰度图形态学梯度灰度图 tophat 算法 形态学处理 二值图形态学处理 二值图形态学基本算子 二值图形态学图像处理通常在目标图像中…

Spring Boot 学习(1)——环境搭建

一只老辣鸟的自我救赎 不科普&#xff0c;简单记录学习过程。 开发环境约束&#xff1a; jdk1.8 Spring Boot 1.5.9 Spring 4.3.13 Maven 3.3.3 Intellij IDEA 2017 【脑瓜灵光的开发环境随意&#xff0c;不灵光尽量按上述约束设置。看了好些教程总…

基于SSM+MySQL的校园在线点餐系统设计与实现(包运行调试)

介绍 SSM&#xff1a;采用主流的SpringMVC、Spring、Mybatis框架构建 layui&#xff1a;Layui是一套开源的 Web UI 解决方案&#xff0c;采用自身经典的模块化规范&#xff0c;并遵循原生 HTML/CSS/JS 的开发方式&#xff0c;常适合网页界面的快速开发 源码论文获取 文章链接…

Docker实例

华子目录 docker实例1.为Ubuntu镜像添加ssh服务2.Docker安装mysql docker实例 1.为Ubuntu镜像添加ssh服务 (1)访问https://hub.docker.com&#xff0c;寻找合适的Ubuntu镜像 (2)拉取Ubuntu镜像 [rootserver ~]# docker pull ubuntu:latest latest: Pulling from library/ub…

VMware虚拟机三种网络模式配置

vmware有三种网络工作模式&#xff1a;Bridged&#xff08;桥接模式&#xff09;、NAT&#xff08;网络地址转换模式&#xff09;、Host-Only&#xff08;仅主机模式&#xff09;。 1. 打开网络编辑器&#xff08;编辑 --> 虚拟网络编辑器&#xff09; 在主机上有VMware Ne…

pytest--python的一种测试框架--pytest初阶

前言 使用pytest去做测试时我们对文件名的命名其实是有规范的&#xff0c;要用test_开头&#xff01;&#xff01;&#xff01; 一、pytest初阶 def test_one():expect1actual1assert expectactual#测试专用语句&#xff1a;assert&#xff0c;识别期望与实际值是否相等这个…

【Node.js】大文件上传

概述 大文件上传通常采用分片上传。如果因为某些原因上传突然中断&#xff0c;解决问题之后可以接着之前的分片上传&#xff0c;而不需要从头开始上传&#xff0c;也就是断点续传。此外还可以利用多个网络连接并行上传多个分片&#xff0c;提高上传速度。 注&#xff1a;前端不…

Linux 著名的sudo、su是什么?怎么用?

一、su 什么是su&#xff1f; su命令&#xff08;简称是&#xff1a;substitute 或者 switch user &#xff09;用于切换到另一个用户&#xff0c;没有指定用户名&#xff0c;则默认情况下将以root用户登录。 为了向后兼容&#xff0c;su默认不改变当前目录&#xff0c;只设…

C++ 中的 vector 的模拟实现【代码纯享】

文章目录 C 中的 vector 模拟实现1. vector 的基本概念2. vector 的基本操作3. vector 的模拟实现4.代码纯享5. 总结 C 中的 vector 模拟实现 在 C 中&#xff0c;vector 是一个非常重要的容器&#xff0c;它提供了动态数组的功能。在本篇博客中&#xff0c;我们将尝试模拟实现…

基于CycleGan开源项目实战图像合成

项目代码及数据链接见文末 没有配对图像能够进行图像生成吗&#xff1f;当然可以&#xff0c;CycleGan不需要配对的数据&#xff0c;例如&#xff0c;只要我们知道马的样子和斑马的样子&#xff0c;我们就能够很轻松的将马转化为斑马。 1.网络结构 传统GAN网络是&#xff0c;我…

src挖掘技巧总结分享

src挖洞技术分享 src推荐刚入门的新手首选公益src如漏洞盒子、补天src&#xff0c;因为漏洞盒子收录范围广&#xff0c;只要是国内的站点都收入&#xff0c;相比其它src平台挖掘难度非常适合新手。后续可以尝试先从一些小的src厂商入手。 首先是熟能生巧&#xff0c;我一开始挖…

java网络编程——网络编程概述及UDP/TCP通信编程的实现

前言&#xff1a; 学习到通信了&#xff0c;整理下相关知识点。打好基础&#xff0c;daydayup!!! 网络编程 网络编程指可以让设备中的程序与网络上其他设备中的程序进行数据交互。 基本的通信架构 基本的通信架构有两种形式&#xff1a;CS架构&#xff08;Client客户端/Server服…

Docker数据卷挂载

一、容器与数据耦合的问题: 数据卷是虚拟的&#xff0c;不真实存在的&#xff0c;它指向文件中的文件夹 &#xff0c;属主机文件系统通过数据卷和容器数据进行联系&#xff0c;你改变我也改变。 解决办法&#xff1a; 对宿主机文件系统内的文件进行修改&#xff0c;会立刻反应…

光伏无人机:绿色能源与航空技术的融合创新

在可再生能源和无人机技术快速发展的背景下&#xff0c;光伏无人机作为一种新兴的绿色航空器&#xff0c;正逐渐展现出其独特的优势和广阔的应用前景。本文将深入探讨光伏无人机的原理、优势以及其在多个领域的应用&#xff0c;展望其未来的发展趋势。 一、光伏无人机的原理 光…

Midjourney绘图欣赏系列(十五)

Midjourney介绍 Midjourney 是生成式人工智能的一个很好的例子&#xff0c;它根据文本提示创建图像。它与 Dall-E 和 Stable Diffusion 一起成为最流行的 AI 艺术创作工具之一。与竞争对手不同&#xff0c;Midjourney 是自筹资金且闭源的&#xff0c;因此确切了解其幕后内容尚不…