try redis(四) -java 客户端jedis 使用

首页 > 代码库 > try redis(四) -java 客户端jedis 使用

try redis(四) -java 客户端jedis 使用

2024-08-01 04:46:21 223人阅读

不同的计算机语言针对redis,都有自己的客户端。

官网上也列出了客户端的 http://www.redis.io/clients

java客户端如下：

感觉客户端无非也就是做些连接和拼接命令的事情。所以不费心思比较哪个好了，就选第一个吧。一般第一个应该都是不错的。

选择jedis ，发现他的代码是 GitHub 托管的，开源的。地址为 https://github.com/xetorthio/jedis

找到 maven dependency

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.6.0</version>
    <type>jar</type>
    <scope>compile</scope>
</dependency>

将上面这段 xml，拷入 pom.xml 中（maven 依赖）

发现添加了 jedis-2.6.0.jar 和 commons-pool2-2.0.jar 这两个包。一个应该是核心包，一个appache的pool包，我猜是客户端连接池用到了。具体的还得往下走。

到目前为止，准备工作都ok.跑一个简单的例子如下：

Jedis jedis = new Jedis("10.13.145.75",6379); //默认端口6379
		jedis.set("key", "HelloWorld");
		String result = jedis.get("HelloWorld");
		System.out.println(result);

注意，我这里报连接超时。

查了下，发现是redis服务器端防火墙造成的。

service iptables stop

把防火墙关了，再执行下代码。ok.完成了。

代码很简单，直接看下 jedis 的源代码是怎么实现的吧。

当调用 jedis.set("key", "HelloWorld"); 的时候

在Jedis.class 中，调用了String set(final String key, String value)

其中client 是客户端对象

/**
     * Set the string value as value of the key. The string can't be longer than
     * 1073741824 bytes (1 GB).
     * <p>
     * Time complexity: O(1)
     * 
     * @param key
     * @param value
     * @return Status code reply
     */
    public String set(final String key, String value) {
	checkIsInMulti();
	client.set(key, value);
	return client.getStatusCodeReply();
    }

在Client.class中

    public void set(final String key, final String value) {
	set(SafeEncoder.encode(key), SafeEncoder.encode(value));
    }

其中 SafeEncoder.encode（String）是把字符串，安装utf-8字符集，转成 byte[]数组。

然后相当于调用了父类

BinaryClient.class的 public void set(final byte[] key, final byte[] value)

public void set(final byte[] key, final byte[] value) {
	sendCommand(Command.SET, key, value);
    }

Connection.class 中 sendCommand 是所有发送命令的入口。command 是个枚举对象

 protected Connection sendCommand(final Command cmd, final byte[]... args) {
	try {
	    connect();
	    Protocol.sendCommand(outputStream, cmd, args);
	    pipelinedCommands++;
	    return this;
	} catch (JedisConnectionException ex) {
	    // Any other exceptions related to connection?
	    broken = true;
	    throw ex;
	}
    }

connect()方法就是传统的socket连接服务器的代码

Protocol.class

public static void sendCommand(final RedisOutputStream os,
	    final Command command, final byte[]... args) {
	sendCommand(os, command.raw, args);
    }

sendCommand 是所有发送命令的出口.直接给 redis-server 发送命令。说白了就是把 set key HelloWorld 的byte[] 字节发给redis-server了

为了证实自己的猜测，特意抓了个包。