2024-09-06

在这篇文章中,我们将会使用Spring Cloud Feign来重写之前使用Dubbo的例子。Feign是一个声明式的Web服务客户端,它使得编写Web服务客户端变得更加简单。

首先,我们需要在pom.xml中添加Feign的依赖:




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

然后,我们需要在启动类上添加@EnableFeignClients注解来启用Feign客户端:




@SpringBootApplication
@EnableFeignClients
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

接下来,我们需要定义一个Feign客户端接口:




@FeignClient(name = "provider-service", path = "/provider")
public interface ProviderClient {
    @GetMapping("/hello")
    String hello();
}

在这个接口中,我们指定了服务名称name和基础路径path,并且定义了一个hello方法来调用提供者服务的/hello接口。

最后,我们可以在Controller中使用这个Feign客户端:




@RestController
public class ConsumerController {
    @Autowired
    private ProviderClient providerClient;
 
    @GetMapping("/hello")
    public String hello() {
        return providerClient.hello();
    }
}

这样,我们就使用Feign替换了Dubbo,实现了服务的消费者。这个例子非常简单,但足以展示如何使用Feign进行服务调用。

2024-09-06

微服务是一种架构风格,它提倡将单一应用程序划分成一组小的服务,每个服务运行在自己的进程中,服务之间通过轻量级的通信机制进行通信。Spring Cloud 是一个提供工具支持以微服务架构方式开发分布式系统的 Java 库。

以下是使用 Spring Cloud 构建微服务的一些关键概念和示例代码:

  1. 服务注册与发现 - 使用 Eureka



@EnableEurekaClient
@SpringBootApplication
public class MyServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyServiceApplication.class, args);
    }
}
  1. 客户端负载均衡 - 使用 Ribbon 或 Feign



@EnableFeignClients
@EnableEurekaClient
@SpringBootApplication
public class MyServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyServiceApplication.class, args);
    }
}
 
@FeignClient("other-service")
public interface OtherServiceClient {
    @GetMapping("/endpoint")
    String getData();
}
  1. 配置管理 - 使用 Spring Cloud Config



@EnableConfigServer
@SpringBootApplication
public class ConfigServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }
}
 
@EnableConfigClient
@SpringBootApplication
public class MyServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyServiceApplication.class, args);
    }
}
  1. 服务间调用 - 使用 Hystrix 实现断路器模式



@EnableCircuitBreaker
@SpringBootApplication
public class MyServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyServiceApplication.class, args);
    }
}
 
@Component
public class MyServiceClient {
    @HystrixCommand(fallbackMethod = "fallbackMethod")
    public String callOtherService() {
        // 调用其他服务的逻辑
    }
 
    public String fallbackMethod() {
        // 断路器触发时的回退逻辑
    }
}
  1. 路由网关 - 使用 Spring Cloud Gateway



@EnableGateway
@SpringBootApplication
public class GatewayApplication {
    public static void main(String[] args) {
        SpringApplication.run(GatewayApplication.class, args);
    }
}

这些代码片段展示了如何使用 Spring Cloud 的注解和组件来构建微服务架构。Spring Cloud 提供了一套完整的工具集,帮助开发者更容易地实现和管理微服务。

2024-09-06

Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性简化了分布式系统的开发,通过集成现有的服务发现和治理的方案,提供了配置管理、服务发现、智能路由、负载均衡、断路器、分布式消息传递等。

以下是Spring Cloud的主要组成部分:

  1. Spring Cloud Config:配置管理工具,使用版本控制系统来存储配置信息,可以方便的管理不同环境下的配置。
  2. Spring Cloud Netflix:集成了多种Netflix的开源工具,如Zuul路由器、Eureka服务发现等。
  3. Spring Cloud Bus:事件、消息总线,用于传输集群中的状态变化,可与配置管理组件配合,实现配置的热更新。
  4. Spring Cloud Sleuth:日志收集工具,将分布式系统的跟踪日志整合在一起,方便调试。
  5. Spring Cloud Security:为微服务系统提供安全保障,如OAuth2、JWT等。
  6. Spring Cloud Stream:数据流操作开发包,简化消息的发送和接收。
  7. Spring Cloud Task:为短期运行的微服务提供支持。
  8. Spring Cloud Zookeeper:服务发现的Zookeeper实现。
  9. Spring Cloud Consul:服务发现的Consul实现。
  10. Spring Cloud Gateway:新一代API网关。

示例代码:




