首页 > 数据库> 文章详细

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

2022-08-02 01:03:56 阅读：175 来源： 互联网

标签：缓存服务 service Spring Redis eureka SpEL Eureka order

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请求实现远程调用

流程：

先向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();
    }

}

修改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

标签：缓存,服务,service,Spring,Redis,eureka,SpEL,Eureka,order
来源： https://www.cnblogs.com/XinChennn/p/16542350.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9