Hazelcast系列(三):hazelcast集成(服务器/客户端)

2023-10-11 11:52

本文主要是介绍Hazelcast系列(三):hazelcast集成(服务器/客户端),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

系列文章

Hazelcast系列(一):初识hazelcast

Hazelcast系列(二):hazelcast集成(嵌入式)

Hazelcast系列(三):hazelcast集成(服务器/客户端)

Hazelcast系列(四):hazelcast管理中心

Hazelcast系列(五):Auto-Detection发现机制

Hazelcast系列(六):Multicast发现机制

Hazelcast系列(七):TCP-IP发现机制

Hazelcast系列(八):数据结构

目录

        前言

        环境

        服务器

        客户端 

        测试

        其他 

        参考


前言

        前面对通过 Hazelcast系列(二):hazelcast集成(嵌入式)已经对 Hazelcast 如何在 Java 中使用,已经有了初步的认识,接下来,咱们研究一下 Hazelcast 集成的另外一种模式:服务器/客户端

        相较于 嵌入式 的模式,服务器/客户端 模式将 Hazelcast 缓存服务和客户端单独拆分开,方便后期对服务器的单独维护和持续扩展,避免缓存的数据在堆内存中影响到垃圾收集器收集效率和垃圾回收时的应用响应时间。

        当前 Hazelcast 服务器版本:4.2.6,客户端版本:5.1.7

环境

名称版本
hazelcast/management-center 管理中心 5.3.0
hazelcast/hazelcast 服务端4.2.6
springboot2.7.16
hazelcast 客户端5.1.7

服务器

        服务器端通过 Docker 部署,Docker 的安装和配置可以参照俺的 CentOS 7下安装Docker,部署采用版本 hazelcast/hazelcast:4.2.6      

  • 首先拉取 hazelcast 的镜像
docker pull hazelcast/hazelcast:4.2.6
  • 添加一个配置文件 hazelcast.yaml,配置服务器集群中成员的相关参数,然后放在某个目录下,这里为 /home/hazelcast/config
hazelcast:cluster-name: hazelcast-clusterinstance-name: hzInstance_141network:port:auto-increment: trueport-count: 100port: 5701outbound-ports:- 0join:auto-detection:enabled: falsemulticast:enabled: falsemulticast-group: 224.2.2.3multicast-port: 54327tcp-ip:enabled: truemember-list:- 192.168.119.141

   说明: cluster-name 集群名称,通过名称隔离同网络下的集群

               instance-name 服务器节点名称

               network.port.auto-increment 成员节点使用的端口是否允许自动增长

               network.port.port-count 使用端口增长的范围,例如这里:5701-5801

               network.port.port 默认使用的端口,如果 auto-increment 为false,则必须使用 5701

               network.outbound-ports 套接字绑定期间使用的临时端口,可以是值和范围,0为没限制

               network.tcp-ip.enabled 采用 tcp/ip 的方式,前面两个发现方式必须设置为 false

               network.tcp-ip.member-list 集群中能被发现的成员,可以只配置一个,端口可不设置

  • 通过 docker run 命令,启动容器名称为 hazecast-node1 的节点1
docker run -d -p 5701:5701 
-e JAVA_OPTS="-Dhazelcast.config=/opt/hazelcast/config_ext/hazelcast.yaml" 
-e HZ_NETWORK_PUBLICADDRESS=192.168.119.141:5701 
-v /home/hazelcast/config:/opt/hazelcast/config_ext 
--name hazecast-node1 hazelcast/hazelcast:4.2.6

   说明:-e 为添加执行的环境变量

              -e JAVA_OPTS="-Dhazelcast.config=/opt/hazelcast/config_ext/hazelcast.yaml"   添加                         hazecast 的寻找配置路径

              -e HZ_NETWORK_PUBLICADDRESS  添加集群中成员的公共地址,方便私有云映射

              -v  /home/hazelcast/config:/opt/hazelcast/config_ext  挂载本地 hazelcast.yaml 所在配置                     目录到容器中

              --name 容器名称,节点名称

    另外:192.168.119.141 为虚拟机地址,这里看情况配置对外公共地址

  • 接下来,继续通过 docker run 命令,启动容器名称为 hazecast-node2 的节点2
docker run -d -p 5702:5701 
-e JAVA_OPTS="Dhazelcast.config=/opt/hazelcast/config_ext/hazelcast.yaml" 
-e HZ_NETWORK_PUBLICADDRESS=192.168.119.141:5702 
-v /home/hazelcast/config:/opt/hazelcast/config_ext 
--name hazecast-node2 hazelcast/hazelcast:4.2.6

    说明:参数说明参考上面的

              hazecast-node2 和 hazecast-node1 对比,对外端口不同

  • 服务器端这样差不多就启动了,通过搭建管理中心Hazelcast系列(三):hazelcast管理中心,我们可连接到对应集群查看,当然查看本地日志和获取本地集群数也可以确认

客户端 

        客户端配置和前面配置 Hazelcast系列(二):hazelcast集成(嵌入式)大同小异,咱们直接开干。

  • 创建一个SpringBoot项目,先添加依赖,这里额外添加 spring-boot-starter-web 依赖方便测试
      <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>com.hazelcast</groupId><artifactId>hazelcast</artifactId></dependency>
  • 项目 resources 下添加 hazelcast-client.yaml 配置文件,内容如下:
