
Spring Cloud Alibaba微服务组件,是市面上是比较主流的微服务组件,同时有着阿里巴巴官方认证,因此可以称的上是国内最强的微服务框架,没有之一。本文作为Spring Cloud Alibaba微服务系列的实战开篇,主要内容如下:
如果你没有用过Spring Cloud Alibaba,或者没有亲手从零搭建过环境,那么本篇非常适合你入门Spring Cloud Alibaba。
微服务、Spring Cloud、Spring Cloud Netflix 和 Spring Cloud Alibaba,你知道它们之间的关系吗?
作为Spring Cloud Alibaba微服务系列的实战开篇,我觉得有必要对齐一下对于这几个概念的理解,纯讲概念可能比较枯燥,所以咱们不写官方的概念,以下输出仅是我的理解,欢迎共同探讨!
微服务
我们通常讲的微服务,就是指的微服务架构,是一种架构风格,也是一种思想,简单来说:就是按业务边界,将应用更细粒度的拆分为多个小的服务,每个服务独立部署,服务之间直接调用。方便针对不同业务进行不同的水平扩展,避免业务捆绑在一起部署造成服务器资源部署的浪费。它和SOA架构的主要区别是去中心化,比较经典的图例:

Spring Cloud
在微服务中,我们将业务拆分成一个个小的服务,那么业务之间的相互调用,就需要跨服务远程调用,调用链路可能错综复杂,就像蜘蛛网一样,这就引出如何实现服务治理、链路跟踪等等一系列功能,Spring Cloud正是以微服务为核心的整体解决方案的一套标准。当然,微服务不止有Spring Cloud!
Spring Cloud Netflix
Spring Cloud有很多第三方的实现,Spring Cloud Netflix是其中实现的比较早,也比较完整的一套,所以用的项目也比较多,由于比较深入人心,所以在早期人们往往把Netflix叫做Spring Cloud,把Spring Cloud也叫做Netflix。但后面由于Spring Cloud Netflix的组件停更进入维护模式,迫使Spring Cloud后续也在移除Netflix相关组件,所以目前Spring Cloud Alibaba 逐渐代替它成为主流的微服务框架。
Spring Cloud Alibaba
Spring Cloud Alibaba 是阿里巴巴提供的微服务开发一站式解决方案,是阿里巴巴开源中间件与 Spring Cloud 体系的融合,它包含开发分布式应用程序所需的所有组件,使您可以轻松地使用Spring Cloud开发应用程序。比早期的Netflix提供了更丰富、更强大的微服务组件。Spring Cloud Alibaba 和其它的实现如 Netflix, Consul,Zookeeper 等的对比如下图:

微服务是去中心化的,为什么还有注册中心?
如果你还没有真正理解微服务和注册中心,那么这个问题多半会懵🤔
实际上,这个去中心化,是指服务与服务之间的调用是去中心化的调用,也就是点对点的调用。而注册中心正是为了实现去中心化调用起到了的至关重要的作用,用于服务注册和服务发现,这样通过注册中心,各个服务之间就可以相互发现,就为去中心化的调用提供了必备条件。

对于注册中心,常见的有Nacos、Zookeeper、Eureka、Consul等。对于Spring Cloud Alibaba来说,Nacos是首选,因为它是Spring Cloud Alibaba微服务组件中标配的注册中心,也是阿里开源的非常重要的微服务组件,不止可以做注册中心,也可以做配置中心,本文只用它来做注册中心。
对于选择Nacos作为注册中心,我们需要单独安装Nacos-server,可以部署到Windows/Linux/Unix/Mac,有单机模式和集群模式,本文仅演示Window单机模式部署,关于其它系统和集群模式安装,请参考官方部署文档: https://nacos.io/zh-cn/docs/deployment.html
下载地址:https://github.com/alibaba/nacos/tags?after=2.0.4

我下载的是 nacos-server-1.4.2.zip,下载直接解压运行即可,解压后:

进入bin目录,打开cmd,执行以下命令启动:
startup.cmd -m standalone

启动成功,访问Nacos控制台:http://localhost:8848/nacos/index.html
用户名:nacos
密码:nacos

至此,Window单机模式的Nacos注册中心就安装完成并能正常启动了,非常简单易上手,接下来,让咱们来连接Nacos注册中心开始源码实战吧!
使用Spring Cloud Alibaba Nacos 实战,具体实现功能 如下:
能注册到Nacos;使用Ribbon做负载均衡关于Spring Cloud Alibaba版本选型:

