Redis之JedisConnectionFactory經過哨兵發現master

    JedisConnectionFactory中配置了哨兵後，會自動發現master節點，它是怎麼作到的呢?

    注：Spring-data-redis的版本: 1.8.7.RELEASE，Jedis的版本: 2.9.0.RELEASE

1.xml配置

    List-1 properties文件省略了

<bean class="redis.clients.jedis.JedisPoolConfig" id="jedisPoolConfig">
    <property name="maxTotal" value="${redis.maxTotal}"/>
    <property name="maxIdle" value="${redis.maxIdle}"/>
    <property name="numTestsPerEvictionRun" value="${redis.numTestsPerEvictionRun}"/>
    <property name="timeBetweenEvictionRunsMillis" value="${redis.timeBetweenEvictionRunsMillis}"/>
    <property name="minEvictableIdleTimeMillis" value="${redis.minEvictableIdleTimeMillis}"/>
    <property name="softMinEvictableIdleTimeMillis"
              value="${redis.softMinEvictableIdleTimeMillis}"/>
    <property name="testOnReturn" value="${redis.testOnReturn}"/>
    <property name="maxWaitMillis" value="${redis.maxWaitMillis}"/>
    <property name="testOnBorrow" value="${redis.testOnBorrow}"/>
</bean>
<!-- redis集羣配置 哨兵模式 -->
<bean class="org.springframework.data.redis.connection.RedisSentinelConfiguration" id="sentinelConfiguration">
    <property name="master">
        <bean class="org.springframework.data.redis.connection.RedisNode">
            <property name="name" value="${redis.master}"/>
        </bean>
    </property>
    <property name="sentinels">
        <set>
            <bean class="org.springframework.data.redis.connection.RedisNode">
                <constructor-arg name="host" value="${redis.sentinel.host1}"/>
                <constructor-arg name="port" value="${redis.sentinel.port1}"/>
            </bean>
            <bean class="org.springframework.data.redis.connection.RedisNode">
                <constructor-arg name="host" value="${redis.sentinel.host2}"/>
                <constructor-arg name="port" value="${redis.sentinel.port2}"/>
            </bean>
            <bean class="org.springframework.data.redis.connection.RedisNode">
                <constructor-arg name="host" value="${redis.sentinel.host3}"/>
                <constructor-arg name="port" value="${redis.sentinel.port3}"/>
            </bean>
        </set>
    </property>
</bean>
<bean id="redisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
    <constructor-arg name="sentinelConfig" ref="sentinelConfiguration"/>
    <constructor-arg name="poolConfig" ref="jedisPoolConfig"/>
    <property name="database" value="${redis.dbIndex}"/>
</bean>

    這樣咱們就在JedisConnectionFactory中配置了pool和哨兵信息。

2.分析JedisConnectionFactory

    看以下圖1所示：

                         

                                                           圖1 JedisConnectionFactory的繼承圖

    若是瞭解過SpringIOC的，那麼看到InitializingBean，應該知道JedisConnectionFactory爲何繼承它了。看以下圖2所示

                    

                                                     圖2 JedisConnectionFactory的afterPropertiesSet時序圖

        重點在步驟12中，MasterListener繼承了Thread，它是個單獨的線程，經過Jedis監聽Redis的哨兵，若是收到master改變的消息，那麼會修改JedisFactory。以下圖3所示是MasterListener收到master節點變化的消息： 

       

     

                                                    圖3 MasterListener收到master改變的消息

    圖3中，message的內容表示，以前6482端口的redis是master，如今6483端口的纔是master。

    收到master改變的消息後，會修改JedisFactory，進而會影響connection的獲取。值得注意的是，鏈接池底層上使用的是apache的common-pool的org.apache.commons.pool2.impl.GenericObjectPool，有興趣的讀者能夠去看下common-pool的實現，我在這裏就再也不深刻common-pool的實現。提示: dbcp鏈接池使用的也是common-pool，若是你理解了common-pool的實現，那麼會明白鏈接池的不少參數是什麼意思(好比maxActive、maxIdle等)。