Java 类redis.clients.jedis.JedisMonitor 实例源码

@Test
public void monitor() {
  new Thread(new Runnable() {
    public void run() {
      try {
        // sleep 100ms to make sure that monitor thread runs first
        Thread.sleep(100);
      } catch (InterruptedException e) {
      }
      Jedis j = new Jedis("localhost");
      j.auth("foobared");
      for (int i = 0; i < 5; i++) {
        j.incr("foobared");
      }
      j.disconnect();
    }
  }).start();

  jedis.monitor(new JedisMonitor() {
    private int count = 0;

    public void onCommand(String command) {
      if (command.contains("INCR")) {
        count++;
      }
      if (count == 5) {
        client.disconnect();
      }
    }
  });
}

@Override
public void monitor(JedisMonitor jedisMonitor) {
  Span span = helper.buildSpan("monitor");
  try {
    super.monitor(jedisMonitor);
  } catch (Exception e) {
    onError(e, span);
    throw e;
  } finally {
    span.finish();
  }
}

@Test
public void monitor() {
  new Thread(new Runnable() {
    @Override
    public void run() {
      try {
        // sleep 100ms to make sure that monitor thread runs first
        Thread.sleep(100);
      } catch (InterruptedException e) {
      }
      Jedis j = new Jedis("localhost");
      j.auth("foobared");
      for (int i = 0; i < 5; i++) {
        j.incr("foobared");
      }
      j.disconnect();
    }
  }).start();

  jedis.monitor(new JedisMonitor() {
    private int count = 0;

    @Override
    public void onCommand(String command) {
      if (command.contains("INCR")) {
        count++;
      }
      if (count == 5) {
        client.disconnect();
      }
    }
  });
}

@Test
public void monitor() {
  new Thread(new Runnable() {
    @Override
    public void run() {
      try {
        // sleep 100ms to make sure that monitor thread runs first
        Thread.sleep(100);
      } catch (InterruptedException e) {
      }
      Jedis j = new Jedis("localhost");
      j.auth("foobared");
      for (int i = 0; i < 5; i++) {
        j.incr("foobared");
      }
      j.disconnect();
    }
  }).start();

  jedis.monitor(new JedisMonitor() {
    private int count = 0;

    @Override
    public void onCommand(String command) {
      if (command.contains("INCR")) {
        count++;
      }
      if (count == 5) {
        client.disconnect();
      }
    }
  });
}

@Override
public void monitor(JedisMonitor jedisMonitor) {
    redis.clients.jedis.Jedis delegate = pool.getResource();
    try {
        delegate.monitor(jedisMonitor);
    } finally {
        pool.returnResource(delegate);
    }
}

private String monitor0(Jedis j, final RedisMonitorHandler handler) {
    JedisMonitor jm = new JedisMonitor() {
        @Override
        public void onCommand(String command) {
            handler.onCommand(command);
        }

    };
    j.monitor(jm);
    return OK;
}

@Override
public void monitor(JedisMonitor jedisMonitor) {
}

@Override public void monitor(JedisMonitor jedisMonitor) {
    throw new FakeJedisNotImplementedException();
}

@Override
public void monitor(JedisMonitor jedisMonitor) {
    super.monitor(jedisMonitor);
}

@Override
public void run() {

    if (log.isDebugEnabled()) log.debug("Starting monitor.");

    try {

        this.getMonitorJedis().monitor(new JedisMonitor() {

            @Override
            public void onCommand(String command) {

                if (log.isDebugEnabled()) log.debug(command);

                JedisMonitorThread.this.logBuffer.append(command + "\n");
            }
        });
    } catch (Exception ex) {

        if (log.isDebugEnabled()) log.debug("Stopping monitor.");
    }
}

/**
 * @param jedisMonitor
 * @see redis.clients.jedis.BinaryJedis#monitor(redis.clients.jedis.JedisMonitor)
 */
public abstract void monitor(JedisMonitor jedisMonitor);