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

Spring Boot使用EhCache完成一个缓存集群

news 2025/8/19 17:38:39

在上一篇在SpringBoot中使用EhCache缓存，我们完成了在Spring Boot中完成了对EhCaChe的使用，这篇，我们将对EhCache的进一步了解，也就是搭建一个EhCache的缓存集群。

集群

在搭建一个EhCache的时候，我们需要先了解，什么是集群？集群具有的特点？

什么是集群？以及集群的特点？

集群是值将多个独立的计算机节点连接在一起，通过网络协议协同工作，用以实现工共同的目标，在集群中，各个节点通过通信和协作来提供更高的性能，可用性和可扩展性。

集群可以用于各种不同领域，和应用场景，包括计算、存储、数据库、网络服务等，通过将各个节点组成集群，可以实现以下特点（或者成为好处）：

  • 高性能： 集群可以将任务分配给不同的节点并行处理，从而进一步提高整体的计算能力和处理速度，通过增加节点的数量，可以进一步提高集群的性能。
  • 高可用性：集群中的节点可以相互备份和冗余，当某个节点发生故障时，其他节点可以接管其工作，保证系统的持续可用性。这种冗余机制可以提高系统的容错能力。
  • 可扩展性：通过向集群中添加新的节点，可以轻松的拓展系统的处理能力和存储容量，这种可拓展性可以使得集群能够应对不同增长的需求和负载。
  • 负载均衡：集群可以通过负载均衡算法将请求分发到不同节点上，从而平衡各个节点的负载，避免单个节点过载，提高系统的稳定性和性能。
  • 故障恢复：集群可以通过故障检测和自动恢复机制来处理节点故障，当某个节点发生故障的时候，集群可以自动将任务重新分配给其他正常工作的节点，从而实现故障的快速恢复。

集群demo的搭建

引入相关依赖：

		<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-cache</artifactId></dependency><dependency><groupId>net.sf.ehcache</groupId><artifactId>ehcache</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><scope>provided</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>

application.properties配置文件

spring.datasource.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverspring.jpa.show-sql=true
spring.jpa.hibernate.ddl-auto=create#logging.level.net.sf.ehcache=debug# 不同实例的配置
#spring.cache.ehcache.config=classpath:ehcache-1.xml
#spring.cache.ehcache.config=classpath:ehcache-2.xml# 用不同命令启动不同实例
#-Dserver.port=8001 -Dspring.cache.ehcache.config=classpath:ehcache-1.xml
#-Dserver.port=8002 -Dspring.cache.ehcache.config=classpath:ehcache-2.xml

创建一个User实体类：

@Entity
public class User implements Serializable {@Id@GeneratedValueprivate Long id;private String name;private Integer age;public User(String name, Integer age) {this.name = name;this.age = age;}public Long getId() {return id;}public void setId(Long id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Integer getAge() {return age;}public void setAge(Integer age) {this.age = age;}public User() {}
}

创建一个User实体的数据访问实现

//插入缓存注解
@CacheConfig(cacheNames = "users")
public interface UserRepository extends JpaRepository<User, Long> {@CacheableUser findByName(String name);
}

在resources目录下分别创建ehcache-1.xml

<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:noNamespaceSchemaLocation="ehcache.xsd"><!--这里的users对应我们常用的--><cache name="users"maxEntriesLocalHeap="200"timeToLiveSeconds="600"><cacheEventListenerFactoryclass="net.sf.ehcache.distribution.RMICacheReplicatorFactory"properties="replicateAsynchronously=true,replicatePuts=true,replicateUpdates=true,replicateUpdatesViaCopy=false,replicateRemovals=true "/></cache><cacheManagerPeerProviderFactoryclass="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"properties="hostName=10.10.0.100,port=40001,socketTimeoutMillis=2000,peerDiscovery=manual,rmiUrls=//10.10.0.101:40001/users" /></ehcache>

创建另一个ehcache-2.xml

<ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:noNamespaceSchemaLocation="ehcache.xsd"><cache name="users"maxEntriesLocalHeap="200"timeToLiveSeconds="600"><cacheEventListenerFactoryclass="net.sf.ehcache.distribution.RMICacheReplicatorFactory"properties="replicateAsynchronously=true,replicatePuts=true,replicateUpdates=true,replicateUpdatesViaCopy=false,replicateRemovals=true "/></cache><cacheManagerPeerProviderFactoryclass="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"properties="hostName=10.10.0.101,port=40001,socketTimeoutMillis=2000,peerDiscovery=manual,rmiUrls=//10.10.0.100:40001/users" /></ehcache>

cache标签中定义名为users的缓存，这里我们增加了一个子标签定义cacheEventListenerFactory，这个标签主要用来定义缓存事件监听的处理策略，它有以下这些参数用来设置缓存的同步策略：
replicatePuts：当一个新元素增加到缓存中的时候是否要复制到其他的peers。默认是true。
replicateUpdates：当一个已经在缓存中存在的元素被覆盖时是否要进行复制。默认是true。
replicateRemovals：当元素移除的时候是否进行复制。默认是true。
replicateAsynchronously：复制方式是异步的指定为true时，还是同步的，指定为false时。默认是true。
replicatePutsViaCopy：当一个新增元素被拷贝到其他的cache中时是否进行复制指定为true时为复制，默认是true。
replicateUpdatesViaCopy：当一个元素被拷贝到其他的cache中时是否进行复制指定为true时为复制，默认是true。
新增了一个cacheManagerPeerProviderFactory标签的配置，用来指定组建的集群信息和要同步的缓存信息，其中：
hostName：是当前实例的主机名
port：当前实例用来同步缓存的端口号
socketTimeoutMillis：同步缓存的Socket超时时间
peerDiscovery：集群节点的发现模式，有手工与自动两种，这里采用了手工指定的方式
rmiUrls：当peerDiscovery设置为manual的时候，用来指定需要同步的缓存节点，如果存在多个用|连接

注意以上ip地址的分配

ok具体的配置我们已经配置完毕了，那么我们启动项目和添加测试类进行测试了：

@EnableCaching
@SpringBootApplication
public class Application {public static void main(String[] args) throws Exception {
//		LocateRegistry.createRegistry(Integer.valueOf(System.getProperty("rmi.port")));SpringApplication.run(Application.class, args);}@RestControllerstatic class HelloController {@Autowiredprivate UserRepository userRepository;@GetMapping("/create")public void create() {userRepository.save(new User("AAA", 10));}@GetMapping("/update")public User update() {User u1 = userRepository.findByName("AAA");u1.setAge(20);u1 = userRepository.save(u1);return u1;}@GetMapping("/find")public User find() {User u1 = userRepository.findByName("AAA");System.out.println("查询AAA用户：" + u1.getAge());return u1;}}
}

我们通过打包的方式运行我们的实例：

# 实例1
-Dspring.cache.ehcache.config=classpath:ehcache-1.xml
# 实例2 
-Dspring.cache.ehcache.config=classpath:ehcache-2.xml

在以上代码中，也就是我们常用的Controller层，主要围绕我们所说的命令参数，启动相关实例。

