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

在上一篇在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.rhkb.cn/news/194557.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

qt笔记之qml和C++的交互系列(一)：初记

qt笔记之qml和C++的交互系列(一)：初记

code review! —— 杭州 2023-11-16 夜 文章目录 一.qt笔记之qml和C的交互&#xff1a;官方文档阅读理解0.《Overview - QML and C Integration》中给出五种QML与C集成的方法1.Q_PROPERTY&#xff1a;将C类的成员变量暴露给QML2.Q_INVOKABLE()或public slots&#xff1a;将C类…
阅读更多...
【python】均值、中值和高斯滤波详解和示例

【python】均值、中值和高斯滤波详解和示例

本文对均值、中值和高斯滤波进行详解&#xff0c;以帮助大家理解和使用。 这里写目录标题 均值滤波中值滤波高斯滤波核大小为&#xff08;9,9&#xff09;核大小为&#xff08;51,51&#xff09; 小结 下面是示例中使用的原图。 均值滤波 均值滤波是一种简单的平滑滤波器&…
阅读更多...
nodejs+vue教室管理系统的设计与实现-微信小程序-安卓-python-PHP-计算机毕业设计

nodejs+vue教室管理系统的设计与实现-微信小程序-安卓-python-PHP-计算机毕业设计

用户 用户管理&#xff1a;查看&#xff0c;修改自己的个人信息 教室预约&#xff1a;可以预约今天明天的教室&#xff0c;按着时间段预约&#xff08;可多选&#xff09;&#xff0c;如果当前时间超过预约时间段不能预约该时间段的教室 预约教室的时候要有个预约用途&#xff…
阅读更多...
python趣味编程-5分钟实现一个Flappy Bird游戏（含源码、步骤讲解）

python趣味编程-5分钟实现一个Flappy Bird游戏（含源码、步骤讲解）

Python 中的 Flappy Bird 游戏可以免费下载开源代码，它是为想要学习 Python 的初学者创建的。 该项目系统使用了 Pygame 和 Random 模块。 Pygame 是一组跨平台的 Python 模块，专为编写视频游戏而设计。 Python 中的 Flappy Bird 代码 – 项目信息 项目名称：Python 中的 Fl…
阅读更多...
redis设置密码

redis设置密码

首先到redis的下载目录下&#xff1a;运行 redis-cli 查看redis密码&#xff1a; config get requirepass 设置redis密码为123456&#xff1a; config set requirepass 123456
阅读更多...
Spring SPI

Spring SPI

SPI 服务供给接口&#xff08;Service Provider Interface&#xff09;。是Java 1.5新添加的一个内置标准&#xff0c;允许不同的开发者去实现某个特定的服务。 1 SPI 介绍 一个接口&#xff0c;可能会有许多个实现&#xff0c;我们在编写代码时希望能动态切换具体实现&#…
阅读更多...
基于STM32的循迹小车项目实战

基于STM32的循迹小车项目实战

循迹小车是一种能够沿着预定路线行驶的智能小车&#xff0c;通过巡线传感器检测路面的线路&#xff0c;并根据检测结果调整行驶方向。本项目将基于STM32微控制器实现一个简单的循迹小车&#xff0c;通过学习和实践&#xff0c;帮助初学者熟悉STM32的开发流程和掌握循迹小车的实…
阅读更多...
linux运行java程序

linux运行java程序

这个帖子实现的是linux上运行java代码 文章目录 前言一、pandas是什么&#xff1f;二、使用步骤 1.引入库2.读入数据总结 前言 事情发生的原因是博洋需要知道海外城市的数量&#xff0c;我一开始准备将全量数据拉取到本地&#xff0c;用代码遍历一遍。但是打包好全量数据&…
阅读更多...
CentOS中安装常用环境

CentOS中安装常用环境

一、CentOS安装 redis ①&#xff1a;更新yum sudo yum update②&#xff1a;安装 EPEL 存储库 Redis 通常位于 EPEL 存储库中。运行以下命令安装 EPEL 存储库 sudo yum install epel-release③&#xff1a;安装 Redis sudo yum install redis④&#xff1a;启动 Redis 服…
阅读更多...
MYSQL中的触发器TRIGGER

MYSQL中的触发器TRIGGER

1.概念 触发器是一个特殊的存储过程&#xff0c;当触发器保护的数据发生变更时就会触发。 2.特性 1.触发器与表息息相关&#xff0c;一般我们一个表创建六个触发器。 2.六个触发器其实是三种类六个 insert 类型 before | after insertupdate 类型 before | af…
阅读更多...
STM32中断看这一篇就够了

STM32中断看这一篇就够了