@SpringBootApplication
@EnableEurekaClient
public class MyServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyServiceApplication.class, args);
    }
}

以上代码示例展示了如何创建一个简单的Spring Cloud微服务,通过@EnableEurekaClient注解将服务注册到Eureka服务中心。这只是一个简单的入门示例,实际使用时需要根据具体需求配置服务发现、断路器、配置管理等组件。

2024-09-06

在Spring Cloud Alibaba微服务中,Ribbon是一个客户端负载均衡器,它可以在客户端配置服务提供者地址后,在服务提供者列表中选择一个服务实例进行通信。

以下是使用Ribbon进行负载均衡的示例代码:

  1. 在pom.xml中添加依赖:



<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>
  1. 配置RestTemplate实例,并通过@LoadBalanced注解启用Ribbon负载均衡:



@Configuration
public class RestConfig {
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}
  1. 使用RestTemplate调用服务提供者:



@RestController
public class ConsumerController {
 
    @Autowired
    private RestTemplate restTemplate;
 
    @GetMapping("/consumer")
    public String consumer() {
        return restTemplate.getForObject("http://provider-service/provider", String.class);
    }
}

在上述代码中,我们配置了一个RestTemplate的Bean,并且通过@LoadBalanced注解使其支持Ribbon的负载均衡。然后在ConsumerController中,我们使用这个RestTemplate来调用服务提供者的接口,Ribbon会根据服务ID自动在服务提供者列表中选择一个实例进行通信。

2024-09-06

微服务治理是微服务架构中的一个核心部分,主要解决服务的注册与发现,服务的配置管理,服务的路由和负载均衡,服务的熔断机制等问题。

Nacos 是一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。它是Spring Cloud Alibaba 组件之一,可以帮助开发者更容易地管理微服务应用。

以下是如何在Spring Cloud项目中引入Nacos的步骤:

  1. 在pom.xml中添加Nacos的依赖:



<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
  1. 在application.properties或application.yml中配置Nacos服务器地址:



spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
  1. 在启动类上添加@EnableDiscoveryClient注解:



import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
 
@SpringBootApplication
@EnableDiscoveryClient
public class NacosProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(NacosProviderApplication.class, args);
    }
}
  1. 编写一个服务提供者,并将其注册到Nacos:



import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class EchoController {
    @Value("${server.port}")
    private String serverPort;
 
    @GetMapping(value = "/echo")
    public String echo(@RequestParam String message) {
        return "Hello " + message + " , Port is " + serverPort;
    }
}

以上步骤展示了如何在Spring Cloud项目中引入Nacos,并将服务注册到Nacos。这样,你就可以通过Nacos来管理你的微服务,实现服务的发现和管理。

2024-09-06

Spring Cloud 微服务的五大组件分别是:服务注册与发现、服务网关、服务负载均衡、服务容错保护、服务配置管理。

  1. 服务注册与发现 - Eureka

    Eureka 是 Netflix 开源的一款提供服务注册和服务发现的产品,Spring Cloud 集成了 Eureka,可以很容易的实现服务注册和发现。

  2. 服务网关 - Zuul

    Zuul 是 Netflix 开源的微服务网关,用于服务路由和过滤。

  3. 服务负载均衡 - Ribbon

    Ribbon 是 Netflix 开源的一个负载均衡客户端,可以帮助我们在微服务架构中实现服务间的负载均衡。

  4. 服务容错保护 - Hystrix

    Hystrix 是 Netflix 开源的一个延迟和容错库,用于防止系统间的级联故障,提高系统的弹性。

  5. 服务配置管理 - Spring Cloud Config

    Spring Cloud Config 是 Spring Cloud 的一个配置管理工具,可以让我们在微服务架构中更好的管理配置文件。

以上各组件的使用示例代码可以在各自的官方文档或相关技术博客中找到,这里不再展开。

2024-09-06



import com.alibaba.csp.sentinel.annotation.SentinelResource;
import com.alibaba.csp.sentinel.slots.block.BlockException;
import com.ctrip.framework.apollo.Config;
import com.ctrip.framework.apollo.ConfigService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class SentinelController {
 
    private final Config config = ConfigService.getAppConfig();
 
    @GetMapping("/testSentinel")
    @SentinelResource(value = "test", blockHandler = "handleException")
    public String testSentinel(@RequestParam(value = "p", defaultValue = "0") int p) {
        if (p > 0) {
            // 模拟长时间运行的业务逻辑
        }
        return "Sentinel 限流和熔断测试";
    }
 
    public String handleException(String s, BlockException ex) {
        // 可以根据配置的Apollo值进行逻辑处理
        String fallback = config.getProperty("fallback", "fallback");
        return fallback;
    }
}

