Scala 操作Redis使用连接池工具类RedisUtil

Scala 操作操作Redis使用连接池工具类使用连接池工具类RedisUtil

主要介绍了Scala 操作Redis使用连接池工具类RedisUtil，文中通过示例代码介绍的非常详细，对大家的学习或

者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

本文介绍了Scala 操作Redis，分享给大家，具体如下：

package com.zjw.util

import java.util

import org.apache.commons.pool2.impl.GenericObjectPoolConfig

import org.apache.logging.log4j.scala.Logging

val host = "192.168.100.101"

val port = 6379

val timeout = 1000

RedisUtil.init(host, port, timeout, password, 0)

//RedisUtil.set("Time".getBytes(), "2018-09-03 09:00:00".getBytes())

//val result = RedisUtil.get("Time".getBytes())

//println(new String(result))

//val map = Map("name"-> "zhangsan","age"-> "21", "gender"-> "male", "id"-> "519099386")

//RedisUtil.setCols("hash",map)

// val result = RedisUtil.getCols("hash", Array("name", "age", "xx")).map(x => (x._1, new String(x._2)))

}

def get(key: Array[Byte]): Array[Byte] = {

val jedis = jedisPool.getResource

val result: Array[Byte] = jedis.get(key)

jedis.close()

result

}

def set(key: Array[Byte], value: Array[Byte]): Boolean = {

try {

val jedis = jedisPool.getResource

false

}

}

}

def getCols(key: String,

cols: Array[String] = Array.empty

): Map[String, Array[Byte]] = {

import scala.collection.JavaConverters._

val jedis = jedisPool.getResource

var map = Map.empty[String, Array[Byte]]

} else {

logger.info(s"key: ${key}")

val tmpMap: util.Map[Array[Byte], Array[Byte]] = jedis.hgetAll(key.getBytes())

map = tmpMap.asScala.toMap.map(x => (new String(x._1), x._2))