| Spring Cloud Alibaba Version | Spring Cloud Version | Spring Boot Version | Nacos Version |
|---|---|---|---|
| 2.2.7.RELEASE | Hoxton.SR12 | 2.3.12.RELEASE | 1.4.2 |

父工程只有一个pom.xml文件,主要目的是引入BOM,定义好版本,服务不必关心版本号,pom.xml的dependencyManagement配置如下:
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<spring-boot.version>2.3.12.RELEASE</spring-boot.version>
<spring-cloud.version>Hoxton.SR12</spring-cloud.version>
<spring-cloud-alibaba.version>2.2.7.RELEASE</spring-cloud-alibaba.version>
<spring.version>5.2.21.RELEASE</spring.version>
<dubbo.version>2.7.18</dubbo.version>
</properties>
<dependencyManagement>
<dependencies>
<!-- bom start -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-framework-bom</artifactId>
<version>${spring.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- duboo-->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-bom</artifactId>
<version>${dubbo.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- spring cloud alibab-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>${spring-cloud-alibaba.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- spring boot-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- spring cloud-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- bom end -->
</dependencies>
</dependencyManagement>
Spring Cloud的每个服务,实际上就是一个简单的Spring Boot程序,下面演示创建SpringBoot程序服务demo-a,并可以注册到Nacos。
pom.xml
在SpringBoot程序基础上,重点额外增加依赖:spring-cloud-starter-alibaba-nacos-discovery用于Nacos服务发现,版本随父工程,所以不用定义。
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Spring Cloud Nacos Service Discovery -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
</dependencies>
application.properties
spring.application.name: 配置服务名
spring.cloud.nacos.discovery.server-addr:配置Nacos-server地址
server.port=8080
spring.application.name=demo-a
spring.cloud.nacos.discovery.server-addr=localhost:8848
如果不想使用 Nacos 作为您的服务注册与发现,可以将
spring.cloud.nacos.discovery.enabled设置为false。
更多关于 spring-cloud-starter-alibaba-nacos-discovery 的 starter 配置项: https://github.com/alibaba/spring-cloud-alibaba/wiki/Nacos-discovery
@EnableDiscoveryClient@SpringBootApplication
@EnableDiscoveryClient
public class DemoARunner {
public static void main(String[] args) {
SpringApplication.run(DemoARunner.class, args);
}
}
控制器类 DemoAController
这里增加一个简单的 /hello API
@RestController
@RequestMapping("/a")
public class DemoAController {
@GetMapping("/hello")
public String hello(@RequestParam("name") String name) {
return "hello:" + name;
}
}
启动demo-a服务
可以看到启动成功,并注册到nacos

通过Nacos 控制台查看注册结果

通过Nacos Open API查看注册结果
API地址:http://localhost:8848/nacos/v1/ns/instance/list?serviceName=demo-a

微服务框架,肯定不能只有一个服务,参考demo-a 同样的步骤,再创建一个demo-b:
pom.xml
与demo-a的依赖相同
application.properties
server.port=8081
spring.application.name=demo-b
spring.cloud.nacos.discovery.server-addr=localhost:8848
启动类 DemoBRunner
@SpringBootApplication
@EnableDiscoveryClient
public class DemoBRunner {
public static void main(String[] args) {
SpringApplication.run(DemoBRunner.class, args);
}
}
控制器类 DemoBController
这里增加一个简单的 /world API
@RestController
@RequestMapping("/b")
public class DemoBController {
@GetMapping("/world")
public String world(@RequestParam("name") String name) {
return "world:" + name;
}
}

先来看看如果没有注册中心,我们传统的调用方式:RestTemplate指定ip调用,a调用b
@Configuration
public class RestTemplateConfig {
@Bean
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
在DemoAController中注入RestTemplate 并实现a调用b:
@RestController
@RequestMapping("/a")
public class DemoAController {
@Autowired
private RestTemplate restTemplate;
@GetMapping("/callB1")
public String callB1(@RequestParam("name") String name) {
String url = "http://localhost:8081/b/world?name=" + name;
return restTemplate.exchange(url, HttpMethod.GET, null, String.class).getBody();
}
}
测试OK,如下图:

再来看看,Nacos通过Ribbon负载均衡的调用方式:
因为spring-cloud-starter-alibaba-nacos-discovery默认集成的Ribbon,Spring Cloud Ribbon是基于Netflix Ribbon 实现的一套客户端的负载均衡工具,所以这里的LoadBalancerClient的实现类是RibbonLoadBalancerClient,由Ribbon实现对RestTemplate的负载均衡。
@RestController
@RequestMapping("/a")
public class DemoAController {
@Autowired
private LoadBalancerClient loadBalancerClient;
@Autowired
private RestTemplate restTemplate;
@GetMapping("/callB2")
public String callB2(@RequestParam("name") String name) {
ServiceInstance serviceInstance = loadBalancerClient.choose("demo-b");
String url = String.format("http://%s:%s/b/world?name=%s", serviceInstance.getHost(), serviceInstance.getPort(), name);
return restTemplate.exchange(url, HttpMethod.GET, null, String.class).getBody();
}
}
测试OK,如下图:

这样就实现了按服务名的负载均衡调用,当我们启动多个demo-b服务的话,也可以对Ribbon配置不同的负载均衡策略,内容较多具体不再详述。
@Configuration
public class RestTemplateConfig {
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
RestTemplate加了@LoadBalanced注解后,会被LoadBalancerInterceptor拦截,内部依然是调用Ribbon的RibbonLoadBalancerClient实现负载均衡。
@RestController
@RequestMapping("/a")
public class DemoAController {
@Autowired
private RestTemplate restTemplate;
@GetMapping("/callB3")
public String callB3(@RequestParam("name") String name) {
String url = String.format("http://%s/b/world?name=%s", "demo-b", name);
return restTemplate.exchange(url, HttpMethod.GET, null, String.class).getBody();
}
}
测试OK,如下图:

至此,今天带来的Spring Cloud Alibaba教程,我们已经实现了一个简易的微服务框架,服务之间能相互发现及调用。
简单串一下本文都讲了什么:本文先从我对微服务的理解,再到注册中心Nacos的理解和安装,最后进行了Spring Cloud Alibaba的源码实战!其实如果你真正消化了,你就会发现原来Spring Cloud Alibaba上手这么容易,可能只是 缺少一次实践!如果你在实践过程中遇到任何问题,非常欢迎联系我!
微服务有多么重要我就不必多说了,我们已看到,在过去的这些年中有许多项目使用了微服务,并且到目前为止结果都还不错。
另外,Spring Cloud Alibaba作为当前国内最强的微服务框架,即使你的工作中可能没用过微服务,但如果出去找工作,大概率面试官会要求你懂微服务,所以,作为Java程序员,微服务已经成为我们必不可少的一个技能,也是用人单位考核的重要标准,所以必须吃透!
其实,在实际的项目中,微服务之间调用,使用RestTemplate 的方式已经用的不多,因为还有更简单、更方便、更强大 的调用方式,这也是我计划将在下文分享的内容,如果感觉不错,欢迎订阅本专栏,后面还有更多的【Spring Cloud Alibaba】实战知识陆续放出。
关注我 天罡gg 分享更多干货: https://blog.csdn.net/scm_2008
大家的「关注❤️ + 点赞👍 + 收藏⭐」就是我创作的最大动力!谢谢大家的支持,我们下文见!
?博客主页:https://xiaoy.blog.csdn.net?本文由呆呆敲代码的小Y原创,首发于CSDN??学习专栏推荐:Unity系统学习专栏?游戏制作专栏推荐:游戏制作?Unity实战100例专栏推荐:Unity实战100例教程?欢迎点赞?收藏⭐留言?如有错误敬请指正!?未来很长,值得我们全力奔赴更美好的生活✨------------------❤️分割线❤️-------------------------
这篇文章是继上一篇文章“Observability:从零开始创建Java微服务并监控它(一)”的续篇。在上一篇文章中,我们讲述了如何创建一个Javaweb应用,并使用Filebeat来收集应用所生成的日志。在今天的文章中,我来详述如何收集应用的指标,使用APM来监控应用并监督web服务的在线情况。源码可以在地址 https://github.com/liu-xiao-guo/java_observability 进行下载。摄入指标指标被视为可以随时更改的时间点值。当前请求的数量可以改变任何毫秒。你可能有1000个请求的峰值,然后一切都回到一个请求。这也意味着这些指标可能不准确,你还想提取最小/
@作者:SYFStrive @博客首页:HomePage📜:微信小程序📌:个人社区(欢迎大佬们加入)👉:社区链接🔗📌:觉得文章不错可以点点关注👉:专栏连接🔗💃:感谢支持,学累了可以先看小段由小胖给大家带来的街舞👉微信小程序(🔥)目录自定义组件-behaviors 1、什么是behaviors 2、behaviors的工作方式 3、创建behavior 4、导入并使用behavior 5、behavior中所有可用的节点 6、同名字段的覆盖和组合规则总结最后自定义组件-behaviors 1、什么是behaviorsbehaviors是小程序中,用于实现
作为新的阿里云用户,您可以50免费试用多种优惠,价值高达1,700美元(或8,500美元)。这将让您了解和体验阿里云平台上提供的一系列产品和服务。如果您以个人身份注册免费试用,您将获得价值1,700美元的优惠。但是,如果您是注册公司,您可以选择企业免费试用,提交基本信息通过企业实名注册验证,即可开始价值$8,500的免费试用!本教程介绍了如何设置您的帐户并使用您的免费试用版。关于免费试用在我们开始此试用之前,您还必须遵守以下条款和条件才能访问您的免费试用:只有在一年内创建的账户才有资格获得阿里云免费试用。通过此免费试用优惠,用户可以免费试用免费试用活动页面上列出的每种产品一次。如果您有多个帐
我在我的项目中有一个用户和一个管理员角色。我使用Devise创建了身份验证。在我的管理员角色中,我没有任何确认。在我的用户模型中,我有以下内容:devise:database_authenticatable,:confirmable,:recoverable,:rememberable,:trackable,:validatable,:timeoutable,:registerable#Setupaccessible(orprotected)attributesforyourmodelattr_accessible:email,:username,:prename,:surname,:
完成这个有困难。我正在使用seed.rb+factory_girl来使用rakedb:seed填充数据库。(我知道固定装置存在,但我想以这种方式完成,这只是一个示例,数据库将填充复杂的关联对象。)我的种子.rb:require'factory_girl_rails'["QM","CDC","SI","QS"].eachdo|n|FactoryGirl.create(:grau,nome:n)end还有我的/factories/graus.rbFactoryGirl.definedofactory:graudonomeendend但是当我运行时:rakedb:seed我得到:rakeab
目录H2数据库入门以及实际开发时的使用1.H2数据库的初识1.1H2数据库介绍1.2为什么要使用嵌入式数据库?1.3嵌入式数据库对比1.3.1性能对比1.4技术选型思考2.H2数据库实战2.1H2数据库下载搭建以及部署2.1.1H2数据库的下载2.1.2数据库启动2.1.2.1windows系统可以在bin目录下执行h2.bat2.1.2.2同理可以通过cmd直接使用命令进行启动:2.1.2.3启动后控制台页面:2.1.3spring整合H2数据库2.1.3.1引入依赖文件2.1.4数据库通过file模式实际保存数据的位置2.2H2数据库操作2.2.1Mysql兼容模式2.2.2Mysql模式
我正在使用carrierwave上传视频然后有一个名为thumb的版本,带有自定义处理器,可以获取视频并使用streamio-ffmpeg创建屏幕截图。视频和文件都已正确上传,但在调用uploader.url(:thumb)时我得到:ArgumentError:Versionthumbdoesn'texist!VideoUploader.rbrequire'carrierwave/processing/mime_types'require'streamio-ffmpeg'classVideoUploader5)File.renamethumb_path,current_pathendd
我正在使用Deviseauthtokengem用于验证我的Rails应用程序的某些部分。但是,当我尝试使用注册路径创建新用户时,出现以下错误{"errors":["Authorizedusersonly."]}。这是我用于测试的rspec代码,it'createsauserusingemail/passwordcombo'dopostapi_user_registration_path,{email:'xxx',password:'yyy',password_confirmation:'yyy'}putslast_response.bodyexpect(last_response.bo
这道题开始于here.但随着我对雷神的了解越来越多,情况发生了很大变化。我正在尝试创建一个带参数的Thor::Group子命令。奇怪的是,如果没有参数,它就可以工作。我可以使用Thor::Group作为子命令吗?这在我输入时有效:foocounterfoo/bin/foomoduleFooclassCLI但是当我输入时这不起作用:foocounter5moduleFooclassCLI','Countupfromtheinput.')endclassCounter:numeric,:desc=>"Thenumbertostartcounting"desc"Prints2numbersb