这时候启动会报java.lang.NoSuchMethodError: org.springframework.boot.builder.SpringApplicationBuilder.<init>([Ljava/lang/Object)V的错误
这是由于spring boot版本兼容性导致的,这是我们可以降低springboot的版本来解决
在降低springboot版本之后我们会发现,高版本的sprinboot创建的测试类会报错
我们可以做如下修改
1、删除高版本默认导入的org.junit.jupiter.api.Test类,重新导入org.junit.Test类
2、在类上添加注释@RunWith(SpringRunner.class)
3、将测试类和测试方法都修改为public
本章我们编写一个starter,目标如下:
1、通过 @EnableSms 注解启用Starter
2、完成使用示例
pom.xml
编写业务代码
将SmsUtil类交给Spring IOC管理,并提供给第三方使用
创建@EnableSms注解,当开发者添加了此注解,无论MyConfiguration类是否被spring扫描到都会进行加载
1、创建springboot项目
2、引入starter jar包
3、在启动类添加@EnableSms注解,启用Starter
4、配置参数
5、调用
https://blog.csdn.net/GuiSu97/article/details/107909266
1、Eureka注册中心
现在公司项目大多采用前后端分离架构,服务层被拆分成了很多的微服务,为方便管理Spring Cloud给我们提供了服务注册中心来管理微服务。
1.1、Eureka简介
Spring Cloud Eureka 是对Netflix公司的Eureka的二次封装,它实现了服务治理的功能,Spring Cloud Eureka提
供服务端与客户端,服务端即是Eureka服务注册中心,客户端完成微服务向Eureka服务的注册与发现。服务端和
客户端均采用Java语言编写。下图显示了Eureka Server与Eureka Client的关系:
Eureka Server是服务端,负责管理各各微服务结点的信息和状态。
在微服务上部署Eureka Client程序,远程访问Eureka Server将自己注册在Eureka Server。
微服务需要调用另一个微服务时从Eureka Server中获取服务调用地址,进行远程调用。
1.2、Eureka Server搭建
1.2.1、单机环境搭建
1、父工程引入Maven依赖:
org.springframework.cloud
spring‐cloud‐dependencies
Finchley.SR1
pom
import
2、在Eureka Server工程添加:
org.springframework.cloud
spring‐cloud‐starter‐netflix‐eureka‐server
3、在SpringBoot启动类添加@EnableEurekaServer注解,标识这是一个Eureka服务:
@EnableEurekaServer//标识这是一个Eureka服务
@SpringBootApplication
publicclassGovernCenterApplication{
publicstaticvoidmain(String[] args){
SpringApplication.run(GovernCenterApplication.class, args)
}
}
4、在application.yml中配置Rureka:
server:
port:50101#服务端口
spring:
application:
name:xc‐govern‐center#指定服务名
eureka:
client:
registerWithEureka:false#服务注册,是否将自己注册到Eureka服务中
fetchRegistry:false#服务发现,是否从Eureka中获取注册信息
serviceUrl:#Eureka客户端与Eureka服务端的交互地址,高可用状态配置对方的地址,单机状态配置自己(如果不配置则默认本机8761端口)
defaultZone:http://localhost:50101/eureka/
server:
enable‐self‐preservation:false#是否开启自我保护模式,开发模式建议关闭
eviction‐interval‐timer‐in‐ms:60000#服务注册表清理间隔(单位毫秒,默认是60*1000)
5、启动Eureka Server,浏览50101端口:
上图红色提示信息:
THE SELF PRESERVATION MODE IS TURNED OFF.THIS MAY NOT PROTECT INSTANCE EXPIRY IN CASE OF
NETWORK/OTHER PROBLEMS.
自我保护模式被关闭。在网络或其他问题的情况下可能不会保护实例失效。
Eureka Server有一种自我保护模式,当微服务不再向Eureka Server上报状态,Eureka Server会从服务列表将此
服务删除,如果出现网络异常情况(微服务正常),此时Eureka server进入自保护模式,不再将微服务从服务列
表删除。
至此,Eureka服务端已经搭建完成,下面进行服务注册,将微服务注册到Eureka服务端进行管理。
1.3、服务注册
1、在需要注册的微服务中,添加依赖:
org.springframework.cloud
spring‐cloud‐starter‐netflix‐eureka‐client
2、配置application.yml:
eureka:
client:
registerWithEureka:true#服务注册开关
fetchRegistry:true#服务发现开关
serviceUrl:#Eureka客户端与Eureka服务端进行交互的地址,多个中间用逗号分隔
defaultZone:${EUREKA_SERVER:http://localhost:50101/eureka/}
instance:
prefer‐ip‐address:true#将自己的ip地址注册到Eureka服务中
ip‐address:${IP_ADDRESS:127.0.0.1}
instance‐id:${spring.application.name}:${server.port}#指定实例id
3、启动类上加注解@EnableDiscoveryClient ,表示它是一个Eureka的客户端
4、刷新Eureka Server查看注册情况
同理可将需要注册的服务注册到Eureka Server。
2、Feign远程调用
服务层被拆分成了很多的微服务,服务与服务之间难免发生交互调用,这时候就需要用到远程调用,接下来带大家入门及使用
2.1Ribbon
1、简介
Ribbon是Netflix公司开源的一个负载均衡的项目(https://github.com/Netflix/ribbon),它是一个基于HTTP、TCP的客户端负载均衡器,通过负载均衡来实现系统的高可用、集群扩容等功能。
如下图是服务端负载均衡架构图:
用户请求先到达负载均衡器(也相当于一个服务),负载均衡器根据负载均衡算法将请求转发到微服务。负载均衡算法有:轮训、随机、加权轮训、加权随机、地址哈希等方法,负载均衡器维护一份服务列表,根据负载均衡算法将请求转发到相应的微服务上,所以负载均衡可以为微服务集群分担请求,降低系统的压力。
客户端负载均衡架构图:
客户端负载均衡与服务端负载均衡的区别在于客户端要维护一份服务列表,Ribbon从Eureka Server获取服务列表,Ribbon根据负载均衡算法直接请求到具体的微服务,中间省去了负载均衡服务。
2、测试Ribbon
Spring Cloud引入Ribbon配合 restTemplate 实现客户端负载均衡。Java中远程调用的技术有很多,如:webservice、socket、rmi、Apache HttpClient、OkHttp等,互联网项目使用基于http的客户端较多,下面介绍使用的是OkHttp。
首先加入Maven依赖:
<!--如果依赖了spring-cloud-starter-eureka,会自动添加spring-cloud-starter-ribbon依赖-->
org.springframework.cloud
spring‐cloud‐starter‐ribbon
com.squareup.okhttp3
okhttp
在application.yml中配置Ribbon参数:
ribbon:
MaxAutoRetries:2#最大重试次数,当Eureka中可以找到服务,但是服务连不上时将会重试
MaxAutoRetriesNextServer:3#切换实例的重试次数
OkToRetryOnAllOperations:false#对所有 *** 作请求都进行重试,如果是get则可以,如果是post,put等 *** 作没有实现幂等的情况下是很危险的,所以设置为false
ConnectTimeout:5000#请求连接的超时时间
ReadTimeout:6000#请求处理的超时时间
负载均衡测试:
启动两个cms服务,端口要不一致
定义RestTemplate,使用@LoadBalanced注解:
@Bean
@LoadBalanced
publicRestTemplaterestTemplate(){
returnnewRestTemplate(newOkHttp3ClientHttpRequestFactory())
}
远程调用cms的查询页面接口:
//负载均衡调用
@Test
publicvoidtestRibbon(){
//服务id
String serviceId ="XC‐SERVICE‐MANAGE‐CMS"
for(inti=0i<10i++){
//通过服务id调用
ResponseEntity forEntity = restTemplate.getForEntity("http://"+ serviceId
+"/cms/page/get/5a754adf6abb500ad05688d9", CmsPage.class)
CmsPage cmsPage = forEntity.getBody()
System.out.println(cmsPage)
}
}
添加@LoadBalanced注解后,restTemplate会走LoadBalancerInterceptor拦截器,此拦截器中会通过RibbonLoadBalancerClient查询服务地址,打断点观察每次调用的服务地址和端口,可以看到两个cms服务会轮流被调用。
2.2Feign
简介:
Feign是Netflix公司开源的轻量级rest客户端,使用Feign可以非常方便的实现Http 客户端。Spring Cloud引入Feign并且集成了Ribbon实现客户端负载均衡调用。
使用:
添加Maven依赖:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐starter‐openfeign</artifactId>
</dependency>
<dependency>
<groupId>com.netflix.feign</groupId>
<artifactId>feign‐okhttp</artifactId>
</dependency>
定义FeignClient接口:
@FeignClient(value = "XC_SERVICE_MANAGE_CMS")
publicinterfaceCmsPageClient{
//微服务接口路径
@GetMapping("/cms/page/get/{id}")
publicCmsPagefindById(@PathVariable("id")String id)
}
启动类添加@EnableFeignClients注解
测试:
@RunWith(SpringRunner.class)
@SpringBootTest
publicclassFeignTest{
@Autowired
CmsPageClient cmsPageClient//接口代理对象,由Feign生成代理对象
@Test
publicvoidtestFeign(){
//发起远程调用
CmsPage cmsPage = cmsPageClient.findById("5a754adf6abb500ad05688d9")
System.out.println(cmsPage)
}
}
Feign工作原理:
1、 启动类添加@EnableFeignClients注解,Spring会扫描标记了@FeignClient注解的接口,并生成此接口的代理对象
2、 @FeignClient(value = XcServiceList.XC_SERVICE_MANAGE_CMS)即指定了cms的服务名称,Feign会从注册中心获取cms服务列表,并通过负载均衡算法进行服务调用。
3、在接口方法 中使用注解@GetMapping("/cms/page/get/{id}"),指定调用的url,Feign将根据url进行远程调用。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)