1. 云图网首页
  2. 技术专区
  3. 数据库

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/278388.html

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

相关推荐

发表回复

登录后才能评论