hazelcast-client:cluster-name: hazelcast-clusterinstance-name: hzInstance_clientnetwork:cluster-members:- 192.168.119.141

    说明:cluster-name 要连接的集群名称

               instance-name 客户端节点名称

               network.cluster-members 连接的集群成员,这里可配置一个,但是尽量全部配置

  • 对应的 application.yml,内容如下
server:port: 8082

  • 添加额外的测试代码
@RestController
@RequestMapping("/data")
public class DataController {@Autowiredprivate HazelcastInstance hazelcastInstance;private ConcurrentMap<String,Long> retrieveMap() {return hazelcastInstance.getMap("map");}@PostMapping("/put")public String put(@RequestParam(value = "key") String key, @RequestParam(value = "value") Long value) {retrieveMap().put(key, value);return "成功";}@GetMapping("/get")public Long get(@RequestParam(value = "key") String key) {Long value = retrieveMap().get(key);return value;}
}
  • 接下来,直接启动SpringBoot项目,然后去管理平台查看对应的客户端连接情况(本地查看日志亦可)

测试

        前面在客户端已经连接上了服务器,并且客户端已经有了测试代码,下面,开测。

  • Postman 发送测试数据 key = test,value = 11111

  • Postman 获取数据 key = test

其他 

  1. 服务器端 Docker 启动的时候,-e 添加的 hazelcast 环境变量也可配置在 Hazelcast 中,同理,hazelcast.yaml 的参数也可配置在 -e 环境变量上
  2. 每个版本的 hazelcast.jar 中,都有完整的或者默认的服务器和客户端参数配置

参考

  • Java Client

这篇关于Hazelcast系列(三):hazelcast集成(服务器/客户端)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/187858

相关文章

SpringBoot3应用中集成和使用Spring Retry的实践记录

《SpringBoot3应用中集成和使用SpringRetry的实践记录》SpringRetry为SpringBoot3提供重试机制,支持注解和编程式两种方式,可配置重试策略与监听器,适用于临时性故... 目录1. 简介2. 环境准备3. 使用方式3.1 注解方式 基础使用自定义重试策略失败恢复机制注意事项

MySQL MCP 服务器安装配置最佳实践

《MySQLMCP服务器安装配置最佳实践》本文介绍MySQLMCP服务器的安装配置方法,本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下... 目录mysql MCP 服务器安装配置指南简介功能特点安装方法数据库配置使用MCP Inspector进行调试开发指

在Windows上使用qemu安装ubuntu24.04服务器的详细指南

《在Windows上使用qemu安装ubuntu24.04服务器的详细指南》本文介绍了在Windows上使用QEMU安装Ubuntu24.04的全流程:安装QEMU、准备ISO镜像、创建虚拟磁盘、配置... 目录1. 安装QEMU环境2. 准备Ubuntu 24.04镜像3. 启动QEMU安装Ubuntu4

SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程

《SpringBoot集成LiteFlow实现轻量级工作流引擎的详细过程》LiteFlow是一款专注于逻辑驱动流程编排的轻量级框架,它以组件化方式快速构建和执行业务流程,有效解耦复杂业务逻辑,下面给大... 目录一、基础概念1.1 组件(Component)1.2 规则(Rule)1.3 上下文(Conte

MYSQL查询结果实现发送给客户端

《MYSQL查询结果实现发送给客户端》:本文主要介绍MYSQL查询结果实现发送给客户端方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录mysql取数据和发数据的流程(边读边发)Sending to clientSending DataLRU(Least Rec

Python FastMCP构建MCP服务端与客户端的详细步骤

《PythonFastMCP构建MCP服务端与客户端的详细步骤》MCP(Multi-ClientProtocol)是一种用于构建可扩展服务的通信协议框架,本文将使用FastMCP搭建一个支持St... 目录简介环境准备服务端实现(server.py)客户端实现(client.py)运行效果扩展方向常见问题结

使用vscode搭建pywebview集成vue项目实践

《使用vscode搭建pywebview集成vue项目实践》:本文主要介绍使用vscode搭建pywebview集成vue项目实践,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录环境准备项目源码下载项目说明调试与生成可执行文件核心代码说明总结本节我们使用pythonpywebv

Maven项目中集成数据库文档生成工具的操作步骤

《Maven项目中集成数据库文档生成工具的操作步骤》在Maven项目中,可以通过集成数据库文档生成工具来自动生成数据库文档,本文为大家整理了使用screw-maven-plugin(推荐)的完... 目录1. 添加插件配置到 pom.XML2. 配置数据库信息3. 执行生成命令4. 高级配置选项5. 注意事

Windows Server 2025 搭建NPS-Radius服务器的步骤

《WindowsServer2025搭建NPS-Radius服务器的步骤》本文主要介绍了通过微软的NPS角色实现一个Radius服务器,身份验证和证书使用微软ADCS、ADDS,具有一定的参考价... 目录简介示意图什么是 802.1X?核心作用802.1X的组成角色工作流程简述802.1X常见应用802.

Java集成Onlyoffice的示例代码及场景分析

《Java集成Onlyoffice的示例代码及场景分析》:本文主要介绍Java集成Onlyoffice的示例代码及场景分析,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 需求场景:实现文档的在线编辑,团队协作总结:两个接口 + 前端页面 + 配置项接口1:一个接口,将o