Scala 连接Redis工具类

Scala使用工厂模式返回操作Redis集群的工具类

package come.gome.data.utilsimport redis.clients.jedis.{HostAndPort, JedisCluster, JedisPool, JedisPoolConfig}import scala.collection.JavaConverters.setAsJavaSetConverter/*** @author lgy* @note redis工具类*/
object JedisUtils {var jedis:JedisUtils = _val REDIS_MAX_TOTAL = "100"val REDIS_MAX_IDLE = "8"val REDIS_WAIT_MILLIS = "10000"val REDIS_HOST = ""//工厂模式def apply(): JedisUtils = {if (jedis == null){jedis = new JedisUtils()jedis.init()}jedis}}class JedisUtils{var pool: JedisPool = _var config: JedisPoolConfig = _var hosts: java.util.Set[HostAndPort] = _//初始化def init():Unit = {val redis_conf = Map[String, String]()config = new JedisPoolConfig()//可用连接实例的最大数目,如果赋值为-1表示不限制config.setMaxTotal(JedisUtils.REDIS_MAX_TOTAL.toInt)//控制一个Pool最多有多少个状态为idle(空闲的)jedis实例,默认值8config.setMaxIdle(JedisUtils.REDIS_MAX_IDLE.toInt)//等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时,如果超时直接抛出异常config.setMaxWaitMillis(JedisUtils.REDIS_WAIT_MILLIS.toLong)//在borrow一个jedis实例时,是否提前进行validate操作,如果为true则得到的jedis实例均是可用的config.setTestOnBorrow(false)//设置为true,归还连接时,会进行检查,检查不通过,销毁config.setTestOnReturn(false)clusterInit(JedisUtils.REDIS_HOST)}def clusterInit(redis_conf: String):Unit = {hosts = redis_conf.split(",").map(s => HostAndPort.parseString(s)).toSet.asJava}//返回jedis集群连接def getJedisCluster:JedisCluster = {new JedisCluster(hosts,config)}//关闭连接def close(jedis: JedisCluster):Unit = {getJedisCluster.close()}}

Scala 连接Redis工具类相关推荐

flink连接redis工具类-简单好用
本文包含redis非集群和集群两种方式有些大佬写的实在太牛,恕我能力不足看不太懂,所以自己尝试了一下非集群方式非集群方式工具类如下: object RedisUtil {private v ...
python oracle 工具类,python连接Oracle工具类
上代码: # -*- coding:utf-8 -*- import cx_Oracle import pandas as pd class ORACLE(object): def __init__( ...
Redis工具类的封装
Redis工具类的封装 <dependency><groupId>redis.clients</groupId><artifactId>jedis< ...
基于jedis的Redis工具类
本文来记录下基于 jedis 的 Redis 工具类文章目录核心代码核心代码以下为核心代码 /*** 基于jedis的redis操作工具类* @author www* @time 2021/8 ...
SpringBoot Redis工具类封装
SpringBoot整合Redis的博客很多,但是很多都不是我想要的结果.因为我只需要整合完成后,可以操作Redis就可以了,并不需要配合缓存相关的注解使用(如@Cacheable).看了很多博客后, ...
Springboot集成Redis和Redis工具类
目录 1.导入依赖 2.修改配置文件 3.测试 4.使用redis存入对象 5.redis自定义封装 RedisUtils工具类 1.导入依赖 <dependency><groupI ...
java实现redis工具类及其调用
网上很多redis工具类需要配套ssm,spring等,这是一套可以直接用的redis取参数的工具类(String类型) 一.jedis-2.1.0.jar下载,放到项目的lib下网盘地址(4tn5 ...
Java开发中的工具类——基于JedisPool的Redis工具类
目录一.Maven依赖二.Redis配置类三.使用@Cacheable注解进行数据缓存四.自定义Redis工具类及使用 4.1 序列化工具类 4.2 redis客户端工具类 4.3 redis ...
微服务使用redis操作实例包含redis工具类
1.单机redis使用工具类 application.properties配置内容 #redis配置 #单机模式 #redis数据库索引,默认为0 spring.redis.database=0 #r ...

Scala 连接Redis工具类

Scala 连接Redis工具类相关推荐

最新文章

热门文章