SpEL、Spring缓存注解、Redis核心配置类、微服务Eureka


SpEL表达式

什么是SpEL表达式

SpEL(Spring Expression Language),即Spring表达式语言。它是一种类似JSP的EL表达式、但又比后者更为强大有用的表达式语言。

为什么要用SpEL

因为它可以在spring容器内实时查询和操作数据,尤其是操作List列表型、Array数组型数据。所以使用SpEL可以有效缩减代码量,优化代码结构。

用法

  • 在注解@Value中使用
  • XML配置中使用
  • 代码中创建Expression对象,利用Expression对象来执行SpEL

1. @Value注解

@Value可以加在class的成员变量和形参上。用法如下:

    //@Value能修饰成员变量和方法形参
    //#{}内就是SpEL表达式的语法
    //Spring会根据SpEL表达式语法,为变量arg赋值
    @Value("#{表达式}")
    public String arg;

如果修饰成员变量,Spring容器会根据SpEL表达式语法筛选修改数据,然后赋值给所@Value修饰的变量;

如果修饰方法形参,则是过滤传进来的参数值。

PS:value属性的表现形式

@Value()的value属性可以有三种表现形式:

  • 字符串: 可能为普通字符串或者资源路径,例如:
@Value("hello")
private String word;    //将"hello"字符串赋值给word变量
@Value("http://www.baidu.com")
private Resource url;    //从网址"http://www.baidu.com"获取资源
  • #{}:在大括号内可以为其他bean或者bean的属性环境变量等,本文大量实例都是使用#{}方式实现的,举例略

  • ${}: 在大括号内可以为properties资源文件内的配置项。例如:

    //在application.properties或者其他配置文件中添加如下配置项:
    //book.author=Albert
    
    @Value("${book.author}")
    private String author;    //Spring会将Albert赋值给author变量
    
    //使用@Value(${})格式时,spring会通过加载框架自带的PropertySourcesPlaceholderConfigurer的Bean,或者通过@PropertySource制定特定的properties文件
    

2.XML配置

……… 写的太多了我不想写了 ,大概了解了一下子,估计也挺少用到

原文链接: SpEL表达式的用法

spring关于缓存的注解使用@CacheConfig,@Cacheable,@CachePut,@CacheEvict,@Caching

/**
 *   @CacheConfig: 提供一种在类级别共享公共缓存相关设置的机制。
 *   这个注解写在类上,主要作用是抽取缓存方法的公共属性
 *  主要属性有:
 *   缓存名称:cacheNames,对应value或者cacheNames
 *   缓存管理器名称:cacheManager,对应cacheManager
 *   KeyGenerator的名称集合:keyGenerator,对应keyGenerator
 */
@CacheConfig(cacheNames = "student")  //
public interface StudentService { ... }
 /**
  *  @CachePut: 与@Cacheable基本相同
  *
  *  区别是
  * @CachePut:这个注释可以确保方法被执行,同时方法的返回值也被记录到缓存中。
  * @Cacheable:当重复使用相同参数调用方法时,方法本身不会被调用,而是直接从缓存中找到结果并返回。
  * 也就是说@Cacheable一次缓存,不再更新。@CachePut次次缓存,一直更新
  *
  */
 @CachePut(key = "#p0.sno")
 Student update(Student student);
/**
 *   @CacheEvict: 放置在方法上,可以按照条件清除缓存
 *
 *   主要属性有:
 * 键名:key,可以为空,可使用 SpEL 表达式编写,如果为空,则按照方法的所有参数进行组合
 * 缓存条件:condition,可以为空,使用 SpEL 编写,返回 true 或 false,为 true 才进行缓存
 * 缓存名称:value,可集体抽取为@CacheConfig的cacheNames,或者单独写,必填
 * 是否清空所有缓存:allEntries,缺省为 false,指定为 true
 */
@CacheEvict(key = "#p0", allEntries = true)
void deleteStudentBySno(String sno);
/**
 *   @Cacheable: 放置在方法上,表示可以将结果放入缓存
 *
 *   主要属性有:
 * 键名:key,可以为空,可使用 SpEL 表达式编写,如果为空,则按照方法的所有参数进行组合
 * 缓存条件:condition,可以为空,使用 SpEL 编写,返回 true 或 false,为 true 才进行缓存
 * 缓存名称:value,可集体抽取为@CacheConfig的cacheNames,或者单独写,必填
 */
@Cacheable(key = "#p0")
Student queryStudentBySno(String sno);
/**
 *  @Caching: 为自定义的组合缓存规则
 *
 *  主要属性有:
 * @Cacheable的组合:cacheable,默认{}
 * @CachePut的组合:put,默认{}
 * @CacheEvict的组合:evict,默认{}
 */
@Caching
void caching(String aa);

Redis核心配置类

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * Created by xinchen on 2022/7/22
 *
 * @Description : Redis的核心配置类
 */
@Configuration
public class RedisConfig {

    // 自己定义了一个RedisTemplate
    @Bean
    @SuppressWarnings("all")
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        // 我们为了自己开发方便,一般直接使用 <String, Object>
        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        template.setConnectionFactory(factory);
        // Json序列化配置
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        // String 的序列化
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        // key采用String的序列化方式
        template.setKeySerializer(stringRedisSerializer);
        // hash的key也采用String的序列化方式
        template.setHashKeySerializer(stringRedisSerializer);
        // value序列化方式采用jackson
        template.setValueSerializer(jackson2JsonRedisSerializer);
        // hash的value序列化方式采用jackson
        template.setHashValueSerializer(jackson2JsonRedisSerializer);
        template.afterPropertiesSet();
        return template;
    }

}

