主要依赖 spring-cloud 的 版本控制
<properties>
<!-- springCloud 版本 -->
<scd.version>Dalston.SR4</scd.version>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${scd.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<!-- eureka 注册中心 依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka-server</artifactId>
</dependency>
# 端口
server:
port: 8096
# 服务名
spring:
application:
name: edocmall-eureka
# eureka 服务注册与发现 配置
eureka:
client:
#Eureka 监控页面
service-url:
defaultZone: http://127.0.0.1:${server.port}/eureka
register-with-eureka: false # 是否注册自己的服务到注册中心,默认为true
on-demand-update-status-change: false # 是否主动拉取其他注册的服务信息,默认也是true
@EnableEurekaServer //eureka服务端启动,可以就接受别人来注册
启动项目,访问 http://localhost:8096
<!-- eureka 客户端依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
# 端口
server:
port: 8097
# 服务名配置,eureka注册信息,服务调用基于服务名,必须增加
spring:
application:
name: edocmall-server
#数据源配置
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/kh96_springboot_edocbd?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
username: root
password: root
# mybatis-plus 配置
mybatis-plus:
configuration:
map-underscore-to-camel-case: true
# eureka 注册中心的配置
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:8096/eureka # 注册中心的地址
# 关闭自我保护机制,保证不可用的服务及时剔除
server:
enable-self-preservation: false
@MapperScan("com.kgc.scd.mapper")
@EnableEurekaClient // 开启 eureka 服务注册,将此服务注册到 eureka中
服务提供端的请求最好先单独测试一下,成功后再进行远程调用;
@SpringBootApplication
public class Edocmall96WebApplication {
public static void main(String[] args) {
SpringApplication.run(Edocmall96WebApplication.class, args);
}
//往容器中添加 restTemplate
@Bean
public RestTemplate restTemplate(){
return new RestTemplate();
}
}
@RestController
public class WebEntryController {
@Autowired
private RestTemplate restTemplate;
// 根据文档编号,获取文档详情
@GetMapping("/entryById")
public RequestResult<EdocEntryVO> entryDetail(Integer id){
log.info("------ 根据文档编号:{},获取文档详情 ------",id);
//模拟发送http请求请求server端,获取文档详情
//弊端:消费端,必须在程序内,记录提供者的ip地址,如果地址出现变更,还需要计时更新,如果服务者有多个及其,无法实现负载均衡
EdocEntryVO edocEntryVO = restTemplate.getForObject("http://127.0.0.1:8097/entry?id="+id,EdocEntryVO.class);
return ResultBuildUtil.success(edocEntryVO);
}
}
<!-- eureka 客户端依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<!-- feign远程调用依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-feign</artifactId>
<version>1.3.5.RELEASE</version>
</dependency>
# 端口
server:
port: 8098
spring:
application:
name: edocmall-web
# 服务名
# eureka 注册中心的配置
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:8096/eureka
# 关闭自我保护机制,保证不可用的服务及时剔除
server:
enable-self-preservation: false
# 开启客户端服务降级,默认是关闭的,需要打开
feign:
hystrix:
enabled: true
//指定服务名
@FeignClient(value = "edocmall-server")
public interface WebEntryService {
//基于feign 远程调用edoc-server服务端提供的查询文档详情接口
@GetMapping("/entry") //必须跟远程请求一直
EdocEntryVO invokeEntryServiceUserFeign(@RequestParam("id") Integer id); //必须写 @RequestParam("id")
// 注意 一点更要写 @RequestParam("id") 里面的参数必须写
}
@RestController
public class WebEntryController {
@Autowired
private WebEntryService webEntryService;
// 根据文档编号,获取文档详情
@GetMapping("/entryById")
public RequestResult<EdocEntryVO> entryDetail(Integer id){
log.info("------ 根据文档编号:{},获取文档详情 ------",id);
//基于feign 远程调用服务端接口,获取文档详情
EdocEntryVO edocEntryVO = webEntryService.invokeEntryServiceUserFeign(id);
return ResultBuildUtil.success(edocEntryVO);
}
}
@EnableEurekaClient // 开启 eureka 服务注册,将此服务注册到 eureka中
@EnableFeignClients //开启 feign 远程调用服务
eureka 注册中心:
feign远程调用:
由于feign中有hystrix的依赖,所以不用单独添加;
@FeignClient(value = "edocmall-server",fallback = WebEntryServiceImpl.class) //fallback 指定调用失败后 降级调用的数据
public interface WebEntryService {
......
}
@Service
public class WebEntryServiceImpl implements WebEntryService {
@Override
public EdocEntryVO invokeEntryServiceUserFeign(Integer id) {
//此方法,就是regn远程调用,触发服务剪辑的默认实现,正常请求不会调用
//只用远程 feign调用失败,才会调用
EdocEntryVO edocEntryVO = new EdocEntryVO();
edocEntryVO.setId(999);
edocEntryVO.setCid(0);
edocEntryVO.setTitle("触发熔断服务降级");
edocEntryVO.setSummary("当feign远程调用接口失败,默的默认实现");
edocEntryVO.setUploadUser("feign-hystrix");
edocEntryVO.setCreateDate(new Date());
return edocEntryVO;
}
<!--导入Hystrix依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
@Slf4j
@RestController
public class EntryController {
@Autowired
private EntryService entryService;
//根据 id 查询文档详情
@GetMapping("/entry")
@HystrixCommand(fallbackMethod = "fallbackStoryDetail") //指定 服务熔断后的备选方法
public EdocEntryVO entryDetail(@RequestParam Integer id){
log.info("------ 根据文档编号:{},获取文档详情 ------",id);
EdocEntryVO edocEntry = entryService.getEdocEntryById(id);
if (edocEntry == null){
//抛出异常,触发 熔断 备选方法
throw new RuntimeException("id为:"+id+"的用户不存在,触发服务熔断");
}
return edocEntry;
}
// 根据 id 查询文档详情 方法 服务熔断后 的备选方案
public EdocEntryVO fallbackStoryDetail(@RequestParam Integer id){
//此方法,只用服务熔断时,才会被调用
EdocEntryVO edocEntryVO = new EdocEntryVO();
edocEntryVO.setId(999);
edocEntryVO.setCid(0);
edocEntryVO.setTitle("根据 id 查询文档详情 方法 服务熔断后 的备选方案");
edocEntryVO.setSummary("当根据id 查询不到具体用户信息时,就会触发");
edocEntryVO.setUploadUser("hystrix");
edocEntryVO.setCreateDate(new Date());
return edocEntryVO;
}
}
@EnableHystrix //开启熔断服务 旧的开启服务熔断注解: @EnableCircuitBreaker
直接返回错误;
触发服务降级;
触发服务熔断;
<!-- 暴露info端点给外部访问, 需要添加暴露端点的启动依赖: -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
# 服务信息 eureka 中服务配置的基本信息
info:
app.name: web 消费端
company.name: com.kgc.kh96 # 公司域名
# 其他信息可以自行查询
点击服务路径: