时间:2021-05-20
本文介绍了Scala 操作Redis,分享给大家,具体如下:
package com.zjw.utilimport java.utilimport org.apache.commons.pool2.impl.GenericObjectPoolConfigimport org.apache.logging.log4j.scala.Loggingimport redis.clients.jedis.{Jedis, JedisPool, Response}import redis.clients.util.Poolobject RedisUtil extends Logging { private[this] var jedisPool: Pool[Jedis] = _ def main(args: Array[String]): Unit = { val password = "h-{<Fc!yJL87_Zkc8S" 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))) // logger.info(result) val result = RedisUtil.bulkGetCols(Array("hash", "ss")) logger.info(s"result: ${result}") } def init(host: String, port: Int, timeout: Int, password: String, database: Int = 0): Unit = { jedisPool = new JedisPool(new GenericObjectPoolConfig, host, port, timeout, password, database) } 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 jedis.set(key, value) jedis.close() true } catch { case e: Exception => { logger.error(s"写入数据到Redis出错: ${e}") 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]] if (cols.length > 0) { val pipe = jedis.pipelined() val response = pipe.hmget(key.getBytes(), cols.map(_.getBytes()): _*) pipe.sync() map = cols.zip(response.get.asScala).toMap.filter(x => x._2 != null) pipe.close() } 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)) } jedis.close map } def getCols2( key: String, cols: Array[String] = Array.empty ): Map[String, Array[Byte]] = { val jedis = jedisPool.getResource var map = Map.empty[String, Array[Byte]] if (cols.length > 0) { for (col <- cols) { val value: Array[Byte] = jedis.hget(key.getBytes(), col.getBytes()) if (null != value) { map = map + (col -> value) } } } else { logger.info(s"rowkey: ${key}") val tmpMap: util.Map[Array[Byte], Array[Byte]] = jedis.hgetAll(key.getBytes()) import scala.collection.JavaConverters._ map = tmpMap.asScala.toMap.map(x => (new String(x._1), x._2)) } jedis.close map } def bulkGetCols(keys: Array[String], cols: Array[String] = Array.empty ): Map[String, Map[String, Array[Byte]]] = { import scala.collection.JavaConverters._ var result: Map[String, Map[String, Array[Byte]]] = Map.empty val jedis = jedisPool.getResource val pipe = jedis.pipelined if (cols.length > 0) { val data = keys.map(x => { pipe.hmget(x.getBytes(), cols.map(_.getBytes()): _*) }) pipe.sync pipe.close jedis.close result = keys.zip(data.map(_.get().asScala.toArray).map(cols.zip(_).toMap.filter(null != _._2))) .toMap.filter(_._2.nonEmpty) } else { val data: Array[Response[util.Map[Array[Byte], Array[Byte]]]] = keys.map(x => { pipe.hgetAll(x.getBytes()) }) pipe.sync pipe.close jedis.close result = keys.zip(data.map(_.get().asScala.map(x => (new String(x._1), x._2)).toMap)) .toMap.filter(_._2.nonEmpty) } result } def bulkGetCols2(rowkeys: Array[String], cols: Array[String] = Array.empty ): Map[String, Map[String, Array[Byte]]] = { val jedis = jedisPool.getResource var map = Map.empty[String, Map[String, Array[Byte]]] import scala.collection.JavaConverters._ for (rowkey <- rowkeys) { var cellMap = Map.empty[String, Array[Byte]] if (cols.length > 0) { for (col <- cols) { val value = jedis.hget(rowkey.getBytes(), col.getBytes()) if (null != value) { cellMap = cellMap + (col -> value) } } } else { logger.info(s"rowkey: ${rowkey}") val tmpMap = jedis.hgetAll(rowkey.getBytes()) cellMap = tmpMap.asScala.toMap.map(x => (new String(x._1), x._2)) } if (cellMap.nonEmpty) { map = map + (rowkey -> cellMap) } } jedis.close map } def setCols( key: String, fieldValues: Map[String, String] ): Unit = { import scala.collection.JavaConverters._ val data = fieldValues.map(element => { (element._1.getBytes(), element._2.getBytes()) }).asJava val jedis = jedisPool.getResource jedis.hmset(key.getBytes(), data) jedis.close() }}以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
jedis是redis的java客户端,spring将redis连接池作为一个bean配置。redis连接池分为两种,一种是“redis.clients.jed
使用Java操作Redis需要jedis-2.1.0.jar,下载地址:jedis-2.1.0.jar如果需要使用Redis连接池的话,还需commons-po
本文实例讲述了python实现与redis交互操作。分享给大家供大家参考,具体如下:相关内容:redis模块的使用安装模块导入模块连接方式连接池操作设置值获取值
简介在springboot使用搭建好的redis集群添加redis和连接池依赖org.apache.commonscommons-pool2org.spring
在开发中中我们经常会使用到数据库连接池,比如dbcp数据库连接池,本章将讲解java连接dbcp数据库库连接池的简单使用。开发工具myeclipse20141、