当前位置： 首页 > wzjs >正文

上线吧做的网站可以备案公司主页网站设计

wzjs 2025/8/3 11:24:05
上线吧做的网站可以备案,公司主页网站设计,上海网站制作工作室,网页首页代码注册中心Eureka Eureka-Server：就是服务注册中心（可以是一个集群），对外暴露自己的地址。 提供者：启动后向Eureka注册自己信息（地址，服务名称等），并且定期进行服务续约 …

注册中心Eureka

  • Eureka-Server：就是服务注册中心（可以是一个集群），对外暴露自己的地址。

  • 提供者：启动后向Eureka注册自己信息（地址，服务名称等），并且定期进行服务续约

  • 消费者：服务调用方，在使用的时候去拉取一次，之后会定期去Eureka拉取服务列表，然后使用负载均衡算法选出一个服务进行调用。

  • 心跳(续约)：提供者和消费者定期通过http方式向Eureka刷新获取（默认30秒）

 如果消费者之前已经调用过注册中心获取过提供者的地址信息，那么注册中心宕机后，在提供者地址不变的前提下，不影响服务直接调用

引入SpringCloud为eureka提供的starter依赖：

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

 编写一个启动类

给eureka-server服务编写一个启动类，一定要添加一个@EnableEurekaServer注解，开启eureka的注册中心功能：

@SpringBootApplication
@EnableEurekaServer  //开启eureka的注册中心功能
public class EurekaApplication {public static void main(String[] args) {SpringApplication.run(EurekaApplication.class, args);}
}

编写一个application.yml文件，内容如下：

server:port: 10086
spring:application:name: eureka-server
eureka:client:service-url: defaultZone: http://127.0.0.1:10086/eurekaregister-with-eureka: false # 自己不注册到eureka中fetch-registry: false #自己不从eureka中拉取别的服务

启动微服务，然后在浏览器访问：http://127.0.0.1:10086

 将微服务注册到注册中心->引入依赖->编写配置文件，名字要指定

spring:application:name: userservice
eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka

Ribbon负载均衡

@SpringBootApplication
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}//注册RestTemplate,第三方的类,交给IOC容器管理@Bean@LoadBalanced//自动负载均衡public RestTemplate restTemplate() {return new RestTemplate();}
}

@LoadBalanced 

在远程调用的RestTemplate，上添加了@LoadBalanced注解，即可实现负载均衡功能

原理：SpringCloud底层其实是利用了一个名为Ribbon的组件，来实现负载均衡功能的。

 SpringCloudRibbon的底层采用了一个拦截器，拦截了RestTemplate发出的请求，对地址做了修改。用一幅图来总结一下：

基本流程如下：

  • 拦截我们的RestTemplate请求http://userservice/user/1

  • RibbonLoadBalancerClient会从请求url中获取服务名称，也就是user-service

  • DynamicServerListLoadBalancer根据user-service到eureka拉取服务列表

  • eureka返回列表，localhost:8081、localhost:8082

  • IRule利用内置负载均衡规则，从列表中选择一个，例如localhost:8081

  • RibbonLoadBalancerClient修改请求地址，用localhost:8081替代userservice，得到http://localhost:8081/user/1，发起真实请求

Hystrix 熔断器

雪崩问题

微服务中，服务间调用关系错综复杂，一个请求，可能需要调用多个微服务接口才能实现，会形成非常复杂的调用链路：Hystix解决雪崩问题的手段主要是服务降级和线程隔离；

服务降级的演示

第一步：导依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId></dependency>

第二步：在引导类上开启Hystrix  


@EnableCircuitBreaker//开启断路器
@SpringBootApplication
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}//注册RestTemplate,第三方的类,交给IOC容器管理@Bean@LoadBalanced//自动负载均衡public RestTemplate restTemplate() {return new RestTemplate();}}

第三步：开发一个方法作为降级的处理方式要求：方法的参数和返回结果类型要和原方法findById应该一致

public String queryOrderByIdFallback(Long orderId) {return "服务器太忙，请稍后重试........";
}

 第四步：修改原有的方法，在方法上添加注解

 全局降级

 上面的写法中每个方法都需要一个降级方法，很麻烦，我们可以使用一个全局的降级方案

@Service
@DefaultProperties(defaultFallback="allMethodFallBack")
//在类上添加一个注解  @DefaultProperties(defaultFallback="allMethodFallBack")
public class OrderService {@HystrixCommand//指向降级方法public String queryOrderById() {    return "我出错了";}//    全局降级方法public String allMethodFallBack() {return "服务器太太太太太太太忙，请稍后重试.....";}
}

 超时设置

Hystix的默认超时时长为1秒，如果这个微服务响应时间超过1秒，就会报错，降级处理，但是有的方法本身需要执行的时间就长，自定义超时时间

hystrix:command:default:execution:isolation:thread:timeoutInMilliseconds: 3000 # 超时时间3秒

熔断原理

熔断功能：默认5秒内发起20次请求，失败率超过50% 进入熔断状态 5秒内的其他时间都会直接进入降级方法

熔断器有3种状态：open close half-open

状态机有3个状态：

  • Closed：关闭状态（断路器关闭），所有请求都正常访问。

  • Open：打开状态（断路器打开），所有请求都会被降级。Hystix会对请求情况计数，当一定时间内失败请求百分比达到阈值，则触发熔断，断路器会完全关闭。默认失败比例的阈值是50%，请求次数最少不低于20次。

  • Half Open：半开状态，open状态不是永久的，打开后会进入休眠时间（默认是5S）。随后断路器会自动进入半开状态。此时会释放1次请求通过，若这个请求是健康的，则会关闭断路器，否则继续保持打开，再次进行5秒休眠计时。

 Feign:封装了RestTemple 远程调用

导入依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

创建interface接口


@FeignClient("userservice")
public interface UserClient {@GetMapping("/user/{id}")  //这里的返回结果和 url地址一定要和提供方保持一致User findById(@PathVariable("id") Long id);
}

  • 首先这是一个接口，Feign会通过动态代理，帮我们生成实现类。这点跟mybatis的mapper很像

  • @FeignClient，声明这是一个Feign客户端，同时通过value属性指定服务名称

  • 接口中的定义方法，完全采用SpringMVC的注解，Feign会根据注解帮我们生成URL，并访问获取结果

开启Feign功能

@EnableFeignClients//开启Feign
public class OrderApplication {public static void main(String[] args) {SpringApplication.run(OrderApplication.class, args);}}

负载均衡

Feign中本身已经集成了Ribbon依赖和自动配置：

Feign默认也有对Hystix的集成：

feign:hystrix:enabled: true # 开启Feign的熔断功能
  • 首先，我们要定义一个类，是在刚才编写的UserFeignClient，作为fallback的处理类
import cn.itcast.order.pojo.User;
import org.springframework.stereotype.Component;@Component
public class UserClientFallback implements UserFeignClient {@Overridepublic User findById(Long id) {User user = new User();user.setId(0L);user.setUsername("用户查询出现异常！");return user;}
}
  • 然后在UserFeignClient中，指定刚才编写的实现类，就实现了降级方法
@FeignClient(value = "userservice", fallback = UserClientFallback.class)
public interface UserFeignClient {@GetMapping("/user/{id}")User findById(@PathVariable("id") Long id);
}

Gateway网关

网关的核心功能是：路由和过滤（鉴权）

  •  搭建网关
<dependencies><!--引入gateway 网关--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency>
</dependencies>
  • 编写启动类
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class ApiGatewayApplication {public static void main(String[] args) {SpringApplication.run(ApiGatewayApplication.class,args);}}
  • 编写配置