  • 调用实例1的/create接口，创建一条数据

  • 调用实例1的/find接口，此时会清除缓存中的User,同时同步缓存相关信息给另一个实例，在实例1中会存在我们常用的SQL语句。

  • 调用实例2的/find接口，由于缓存集群同步了User的信息，所以在实例2中的这次查询也不会出现SQL语句

以及创建一个测试类：

@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {@Autowiredprivate UserRepository userRepository;@Autowiredprivate CacheManager cacheManager;@Testpublic void test() throws Exception {System.out.println("CacheManager type : " + cacheManager.getClass());// 创建1条记录userRepository.save(new User("AAA", 10));User u1 = userRepository.findByName("AAA");System.out.println("第一次查询：" + u1.getAge());User u2 = userRepository.findByName("AAA");System.out.println("第二次查询：" + u2.getAge());}
}

在这里插入图片描述

注意，以上实例建议在多机的情况下进行，有云服务器就是使用云服务器，并配备好上述的Ip地址，方便集群之间进行通讯，通过打包的方式运行，可以帮助我们减少很多麻烦

http://www.lryc.cn/news/232620.html

相关文章：

  • yolov5模型代码怎么修改
  • VIM去掉utf-8 bom头
  • Go 使用Viper处理Go应用程序的配置
  • hadoop安装网址
  • JavaMail邮件发送服务
  • 【918.环形子数组的最大和】
  • Unity Quaternion接口API的常用方法解析_unity基础开发教程
  • Rust开发——使用rust实现Redis中hset
  • 海康Visionmaster-环境配置：VB.Net 二次开发环境配 置方法
  • 51单片机应用从零开始（四）
  • Django下的Race Condition漏洞
  • 【数据结构】希尔排序(最小增量排序)
  • Android Native崩溃信息分析和 工具（addr2line和ndkstack）使用
  • 2023年05月 Python（六级）真题解析#中国电子学会#全国青少年软件编程等级考试
  • SQLite3 数据库学习（文章链接汇总）
  • 【VSCode】Visual Studio Code 下载与安装教程
  • 分布式教程从0到1【1】分布式基础
  • Ubuntu22.04 部署Mqtt服务器
  • HMM与LTP词性标注之LTP介绍
  • 基于SSM的学生疫情信息管理系统设计与实现
  • 分类预测 | Matlab实现PSO-GRU粒子群算法优化门控循环单元的数据多输入分类预测
  • 用电子签章软件怎么给标书一键签章的小故事
  • Windows10电脑没有微软商店的解决方法
  • SpringCloud-Gateway修改Response响应体，并解决大数据量返回不全等问题
  • Spark与SQL之间NB的转换_withClumn，split及SubString
  • 修改服务器端Apache默认根目录
  • 网络安全（大厂面试真题集）
  • 系列五、JVM的内存结构【PC寄存器】
  • ClickHouse UDF 运行速度慢问题
  • python科研绘图：面积图