这段代码展示了如何在Spring Cloud微服务中使用Sentinel进行限流和熔断,并结合Apollo进行动态配置。testSentinel方法使用了@SentinelResource注解来标记资源,并指定了异常处理方法handleException。在业务逻辑中,我们模拟了一个根据参数判断的长时间运行的操作,Sentinel会根据配置的规则进行流量控制和熔断。异常处理方法handleException会从Apollo获取配置来决定返回值。

2024-09-06

由于原始代码已经比较完整,以下是核心依赖和配置的示例代码:

pom.xml (Spring Cloud Alibaba 依赖):




<dependencies>
    <!-- Spring Cloud Alibaba 基础设施 -->
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
    </dependency>
    <!-- 其他依赖... -->
</dependencies>

bootstrap.properties (Spring Cloud Alibaba 配置):




spring.application.name=henghub-crm
spring.cloud.nacos.config.server-addr=127.0.0.1:8848
spring.cloud.nacos.config.namespace=henghub-crm-namespace
spring.cloud.nacos.config.group=henghub-crm-group
spring.cloud.nacos.config.extension-configs[0].data-id=henghub-crm-config.properties
spring.cloud.nacos.config.extension-configs[0].group=henghub-crm-group
spring.cloud.nacos.config.extension-configs[0].refresh=true
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848
spring.cloud.nacos.discovery.namespace=henghub-crm-namespace
spring.cloud.nacos.discovery.group=henghub-crm-group

application.properties (项目配置):




# 数据库配置
spring.datasource.url=jdbc:mysql://localhost:3306/henghub_crm?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
 
# 其他配置...

以上代码提供了 Spring Cloud Alibaba 的配置示例,包括服务注册与发现以及配置中心的配置。在实际应用中,你需要根据自己的 Nacos 服务器地址和命名空间进行相应的配置。

2024-09-06

Feign是一个声明式的Web服务客户端,它使得编写Web服务客户端变得更加简单。使用Feign时,你可以创建一个接口,然后在接口上添加注解,Feign就会使用这些注解来创建出Web服务的客户端。

以下是一个使用Feign进行远程调用的简单示例:

  1. 首先,添加Feign的依赖到你的Spring Cloud项目中:



<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
  1. 然后,在你的应用主类或者配置类上添加@EnableFeignClients注解来启用Feign客户端:



@SpringBootApplication
@EnableFeignClients
public class YourApplication {
    public static void main(String[] args) {
        SpringApplication.run(YourApplication.class, args);
    }
}
  1. 创建一个Feign客户端接口:



@FeignClient(name = "your-service-name", url = "http://your-service-url")
public interface YourServiceClient {
    @GetMapping("/endpoint")
    String getData(@RequestParam("param") String param);
}

在这个例子中,YourServiceClient是一个Feign客户端接口,它定义了一个方法getData,该方法用@FeignClient注解标注,指定了远程服务的名称和URL。@GetMapping注解指定了远程服务的端点以及需要传递的参数。

  1. 使用Feign客户端:



@RestController
public class YourController {
 
    @Autowired
    private YourServiceClient yourServiceClient;
 
    @GetMapping("/data")
    public String getData(@RequestParam("param") String param) {
        return yourServiceClient.getData(param);
    }
}

在这个例子中,你可以看到YourController中注入了YourServiceClient,然后在其方法getData中调用了Feign客户端的方法来获取远程服务的数据。

这就是使用Feign进行远程调用的基本步骤。记得替换your-service-namehttp://your-service-url为你实际要调用的服务名称和URL。

2024-09-06

Eureka是Netflix开源的一款提供服务注册和发现的项目,Spring Cloud将它集成在其子项目Spring Cloud Netflix中。

以下是使用Spring Cloud构建Eureka Server的示例代码:




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
 
@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaServerApplication.class, args);
    }
}

application.propertiesapplication.yml中配置Eureka Server:




server:
  port:
 
eureka:
  instance:
    hostname: localhost
  client:
    registerWithEureka: false
    fetchRegistry: false
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

在上述代码中,我们创建了一个标有@EnableEurekaServer的Spring Boot应用程序,该注解启用Eureka服务器的功能。然后,我们在application.yml中配置了Eureka服务器的端口、实例信息以及服务注册相关的设置。这样就创建了一个基本的Eureka服务注册中心。