Jedis作為Redis  Java語言推薦的客戶端被廣泛使用。讓我們一探Jedis原始碼究竟。

我們以如下程式碼來DEBUG觀察Jedis原始碼：

		 //建立Redis客戶端
		 Jedis jedis = new Jedis();
		 //呼叫set 命令,返回狀態標記
		 String code=jedis.set("s", "s");
		 System.out.println("code="+code);
		 //呼叫get命令
		 String s =jedis.get("s");
		 System.out.println("s="+s);

第一部分：Jedis物件的建立
Jedis jedis=new Jedis();主要是建立連結Redis伺服器的客戶端。

在Jedis(BinaryJedis)基類中主要有Connection物件。在建立Jedis物件的時候,其實尚未連結到Redis伺服器。

在Connection類中,主要設定了連結Redis所使用socket的引數以及操作socket所使用的工具。

//Jedis客戶端連結,使用原始socket進行連結
public class Connection implements Closeable 
{
  
  private static final byte[][] EMPTY_ARGS = new byte[0][];
  //預設主機
  private String host = Protocol.DEFAULT_HOST;
  //預設埠
  private int port = Protocol.DEFAULT_PORT;
  //原始socket
  private Socket socket;
  //輸入輸出流
  private RedisOutputStream outputStream;
  private RedisInputStream inputStream;
  private int connectionTimeout = Protocol.DEFAULT_TIMEOUT;
  private int soTimeout = Protocol.DEFAULT_TIMEOUT;
  private boolean broken = false;

  public Connection() {
  }
}
 

由Connection的成員變數中可以看出來。Jedis使用了元素的JDK IO  Socket來處理網路通訊的。

到此,Jedis 物件就建立處理啦。

2-Jedis連結Redis伺服器過程。

在呼叫 String code=jedis.set("s", "s"); 命令的時候,才是真正建立連結的過程。

Client(BinaryClient).set(byte[], byte[])   方法引數就是把由String 字串轉換成位元組數值。

並呼叫Client(Connection).sendCommand(ProtocolCommand, byte[]...) 方法來發送Redis命令。

  //每次傳送命令前都判斷是否連結,如果連結埠並且連結不上，則丟擲異常
  protected Connection sendCommand(final ProtocolCommand cmd, final byte[]... args) {
    try {
      connect();//每次傳送Redis命令都會呼叫Connect()方法來連結Redis遠端伺服器
      Protocol.sendCommand(outputStream, cmd, args); //操作socket 的輸出流來發送命令
      return this;
    } catch (JedisConnectionException ex) {
      /*
       * When client send request which formed by invalid protocol, Redis send back error message
       * before close connection. We try to read it to provide reason of failure.
       */
      try {
        String errorMessage = Protocol.readErrorLineIfPossible(inputStream);
        if (errorMessage != null && errorMessage.length() > 0) {
          ex = new JedisConnectionException(errorMessage, ex.getCause());
        }
      } catch (Exception e) {
        /*
         * Catch any IOException or JedisConnectionException occurred from InputStream#read and just
         * ignore. This approach is safe because reading error message is optional and connection
         * will eventually be closed.
         */
      }
      // Any other exceptions related to connection?
      broken = true;
      throw ex;
    }
  }

每次呼叫sendCommand傳送命令時候，都會呼叫Connnect()方法嘗試連結遠端埠。

  //在傳送命令之前連線redis伺服器
  public void connect() {
    if (!isConnected()) {
      try {
    	//建立新socket  
        socket = new Socket();
        //設定socket引數
        socket.setReuseAddress(true);
        socket.setKeepAlive(true); // Will monitor the TCP connection is
        // valid
        socket.setTcpNoDelay(true); // Socket buffer Whetherclosed, to
        // ensure timely delivery of data
        socket.setSoLinger(true, 0); // Control calls close () method,
        // the underlying socket is closed
        // immediately
        // <[email protected]_add
        //設定連結超時時間
        socket.connect(new InetSocketAddress(host, port), connectionTimeout);
        //設定讀取超時時間
        socket.setSoTimeout(soTimeout);
        //獲取socket原始輸入輸出流
        outputStream = new RedisOutputStream(socket.getOutputStream());
        inputStream = new RedisInputStream(socket.getInputStream());
      } catch (IOException ex) {
        broken = true;
        throw new JedisConnectionException(ex);
      }
    }
  }

每次連結到遠端Redis伺服器後，第一個命令就是傳送金鑰命令。

  @Override
  public void connect() {
    if (!isConnected()) {
      super.connect();
      if (password != null) {
        auth(password);
        getStatusCodeReply();
      }
      if (db > 0) {
        select(Long.valueOf(db).intValue());
        getStatusCodeReply();
      }
    }
  }

在每次傳送一個命令後,都會去獲取返回碼。

  /**  對於Value值存在最大範圍上線。
   * 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
   */
  @Override
  public String set(final String key, String value) {
    checkIsInMultiOrPipeline();
    client.set(key, value);
    return client.getStatusCodeReply();
  }

在獲取狀態碼時，每次都去重新整理通道。

  public String getStatusCodeReply() {
    flush();
    final byte[] resp = (byte[]) readProtocolWithCheckingBroken();
    if (null == resp) {
      return null;
    } else {
      return SafeEncoder.encode(resp);
    }
  }

讀取資料流最終通過SocketInputStream 類來讀取。

以上就涉及到Jedis傳送Redis和接受Redis命令的過程。