青年IT男

个人从事金融行业,就职过易极付、思建科技等重庆一流技术团队,目前就职于某网约车平台负责整个支付系统建设。自身对金融行业有强烈的爱好。同时也实践大数据、数据存储、自动化集成和部署、分布式微服务、人工智能等领域。

深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

转载地址:http://blog.51cto.com/2662087/2177877
Nacos是什么?

引用官方的介绍,他主要提供以下几个功能点:

动态配置服务
服务发现及管理
动态DNS服务
动态配置服务

就是通过一个系统,管理系统中的配置项,在配置项需要更新的时候,可以通过管理系统去操作更新,更新完了之后,会主动推送到订阅了这个配置的客户端
具体的使用场景,例如,在系统中,会有数据库的链接串,账号密码等配置信息,常规的做法是写在配置文件里面,如果需要修改更新,需要重新打包编译,如果你是分布式集群,那成本太大了,通常我们都会将它抽取出来,存放到db,或者一个管理系统,Nacos,就是这个管理系统,Nacos还提供主动通知的能力,DB是没有的,在自己的系统代码里面,可以监听某个配置,如果在管理系统上修改了配置项,客户端的监听函数,会立刻执行,在里面,你可以拿到最新的配置,执行自己的业务逻辑

服务发现及管理

这个主要是针对分布式的微服务集群系统,某A集群提供服务出去,其他应用集群,需要消费到A集群的服务,需要一个系统去管理A集群的ip列表,其他应用集群,去这个系统才能获取到A集群的ip列表,进行调用,同时该系统需要能够自动将A集群中无法工作的ip进行去除掉,这样才能保证调用方调用成功,Nacos就是提供这种能力的一个系统

动态DNS服务

这个理解起来也简单,我们平常在代码里面 ,访问一个http的api,通常是带一个域名的,请求的时候,一般会先去DNS域名服务器上面寻找该域名对应的ip,再发起http请求,Nacos可以充当这个DNS域名服务器的角色的,优点是什么呢?Nacos提供了比DNS域名服务器更方便的管理能力,新增一个域名,只需要在Nacos的控制台上面配置一下,同时它还提供了包括权重,健康检查,属性,路由等DNS服务器不具备的能力,比DNS的产品功能,稳定性,灵活性,超出太多了
Nacos除了能够解决上面提到的一些场景,大家可以自由发挥,反正它的能力在那里,至于怎么用,就靠你们聪明的脑袋了。

下面,我们尝试从Nacos的官方源码拉一份下来,进行一个服务的发布,订阅的简单流程,让大家更有体感去感受下Nacos的功能。

下载源码

Nacos的代码是托管在github上,https://github.com/alibaba/nacos
开始之前先start关注一下,加上watch,后续Nacos的邮件列表也会通知到你,可以关注到Nacos的最新实时消息.

深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

我们首先直接下载Nacos的源码到本地,下载地址如下图:
深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

然后,要从github上把代码拉下来,命令如下:

git clone git@github.com:alibaba/nacos.git
执行完之后,出现下图进度
深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

编译启动
下载完后,在本地会有一个nacos的文件夹,进去后,执行编译打包的命令:

mvn -Prelease-nacos clean install -U -Dmaven.test.skip=true
执行完之后,在nacos/distribution/target文件夹里面,会生成如下几个工程文件:
深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld
忽略archive-tmp,将nacos-server-0.2.0.zip或者nacos-server-0.2.0.tar.gz直接copy到你的服务器上面,
然后解压开来,得到一个叫nacos的文件夹,里面的结构如下:
深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

进入bin文件,里面有启动,关闭nacos server的脚本,我们执行一下启动脚本,注意,nacos server的启动,有2种方式,一种是集群模式,一种是单机模式,由于集群模式还需要一些其他的配置才能运行,今天我们就跑单机模式,需要加一个特殊参数,命令如下:

sh startup.sh -m standalone
命令执行完之后,出现提示:

nacos is starting,you can check the /home/caogu.wyp/test/nacos/logs/start.log
我们可以去/nacos/logs/start.log看下启动日志,是否有报错,如果有报错,自己分析一下,找不到原因,联系Nacos管理员 @超哥,他会很热心的帮你解决问题滴。
启动成功的日志如下:
深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

同时, 我们也可以自己check下server的端口是否监听成功,执行

netstat -ano|grep 8080
深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

发布一个服务

我们现在来用Java客户端,发布和订阅一个服务,客户端,我们有2种方式运行,一个是在自己工程里面,通过maven坐标下载进来,另外一种,直接从下载的nacos源码里面,坐标如下:

com.alibaba.nacos
nacos-client
0.1.0
由于我们有代码,我就直接在工程里面进行操作了,工程结构如下,直接在test模块里面,新建一个helloworld的包:
深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld
Pub类里面,是发布一条数据,代码如下:

public class Pub {

public static void main(String[] args) throws NacosException, InterruptedException {
    //发布的服务名
    String serviceName = "helloworld.services";
    //构造一个nacos实例,入参是nacos server的ip和服务端口
    NamingService naming = NamingFactory.createNamingService("100.81.0.34:8080");
    //发布一个服务,该服务对外提供的ip为127.0.0.1,端口为8888
    naming.registerInstance(serviceName, "127.0.0.1", 8888);
    Thread.sleep(Integer.MAX_VALUE);
}

}
启动之后,服务已经发布上去了

订阅一个服务

下面是Sub的代码:

public class Sub {

public static void main(String[] args) throws NacosException, InterruptedException {
    //订阅的服务名
    String serviceName = "helloworld.services";
    //创建一个nacos实例
    NamingService naming = NamingFactory.createNamingService("100.81.0.34:8080");
    //订阅一个服务
    naming.subscribe(serviceName, event -> {
        if (event instanceof NamingEvent) {

            System.out.println("订阅到数据");
            System.out.println(((NamingEvent) event).getInstances());
        }
    });
    System.out.println("订阅完成,准备等数来");
    Thread.sleep(Integer.MAX_VALUE);
}

}
我们尝试启动,会订阅到刚才发布的数据:

深入浅出高性能服务发现、配置框架Nacos系列 1: HelloWorld

总结

上面流程,就是一个helloworld的服务发布和订阅,够简单吧,在实际的生产环境中,一个服务下面往往挂有好几个ip提供服务,在订阅端,拿到服务下面的所有地址列表后,通过负载均衡策略,例如随机策略,选择到一个ip进行调用,这样就完成了一次远程调用。

0
1028826685@qq.com