&#x1f64c;秋名山码民的主页 &#x1f602;oi退役选手&#xff0c;Java、大数据、单片机、IoT均有所涉猎&#xff0c;热爱技术&#xff0c;技术无罪 &#x1f389;欢迎关注&#x1f50e;点赞&#x1f44d;收藏⭐️留言&#x1f4dd; 获取源码&#xff0c;添加WX 目录 1. 前言…
阅读更多...
基于SSM的教学管理系统设计与实现

基于SSM的教学管理系统设计与实现

末尾获取源码 开发语言&#xff1a;Java Java开发工具&#xff1a;JDK1.8 后端框架&#xff1a;SSM 前端&#xff1a;采用JSP技术开发 数据库&#xff1a;MySQL5.7和Navicat管理工具结合 服务器&#xff1a;Tomcat8.5 开发软件&#xff1a;IDEA / Eclipse 是否Maven项目&#x…
阅读更多...
【Proteus仿真】【Arduino单片机】HC05蓝牙通信

【Proteus仿真】【Arduino单片机】HC05蓝牙通信

文章目录 一、功能简介二、软件设计三、实验现象联系作者 一、功能简介 本项目使用Proteus8仿真Arduino单片机控制器&#xff0c;使用PCF8574、LCD1602液晶、HC05蓝牙传感器等。 主要功能&#xff1a; 系统运行后&#xff0c;LCD1602显示蓝牙接收数据。 二、软件设计 /* 作者…
阅读更多...
MR外包团队：MR、XR混合现实技术应用于游戏、培训，心理咨询、教育成为一种创新的各行业MR、XR形式！

MR外包团队：MR、XR混合现实技术应用于游戏、培训，心理咨询、教育成为一种创新的各行业MR、XR形式！

随着VR、AR、XR、MR混合现实等技术逐渐应用于游戏开发、心理咨询、培训、教育各个领域&#xff0c;为教育、培训、心理咨询等行业带来了全新的可能性。MR、XR游戏开发、心理咨询是利用虚拟现实技术模拟真实场景&#xff0c;让学生身临其境地参与学习和体验&#xff0c;从而提高…
阅读更多...
MapApp 地图应用

MapApp 地图应用

1. 简述 1.1 重点 1&#xff09;更好地理解 MVVM 架构 2&#xff09;更轻松地使用 SwiftUI 框架、对齐、动画和转换 1.2 资源下载地址: Swiftful-Thinking:https://www.swiftful-thinking.com/downloads 1.3 项目结构图: 1.4 图片、颜色资源文件图: 1.5 启动图片配置图: 2. Mo…
阅读更多...
Linux | 安装openGauss数据库

Linux | 安装openGauss数据库

Linux 安装openGauss数据库 今天我们来安装一下国产数据库openGauss~~ 下载openGauss 首先在官网:https://opengauss.org/zh/download/下载对应的安装包&#xff0c;我们这里下载LInux 极简版来演示安装 下载后,使用root用户上传到Linux ,这边上传到/usr/local/目录下, 使用…
阅读更多...
IoC和DI

IoC和DI

Spring 是包含众多工具的 IoC 容器,存的是对象,对象这个词在 Spring 的范围内,称之为 bean IoC 是控制反转 控制权进行了反转,比如对某一个东西的控制权在 A 手上,结果变成了 B ,Spring 管理的是 bean ,所以这里的控制权指的是 bean 的控制权,也就是对象的控制权进行了反转 …
阅读更多...
SAP PI/PO中使用UDF解决按字节拆分字符串的需求

SAP PI/PO中使用UDF解决按字节拆分字符串的需求

需求背景&#xff1a; SAP需要将采购订单信息通过PI发送到SFTP服务器上&#xff0c;生成文件&#xff0c;一般对日项目上文件内容通常都是按照指定的字节数拆分的&#xff0c;而不是字符数&#xff0c;类似下面的格式。 问题点&#xff1a; 如果是使用FTP适配器&#xff0c;则…
阅读更多...
MySQL JDBC编程

MySQL JDBC编程

MySQL JDBC编程 文章目录 MySQL JDBC编程1. 数据库编程的必备条件2. Java的数据库编程&#xff1a;JDBC3. JDBC工作原理4. JDBC使用5. JDBC常用接口和类5.1 JDBC API5.2 数据库连接Connection5.3 Statement对象5.4 ResultSet对象 1. 数据库编程的必备条件 编程语言&#xff1a;…
阅读更多...
[PyTorch][chapter 63][强化学习-时序差分学习]

[PyTorch][chapter 63][强化学习-时序差分学习]

目录&#xff1a; 蒙特卡罗强化学习的问题 基于转移的策略评估 时序差分评估 Sarsa-算法 Q-学习算法 一 蒙特卡罗强化学习的的问题 有模型学习&#xff1a; Bellman 等式 免模型学习: 蒙特卡罗强化学习 迭代&#xff1a; 使用策略 生成一个轨迹&#xff0c; for t…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023