Scala多线程初始化redis集群

偏执的太偏执、 2022-12-05 02:37 89阅读 0赞

话不多说，上代码：

def multiThreadInitialization(): Unit = { 
      var coreSize = Runtime.getRuntime.availableProcessors() + 1;
      var threadPool:ExecutorService = Executors.newFixedThreadPool(coreSize);
      // 这里为了处理JedisConnector初始化时间过长问题
      val jedisCluster = JedisUtils.getJedisConnector();
      val map = jedisCluster.hgetAll("feature_platform_redisConfig")
      var countDownLatch = new CountDownLatch(map.size())
      logger.info("获取集群数据: " + map.toString)
      var startTime = System.currentTimeMillis()
    
      map.asScala.foreach { 
        case (k, v) =>
          threadPool.execute(new Runnable { 
            override def run(): Unit = { 
              val meta = new com.riemann.ai.data.feature.redis.RedisFeatureMeta[java.lang.String] (
                new JedisClusterName(k, v),
                "test{imei}",
                "test{imei}",
                "",
                "test",
                false,
                SerializeType.STRING)
              try { 
                val value = meta.get("0", "0")
                logger.info(s"集群:${k} ${v} 初始化成功:" + value)
              } catch { 
                case e: Exception =>
                  logger.error(e.getMessage)
                  logger.error(s"集群：${k} ${v} 初始化失败！！！")
              } finally { 
                countDownLatch.countDown()
              }
            }
          })
      }
      countDownLatch.await()
      logger.info("集群初始化总耗时: " + (System.currentTimeMillis() - startTime))
    }

发表评论取消回复

表情：

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

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

相关阅读

相关 Redis集群离线安装

近日，由于客户的系统运行环境在一个封闭的网络内，不能与互联网联通，也不能提供yum库，所以运行环境只能采用离线安装的方式，我总结了一下本次的安装经过，希望对需要的人有所帮助。

阳光穿透心脏的1/2处/ 2023年10月04日 21:18/ 0 赞/ 16 阅读

相关 redis集群创建初始化

集群创建完毕之后，需要运行如下命令进行初始化： redis-cli --cluster create 10.233.82.142:6379 10.233.126.176:6

朱雀/ 2023年01月18日 13:20/ 0 赞/ 73 阅读

相关 Redis多机多节点集群实验

目录第一步：环境准备第二步：安装Redis 第三步：修改配置，创建节点第四步：启动两台机器的六个节点第五步：设置防火墙，开放集群端口第六步：创建集群第

本是古典何须时尚/ 2022年12月06日 01:06/ 0 赞/ 169 阅读

相关 Redis多集群客户端

一、pom依赖 <dependency> <groupId>org.springframework.boot</groupId>

你的名字/ 2022年12月05日 10:20/ 0 赞/ 146 阅读

相关 Scala多线程初始化redis集群

话不多说，上代码： def multiThreadInitialization(): Unit = { var coreSize = Runtime.g

偏执的太偏执、/ 2022年12月05日 02:37/ 0 赞/ 90 阅读

相关 Redis集群之多主多从

在上篇中——[Redis集群之哨兵][Redis]中我们使用了哨兵模式来解决主从模式下的弊端，但从架构上来看，哨兵模式其实也是主从模式，因此在业务量暴增的情形下，单一主节点处理

女爷i/ 2022年12月02日 13:58/ 0 赞/ 213 阅读

相关 Scala多线程闭包例子

var time = System.currentTimeMillis() var count = 0; for (i <- (1 to 100000

迈不过友情╰/ 2022年09月30日 09:54/ 0 赞/ 135 阅读

相关 redis集群实现(一)集群架构与初始化

redis是一个高可用、高性能、高可扩展性的基于内存也支持持久化存储的kv存储数据库，redis相比较于之前的kv存储memcached而言，不但支持的value类型大大增加，

红太狼/ 2022年07月15日 00:37/ 0 赞/ 278 阅读

相关集群下的kafka实现多线程消费

https://blog.csdn.net/u011622226/article/details/72500713 上一篇文章讲述了如何部署kafka集群，而这篇文章则

亦凉/ 2022年05月28日 11:51/ 0 赞/ 178 阅读

相关线程初始化

目录 private void init(ThreadGroup g, Runnable target, String name,

淩亂°似流年/ 2022年01月06日 04:33/ 0 赞/ 132 阅读