redis使用Pipeline管道提升写入速度

redis使用Pipeline管道提升写入速度在单实例redis环境，我们可以采用Pipeline的方式写入数据，采用管道的方式将多个key值一起提交，较一个key值提交一次，减少了IO,速度会明显提升,下面是采用管道和不采用管道的方式比较执行10万次的，时间比较。package

com.hxl;import

java.util.LinkedHashSet;import

java.util.Set;import

redis.clients.jedis.BinaryJedis;import

redis.clients.jedis.HostAndPort;import

redis.clients.jedis.Jedis;import

redis.clients.jedis.JedisCluster;import

redis.clients.jedis.JedisPoolConfig;import

redis.clients.jedis.Pipeline;public

class

PipelineTest

{

/**

*

*@paramargs

*/

public

static

void

main(String[]

args)

{

int

count

=

100000;

long

start

=

System.currentTimeMillis();

withoutPipeline(count);

long

end

=

System.currentTimeMillis();

System.out.println("withoutPipeline:"

+

(end

-

start));

start

=

System.currentTimeMillis();

usePipeline(count);

end

=

System.currentTimeMillis();

System.out.println("usePipeline:"

+

(end

-

start));

}

private

static

void

withoutPipeline(int

count)

{

JedisPoolConfigpoolConfig

=

new

JedisPoolConfig();

//最大连接数

poolConfig.setMaxTotal(1);

//最大空闲数

poolConfig.setMaxIdle(1);

//最大允许等待时间，如果超过这个时间还未获取到连接，则会报JedisException异常：

//Couldnotgetaresourcefromthepool

poolConfig.setMaxWaitMillis(1000);

//Set

nodes=newLinkedHashSet();

//nodes.add(newHostAndPort("1",6379));

//nodes.add(newHostAndPort("1",7379));

//nodes.add(newHostAndPort("2",6379));

//nodes.add(newHostAndPort("2",7379));

//nodes.add(newHostAndPort("3",6379));

//nodes.add(newHostAndPort("3",7379));

//JedisClustercluster=newJedisCluster(nodes,poolConfig);

Jedisjr

=

null;

try

{

jr

=

new

Jedis("1",

8379);

for

(int

i

=

0;

i

<

count;

i++)

{

jr.incr("age1");

}

}

catch

(Exception

e)

{

e.printStackTrace();

}

finally

{

if

(jr

!=

null)

{

jr.disconnect();

}

}

}

private

static

void

usePipeline(int

count)

{

JedisPoolConfigpoolConfig

=

new

JedisPoolConfig();

//最大连接数

poolConfig.setMaxTotal(1);

//最大空闲数

poolConfig.setMaxIdle(1);

//最大允许等待时间，如果超过这个时间还未获取到连接，则会报JedisException异常：www.f-1.cc

//Couldnotgetaresourcefromthepool

poolConfig.setMaxWaitMillis(1000);

Set<HostAndPort>

nodes

=

new

LinkedHashSet<HostAndPort>();

//nodes.add(newHostAndPort("1",6379));

//nodes.add(newHostAndPort("1",7379));

//nodes.add(newHostAndPort("2",6379));

//nodes.add(newHostAndPort("2",7379));

//nodes.add(newHostAndPort("3",6379));

//nodes.add(newHostAndPort("3",7379));

//JedisClustercluster=newJedisCluster(nodes,poolConfig);

Jedisjr

=

null;

try

{

jr

=

new

Jedis("1",8379);

Pipelinepl

=

jr.pipelined();

for

(int

i

=

0;

i

<

count;

i++)

{

pl.incr("age2");

}

pl.sync();

}

catch

(Exception

e)

{