程序包 com.sie.mbm.mom.framework.sequence.range.impl.redis

类 RedisSeqRangeMgr

java.lang.Object
com.sie.mbm.mom.framework.sequence.range.impl.redis.RedisSeqRangeMgr
所有已实现的接口:
SeqRangeMgr
public class RedisSeqRangeMgr extends Object implements SeqRangeMgr
Redis区间管理器

  • 字段详细资料

    • KEY_PREFIX

      private static final String KEY_PREFIX
      前缀防止key重复
      另请参阅:

    • jedis

      private redis.clients.jedis.Jedis jedis
      redis客户端

    • ip

      private String ip
      IP

    • port

      private Integer port
      PORT

    • auth

      private String auth
      验证权限

    • step

      private int step
      区间步长

    • stepStart

      private long stepStart
      区间起始位置，真实从stepStart+1开始

    • keyAlreadyExist

      private volatile boolean keyAlreadyExist
      标记业务key是否存在，如果false，在取nextRange时，会取check一把 这个boolean只为提高性能，不用每次都取redis check

  • 构造器详细资料

    • RedisSeqRangeMgr

      public RedisSeqRangeMgr()

  • 方法详细资料

    • nextRange

      public SeqRange nextRange(String name) throws SeqException
      从接口复制的说明: SeqRangeMgr
      获取指定区间名的下一个区间
      指定者:
      nextRange 在接口中 SeqRangeMgr
      参数:
      name - 区间名
      返回:
      返回区间
      抛出:
      SeqException - 异常

    • init

      public void init()
      从接口复制的说明: SeqRangeMgr
      初始化
      指定者:
      init 在接口中 SeqRangeMgr

    • checkParam

      private void checkParam()

    • getRealKey

      private String getRealKey(String name)

    • isEmpty

      private boolean isEmpty(String str)

    • getIp

      public String getIp()

    • setIp

      public void setIp(String ip)

    • getPort

      public int getPort()

    • setPort

      public void setPort(int port)

    • getStep

      public int getStep()

    • setStep

      public void setStep(int step)

    • getAuth

      public String getAuth()

    • setAuth

      public void setAuth(String auth)

    • getStepStart

      public long getStepStart()

    • setStepStart

      public void setStepStart(long stepStart)