Redis开发与运维笔记_客户端

Redis开发与运维笔记_客户端

参考书籍：Redis开发与运维[1]

客户端

客户端通信协议

Redis的通信协议是在TCP协议之上构建的。Redis定制了RESP(Redis Serialization Protocol,Redis序列化协议)实现客户端与服务端的正常交互。

发送命令格式

*<参数数量> CRLF$<参数1的字节数量> CRLF<参数1> CRLF...$<参数N的字节数量> CRLF<参数N> CRLF

•以set hello world为例，命令为*3\r\n$3\r\nSET\r\n$5\r\nhello\r\n$5\r\nworld\r\n

返回结果格式

•状态回复：在RESP中第一个字节是"+"•错误回复："-"•整数回复：":"•字符串回复："$"•多条字符串回复："*"

Redis-cli只能看到最终结果，想要看到Redis的真正返回结果可以使用telnet、nc、甚至使用Socket程序进行模拟。当结果中包含不存在的值(nil)，返回$-1。

Java客户端Jedis

获取Jedis

使用maven,gradle等将Redis坐标加入依赖中。

redis.clients jedis 3.5.1

Jedis的基本使用方法

Jedis jedis = new Jedis("127.0.0.1", 6379);jedis.set("hello", "world");String value = jedis.get("hello");

Jedis初始化需要两个参数，除此之外，包含四个参数的构造函数也比较常用。

/** * host: 主机地址 * port: 主机IP * connectionTimeout: 客户端连接超时 * soTimeout: 客户端读写超时 */Jedis(final String host, final int port, final int connectionTimeout, final int soTimeout)

除了使用传统的String类型，Jedis还提供了基于字节数组的操作。可以使用序列化工具将Java对象进行序列化保存到Redis中，读取后再反序列化为对应对象。

Jedis连接池的使用方法

连接池的优缺点不再赘述，主要是提高复用性，节省每次进行连接及创建对象的开销。Jedis提供了JedisPool这个类作为Jedis的连接池对象，使用Apache的通用池对象工具common-pool作为资源的管理工具。

// common-pool连接池配置，这里使用默认配置，后面小节会介绍具体配置说明 GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig(); // 初始化Jedis连接池JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379);Jedis jedis = null;try{ jedis = jedisPool.getResource(); jedis.get("hello");}catch(Exception e){ logger.error(e.getMessage(),e);}finally{ if(jedis!=null){ jedis.close(); }}

Jedis中Pipeline的使用方法

•利用jedis对象生成一个pipeline对象，jedis.pipelined()•使用pipeline对象进行jedis操作，此时的命令不会真正执行•使用pipeline.sync()完成此次pipeline对象的调用

public void mdel(List keys){ Jedis jedis = new Jedis("127.0.0.1", 6379); Pipeline pipeline = jedis.pipelined(); for(String key : keys){ pipeline.del(key); } pipeline.sync();}

•除了pipeline.sync()，还可以使用List