Spring cloud天气预报系统

小咪咪 2022-02-05 03:09 269阅读 0赞

Spring cloud 天气项目系统,是一个简单的小型项目,从第三方的接口获取天气,并进行储存,能对外提供天气的查询服务的一个项目.

首先我们对其进行一个单体项目的实现,包括以下的功能:

1.  根据现有的xml文档,从中获取所有的城市名字
2.  从第三方根据城市的名字或者城市id获取具体的天气信息
3.  根据名字获取所有的城市天气,并保存在redis中
4.  设置定时任务,每30分钟去更新一遍所有的城市天气信息
5.  对外提供接口,进行当前天气和天气预报的查询.

就可以对项目进行打包,实现了.对外提供服务了.

下面就是对这个应用做功能的拆分,进行分布式系统的改造.

如何设计微服务系统:

1.  服务拆分
2.  服务注册
3.  服务发现
4.  服务消费
5.  统一入口
6.  配置管理
7.  熔断机制
8.  自动扩展

主要难点就是系统功能的拆分,综合上面的功能,对系统进行如下的拆分:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70][]

这就是系统拆分之后的系统数据流量图

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70 1][]

之后的就简单了,只是需要对各个模块进行代码的填充就好了.

1.  天气数据采集的微服务实现
2.  天气数据api微服务的实现
3.  天气预报微服务的实现
4.  城市api微服务的实现

首先完成了各个功能模块的简单实现

下一步就是使用spring cloud进行各个微服务之间的整合了.

首先是服务的发现,现在市面上能够用于微服务的服务发现有很多,哪怕你使用zookeeper都可以,当然了,我们有更多的选择,像netflix开源的一套微服务的东西,还是很好用的,现在阿里也在开源一套微服务的东西,他们的服务发现用的是Nacos,前几天刚刚发布了1.0的GA版本,大家也可以试试的.

这里我们就使用netflix的eureka作为服务的发现了.

具体就是建立一个springboot项目,引入springcloud 的依赖管理,再添加netflix的eureka –server的依赖,在springboot的启动类上添加一个启用注册中心的注解,然后添加对应的配置启动即可.

再把其他的微服务作为客户端都注册到当前的服务端中,进行服务的发现管理.

第二部就是涉及到服务之间的调用了,之前我们对第三方的天气数据使用htppclient进行访问,获取响应.

其实常见微服务的消费者 有ribbon  还有 feign 两个都可以进行对其他的微服务进行访问,同时实现负载均衡以及高可用了.具体用法都是一样的,引入pom的依赖,添加开启的注解,再添加对应的配置,最后使用,具体使用很简单,这里不详细展开了.

下一个就是微服务的网关的整合.

为什么要整合网关呢?集合多个API, 统一API入口.

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70 2][]

网关的好处:

避免将内部信息泄露给外部

为微服务添加额外的安全层

支持混合通信协议

降低构建为服务的复杂性

微服务模拟与虚拟化

坏处:

在架构上需要额外考虑更多编排与管理

路由逻辑配置要进行统一的管理

可能引发单点故障

API的常见实现方式: Zuul  Kong

当然了,这次我们使用zuul进行整合.

具体使用略.其实很简单,就是配置不同访问路径下对应的不同转发.

当然了这个微服务必然也是注册是eureka-server下面的.

其实呢,到这里就差不多可以结束了.已经实现了微服务化的改造,只是因为多环境的原因,我们需要进行项目的配置的管理.

微服务中的配置管理,可以使用spring colud config 或者 携程开源的一个阿波罗(Apollo),

(ps:说道携程了,就有一句,携程在手,天下我有(袁术的 玉玺在手,天下我有),哈哈哈).

本来开发环境/线上的开发环境/测试环境/生产环境  等等不同的配置的管理,避免混乱的发生(因为有时候因为版本的不同会修改配置文件).

很简单啊,就是对git仓库中的文件的获取,然后进行内容的填充.

最后一个就是涉及到微服务的熔断和降级了.

熔断是因为一个微服务的宕机/缓慢,造成了对其调用者一个没有回应或者响应慢,造成了整个系统的缓慢,对其采取的一种措施.就是调用一个默认的方法,进行返回.不提供这里的功能了,但是保证整个系统其他部分的可用性.

降级是因为整体系统的原因,干预系统功能,使一些功能不可用,来保证其他重要功能的可用性.

[https://blog.csdn.net/hongwei15732623364/article/details/82078739][https_blog.csdn.net_hongwei15732623364_article_details_82078739]

整个博客的解释是蛮好,就直接拿过来了.

这里我们的服务熔断采取的是netflix 的hystrix组件.使用起来非常的方便,可以自己实现接口,也可以直接添加方法就够了.

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70]: /images/20220205/d2d950d9cfde4f15ae6243ac55b22d14.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70 1]: /images/20220205/bc826c2d629a4feb9fd14e1f75a952f4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTAzOTg3NzE_size_16_color_FFFFFF_t_70 2]: /images/20220205/d6770dbb80af4c92b1c84076c1d867cc.png
[https_blog.csdn.net_hongwei15732623364_article_details_82078739]: https://blog.csdn.net/hongwei15732623364/article/details/82078739