微服务

微服务的架构特征:

  • 单一职责:微服务拆分粒度更小,每一个服务都对应唯一的业务能力,做到单一职责
  • 自治:团队独立、技术独立、数据独立,独立部署和交付
  • 面向服务:服务提供统一标准的接口,与语言和技术无关
  • 隔离性强:服务调用做好隔离、容错、降级,避免出现级联问题

微服务的上述特性其实是在给分布式架构制定一个标准,进一步降低服务之间的耦合度,提供服务的独立性和灵活性。做到高内聚,低耦合。

因此,可以认为微服务是一种经过良好架构设计的分布式架构方案

微服务的架构特征总结

  • 单体架构:简单方便,高度耦合,扩展性差,适合小型项目。例如:学生管理系统

  • 分布式架构:松耦合,扩展性好,但架构复杂,难度大。适合大型互联网项目,例如:京东、淘宝

  • 微服务:一种良好的分布式架构方案

    ①优点:拆分粒度更小、服务更独立、耦合度更低

    ②缺点:架构非常复杂,运维、监控、部署难度提高

  • SpringCloud是微服务架构的一站式解决方案,集成了各种优秀微服务功能组件

服务拆分原则

  • 不同微服务,不要重复开发相同业务
  • 微服务数据独立,不要访问其它微服务的数据库
  • 微服务可以将自己的业务暴露为接口,供其它微服务调用

微服务远程调用

原因:微服务之间数据库不互通,但服务间有关联,必须在一方服务请求时向另一服务发送请求

方式:使用RestTemplate发起http请求实现远程调用

流程:

  1. 先向Spring注入RestTemplate
@SpringBootApplication
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }
    /**
     * 创建RestTemplate并注入Spring
     * @param
     * @return
     */
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}
  1. 修改OrderService
@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private RestTemplate restTemplate;

    public Order queryOrderById(Long orderId) {
        // 1.查询订单
        Order order = orderMapper.findById(orderId);
        // 2.利用RestTemplate发送http请求,查询用户
        String url = "http://localhost:8081/user/" + order.getUserId();
        // get请求:getForObject(url, *.class); 得到想要的值类型*
        User user = restTemplate.getForObject(url, User.class);
        // 3.封装User对象到Order
        order.setUser(user);
        // 4.返回
        return order;
    }
}

这样就可以完成在一方服务请求时向另一服务发送请求的功能

服务调用关系

  • 服务提供者:暴露接口给其他微服务调用
  • 服务消费者:调用其他微服务提供的接口
  • 提供者与消费者是相对的。一个服务可以同时是提供者和消费者

Eureka注册中心

作用

问题1:order-service如何得知user-service实例地址?

获取地址信息的流程如下:

  • user-service服务实例启动后,将自己的信息注册到eureka-server(Eureka服务端)。这个叫服务注册
  • eureka-server保存服务名称到服务实例地址列表的映射关系
  • order-service根据服务名称,拉取实例地址列表。这个叫服务发现服务拉取

问题2:order-service如何从多个user-service实例中选择具体的实例?

  • order-service从实例列表中利用负载均衡算法选中一个实例地址
  • 向该实例地址发起远程调用

问题3:order-service如何得知某个user-service实例是否依然健康,是不是已经宕机?

  • user-service会每隔一段时间(默认30秒)向eureka-server发起请求,报告自己状态,称为心跳
  • 当超过一定时间没有发送心跳时,eureka-server会认为微服务实例故障,将该实例从服务列表中剔除
  • order-service拉取服务时,就能将故障实例排除

注意:一个微服务,既可以是服务提供者,又可以是服务消费者,因此eureka将服务注册、服务发现等功能统一封装到了eureka-client端

Eureka中的微服务角色类型:

  • EurekaServer:服务端,注册中心

    • 记录服务信息
    • 心跳监控
  • EurekaClient:客户端

    • Provider:服务提供者,例如案例中的 user-service
      • 注册自己的信息到EurekaServer
      • 每隔30秒向EurekaServer发送心跳
    • consumer:服务消费者,例如案例中的 order-service
      • 根据服务名称从EurekaServer拉取服务列表
      • 基于服务列表做负载均衡,选中一个微服务后发起远程调用

搭建EurekaServer

  • 引入eureka-server依赖
<!--eureka服务端依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>
  • 添加@EnableEurekaServer注解
  • 在application.yml中配置eureka地址
server:
  port: 10086
spring:
  application:  # eureka的服务名称
    name: eurekaserver
eureka:
  client:
    service-url:  # eureka的地址信息
      defaultZone: http://127.0.0.1:10086/eureka/

Eureka服务注册(以order服务为例)

  • 引入eureka-client依赖
<!--eureka客户端依赖-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
  • 在application.yml中配置eureka地址
spring:
  application:  # eureka的服务名称
    name: orderservice
eureka:
  client:
    service-url:  # eureka的地址信息
      defaultZone: http://127.0.0.1:10086/eureka/

无论是消费者还是提供者,引入eureka-client依赖、知道eureka地址后,都可以完成服务注册

启动多个order-service 实例

  • 复制原来的user-service启动配置(Copy Configuration)
  • 在弹出的窗口中Environment 的 VM options 栏,填写信息:-Dserver.port=xxxx

原创文章,作者:奋斗,如若转载,请注明出处:https://blog.ytso.com/278384.html

(0)
上一篇 2022年8月2日
下一篇 2022年8月2日

相关推荐

发表回复

登录后才能评论