Scala编写JedisPoolUtils工具类

女爷i 2022-01-07 02:45 281阅读 0赞

package com.cloudera.utils
    
    import redis.clients.jedis.{Jedis, JedisPool, JedisPoolConfig}
    
    object JedisPoolUtils extends Serializable {
    
      @transient private var pool: JedisPool = null
    
      def makePool(redisHost: String, redisPort: Int, redisTimeout: Int, maxTotal: Int, maxIdle: Int, minIdle: Int): Unit = {
        makePool(redisHost, redisPort, redisTimeout, maxTotal, maxIdle, minIdle, true, false, 10000)
      }
    
      def makePool(redisHost: String, redisPort: Int, redisTimeout: Int, maxTotal: Int, maxIdle: Int, minIdle: Int, testOnBorrow: Boolean, testOnReturn: Boolean, maxWaitMillis: Long): Unit = {
        if (pool == null) {
          val poolConfig = new JedisPoolConfig()
          poolConfig.setMaxTotal(maxTotal)
          poolConfig.setMaxIdle(maxIdle)
          poolConfig.setMinIdle(minIdle)
          poolConfig.setTestOnBorrow(testOnBorrow)
          poolConfig.setTestOnReturn(testOnReturn)
          poolConfig.setMaxWaitMillis(maxWaitMillis)
          pool = new JedisPool(poolConfig, redisHost, redisPort, redisTimeout)
    
          val hook = new Thread {
            override def run = pool.destroy()
          }
          sys.addShutdownHook(hook.run)
        }
      }
    
      def getPool: JedisPool = {
        assert(pool != null)
        pool
      }

发表评论取消回复

表情：

评论列表（有 0 条评论，281人围观）

还没有评论，来说两句吧...

相关阅读

相关 jedis连接池工具类JedisPoolUtils

package cn.gpxxg.jedis.util; import redis.clients.jedis.Jedis; import r

r囧r小猫/ 2023年01月03日 02:00/ 0 赞/ 202 阅读

相关 IEDA编写Scala代码

一、IDEA环境创建 Scala环境准备详见：[https://blog.csdn.net/weixin\_42796403/article/details/111122

Dear 丶/ 2022年12月28日 01:36/ 0 赞/ 229 阅读

相关 Kafka工具类（Scala）

1、配置文件config.properties Kafka配置 kafka.broker.list = hadoop300:9092,hadoop301

川长思鸟来/ 2022年12月01日 15:47/ 0 赞/ 161 阅读

相关常用工具类（使用scala编写）

常用工具类（使用scala编写） 1.获取配置文件属性 package com.saprkstreaming.exec.util impo

朱雀/ 2022年10月24日 13:28/ 0 赞/ 261 阅读

相关 4、相关工具类的编写

![这里写图片描述][70] `Const` ： package com.mmall.common; public class Const {

缺乏、安全感/ 2022年05月14日 13:29/ 0 赞/ 201 阅读

相关编写Druid连接池工具类

/ 1. 声明静态数据源/连接池成员变量 2. 创建连接池对象 3. 定义得到数据源/连接池的方法 4. 定义得到连接对象的方法 5. 定义关闭资源的方法 /

旧城等待，/ 2022年02月23日 02:18/ 0 赞/ 223 阅读

相关自己编写一个JDBC工具类

/ 编写JDBC工具类步骤 1. 将固定字符串定义为常量 2. 在静态代码块中注册驱动 3. 提供一个获取连接的方法static Connection getConne

落日映苍穹つ/ 2022年02月23日 01:44/ 0 赞/ 285 阅读

相关 Scala编写JedisPoolUtils工具类

package com.cloudera.utils import redis.clients.jedis.{Jedis, JedisPool, Je

女爷i/ 2022年01月07日 02:45/ 0 赞/ 282 阅读

相关 Scala Druid连接池工具类

package com.sm.utils import java.sql.{Connection, PreparedStatement, SQLExc

蔚落/ 2021年09月25日 04:14/ 0 赞/ 488 阅读

相关 Scala DateTime工具类

> SimpleDateFormat 线程不安全，使用 joda-time 实现的DateTime工具类 import java.util.Date

梦里梦外;/ 2021年09月24日 12:42/ 0 赞/ 358 阅读