server:port: 10010
spring:application:name: api-gatewaycloud:# 网关配置gateway:# 路由配置：转发规则routes: #集合。# id: 唯一标识。默认是一个UUID# uri: 转发路径# predicates: 条件,用于请求网关路径的匹配规则- id: userserviceuri: http://localhost:8081/predicates:- Path=/user/**

application.yml 中的uri是写死的，就是Gateway-静态路由

Gateway-动态路由

<dependency><--添加注册中心Eureka--> <groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

 修改配置文件

server:port: 10010
spring:application:name: api-gatewaycloud:# 网关配置gateway:# 路由配置：转发规则routes: #集合。# id: 唯一标识。默认是一个UUID# uri: 转发路径# predicates: 条件,用于请求网关路径的匹配规则- id: user-serviceuri: lb://userservice # lb负载均衡predicates:- Path=/user/**eureka:client:service-url:defaultZone: http://127.0.0.1:10086/eureka

Gateway-过滤器

GatewayFilter：局部过滤器，针对单个路由 GlobalFilter ：全局过滤器，针对所有路由

全局过滤器

  • GlobalFilter 全局过滤器，不需要在配置文件中配置，系统初始化时加载，并作用在每个路由上。

  • Spring Cloud Gateway 核心的功能也是通过内置的全局过滤器来完成。

  • 自定义全局过滤器步骤：

    1. 定义类实现 GlobalFilter 和 Ordered接口

    2. 复写方法

    3. 完成逻辑处理

/*** 自定义全局过滤器*/
@Component
public class MyGlobalFilter implements GlobalFilter, Ordered {//需求 ：请求参数中带有token 内容，就放行，否则提示未授权@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
//        获取请求对象ServerHttpRequest request = exchange.getRequest();
//        获取参数MultiValueMap<String, String> valueMap = request.getQueryParams();List<String> valList = valueMap.get("token");if(CollectionUtils.isEmpty(valList)){//异常情况，没有token参数// 获取响应对象ServerHttpResponse response = exchange.getResponse();// 返回响应码response.setStatusCode(HttpStatus.FORBIDDEN);//401// 完成响应return response.setComplete();}return chain.filter(exchange);//放行}@Overridepublic int getOrder() {return 0;}
}

http://www.dtcms.com/wzjs/202156.html

相关文章：

  • 公司做一个网站如何定位链接生成二维码
  • 怎么修改网站的源代码如何制作网页广告
  • 浅笑云主机镇江seo快速排名
  • 企业网站seo模板智能营销方法
  • zblog2.0转wordpress关键词优化排名软件推荐
  • 星座 网站 建设青岛seo培训
  • 网站平台内容建设提纲网上做广告宣传
  • 杭州建站百度网站怎么提升排名
  • 谁给个好网站今日国内新闻大事20条
  • 陕西网站建设推广企业培训公司
  • 有哪些做品牌特卖的网站引擎搜索大全
  • 网站pc端建设2345网址导航怎么下载
  • 网页游戏人气排行榜广州seo教程
  • 深圳市城乡住房和建设局网站首页个人可以做推广的平台有哪些
  • app和微网站的对比分析指数工具
  • 贵阳网站设计找哪家企业文化墙
  • 什么人做网站长沙网站公司品牌
  • 如何设计网站站点网站优化seo培训
  • 奎文营销型网站建设长春免费网上推广
  • 校园网页设计模板简单百度seo查询系统
  • 免费文字logo生成器seo推广多少钱
  • 网站定制深圳裤子seo标题优化关键词
  • 买好域名和云主机后怎么做网站海门网站建设
  • 天猫店购买交易平台广东短视频seo搜索哪家好
  • 海口 网站建设怎么样拓展客户资源
  • wordpress 发布模块优化关键词具体要怎么做
  • 网页制作工具的选择与网站整体风格是有关系吗北京seo百科
  • 灵动网站建设媒体软文发稿
  • 谷歌seo网络营销价格宁波seo链接优化
  • 备案怎么关闭网站seo学校培训课程