redis - 如何用java实现基于JedisCluster对象的连接池?
伊谢尔伦
伊谢尔伦 2017-04-18 10:05:46
0
1
815
今天做了一个基于redis集群的java小demo,用于从hadoop中读取文件,然后写入redis集群,但是单个JedisCluster连接在生产中不够效率,不知道哪位大神能给点基于JedisCluster的连接池示例?
下面是我的一点代码
`static {
    URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory());
}

public static void main(String[] args) throws Exception {
    writeRedis("hdfs://mycluster/test/test.txt",new int[]{0});
    //writeRedis(initConfig());
}
public static void writeRedis(String inpath, int[] keyIndex) throws Exception {
    InputStream in = new URL(inpath).openStream();// 输入流 ]
    LineIterator br = org.apache.commons.io.IOUtils.lineIterator(in, "utf8");// 指定输入流与字符编码
    JedisCluster cluster = RedisUtils.getClusterConn();
    String[] line = null;
    while (br.hasNext()) {
        String s = br.next();
        line = RedisUtils.split(s);
        String key = "";
        for (int i = 0; i < keyIndex.length; i++) {
            key += line[keyIndex[i]];// TODO:如果有必要,添加分隔符
        }
        cluster.setnx(key, s);
    }
    RedisUtils.clusterClose(cluster);
}`

拜谢!!!

伊谢尔伦
伊谢尔伦

小伙看你根骨奇佳,潜力无限,来学PHP伐。

membalas semua(1)
洪涛

Tetapi gunakan common-pool untuk merangkumnya sendiri

Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan