Jedis 與 MySQL的鏈接線程安全問題

Jedis的鏈接是非線程安全的

下面是set命令的執行過程，簡單分爲兩個過程，客戶端向服務端發送數據，服務端向客戶端返回數據，從下面的代碼來看：從創建鏈接到執行命令是沒有進行任何併發同步的控制

public String set(final String key, String value) {
  checkIsInMulti();
  // 執行set命令，實際上是發送set命令和其參數到server端，實際是調用下面的SendCommond(…)方法,發送數據
  client.set(key, value);
  // 等待服務器響應
  return client.getStatusCodeReply();
}

set 命令的數據發送過程

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

private static void sendCommand(final RedisOutputStream os, final byte[] command,
    final byte[]... args) {
  try {
    os.write(ASTERISK_BYTE);
    os.writeIntCrLf(args.length + 1);
    os.write(DOLLAR_BYTE);
    os.writeIntCrLf(command.length);
    os.write(command);
    os.writeCrLf();

    for (final byte[] arg : args) {
      os.write(DOLLAR_BYTE);
      os.writeIntCrLf(arg.length);
      os.write(arg);
      os.writeCrLf();
    }
  } catch (IOException e) {
    throw new JedisConnectionException(e);
  }
}

set命令接收服務端響應過程

private static Object process(final RedisInputStream is) {

  final byte b = is.readByte();
  if (b == PLUS_BYTE) {
    return processStatusCodeReply(is);
  } else if (b == DOLLAR_BYTE) {
    return processBulkReply(is);
  } else if (b == ASTERISK_BYTE) {
    return processMultiBulkReply(is);
  } else if (b == COLON_BYTE) {
    return processInteger(is);
  } else if (b == MINUS_BYTE) {
    processError(is);
    return null;
  } else {
    throw new JedisConnectionException("Unknown reply: " + (char) b);
  }
}

JedisPool是線程安全的

Jedis客戶端支持多線程下併發執行時經過JedisPool實現的，藉助於commong-pool2實現線程池，它會爲每個請求分配一個Jedis鏈接，在請求範圍內使用完畢後記得歸還鏈接到鏈接池中，因此在實際運用中，注意不要把一個Jedis實例在多個線程下併發使用，用完後要記得歸還到鏈接池中

MySQL的鏈接是線程安全的

在一些簡單狀況下，我是不用DataSource的，通常都會採用單例的方式創建MySQL的鏈接，剛開始我也不曉得這樣寫，看別人這樣寫也就跟着這樣寫了，忽然有一天我懷疑這樣的寫發是否可選，一個MySQL的Connection是否在多個線程下併發操做是否安全。

在JDK中定義java.sql.Connection只是一個接口，也並無寫明它的線程安全問題。查閱資料得知，它的線程安全性由對應的驅動實現：

java.sql.Connection is an interface. So, it all depends on the driver's implementation, but in general you should avoid sharing the same connection between different threads and use connection pools. Also it is also advised to have number of connections in the pool higher than number of worker threads.

這是MySQL的驅動實現，能夠看到它在執行時，是採用排它鎖來保證鏈接的在併發環境下的同步。

public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency) throws SQLException {
    // 在使用鏈接過程當中是採用排它鎖的方式
    synchronized(this.getConnectionMutex()) {
        this.checkClosed();
        Object pStmt = null;
        boolean canServerPrepare = true;
        String nativeSql = this.getProcessEscapeCodesForPrepStmts()?this.nativeSQL(sql):sql;
        if(this.useServerPreparedStmts && this.getEmulateUnsupportedPstmts()) {
            canServerPrepare = this.canHandleAsServerPreparedStatement(nativeSql);
        }
     ...
 ...

通常狀況下，爲了提升併發性，建議使用池技術來解決單連接的侷限性，好比經常使用的一些數據源：C3P0等