Java Code Examples for redis.clients.jedis.Jedis

超、凢脫俗 2022-08-10 11:57 50阅读 0赞

The following code examples are extracted from open source projects. You can click ![like.png][] to vote up the examples you like. Your votes will be used in an intelligent system to get more and better code examples. Thanks for your votes!

Code Example 1:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *AsyncTaskRep.java*

public Task findTask(final String taskId){
         
      Jedis jedis=jedisPool.getResource();
      try {
         
        Task task=taskDao.findById(taskId,jedis);
        if (task != null) {
         
          task.getJobs().addAll(jobDao.findJobs(taskDao.getTaskJobsEntityKey(task.getIdAsString()),jedis));
        }
        return task;
      }
      finally {
         
        jedisPool.returnResource(jedis);
      }
    }

Code Example 2:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *AsyncTaskRep.java*

public Task findTaskByJobId(final String jobId){
         
      Jedis jedis=jedisPool.getResource();
      try {
         
        Job job=findJob(jobId);
        if (job == null) {
         
          return null;
        }
        return findTask(job.getParentTaskId());
      }
      finally {
         
        jedisPool.returnResource(jedis);
      }
    }

Code Example 3:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *AsyncTaskRep.java*

public Job findJob(final String jobId){
         
      Jedis jedis=jedisPool.getResource();
      try {
         
        return jobDao.findById(jobId,jedis);
      }
      finally {
         
        jedisPool.returnResource(jedis);
      }
    }

Code Example 4:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *CacheEntryRep.java*

public CacheEntry find(final String id){
         
      Jedis jedis=jedisPool.getResource();
      try {
         
        return entryDao.findById(id,jedis);
      }
      finally {
         
        jedisPool.returnResource(jedis);
      }
    }

Code Example 5:

![vote][like.png]

From project *abiquo*, under directory  */vsm/src/main/java/com/abiquo/vsm/migration/*.

Source *Migrator.java*

public void migrateNonPersistedModelFromRedis() throws UnknownHostException, IOException {
         
      RedisDao dao=RedisDaoFactory.getInstance();
      Jedis jedis=new Jedis(host,port);
      jedis.connect();
      jedis.select(database);
      long len=jedis.llen(MachineListKey);
      for (int i=0; i < len; i++) {
         
        insertMachineFromCSVLine(dao,jedis.lindex(MachineListKey,i));
      }
      jedis.del(MachineListKey);
      jedis.disconnect();
    }

Code Example 6:

![vote][like.png]

From project *abiquo*, under directory  */vsm/src/main/java/com/abiquo/vsm/redis/util/*.

Source *RedisUtils.java*

/** 
     * Pings a redis server.
     * @param host The redis host
     * @param port The redis port
     * @return True on successful ping. Otherwise false.
     */
    public static boolean ping(String host,int port){
         
      Jedis client=new Jedis(host,port);
      boolean success=false;
      try {
         
        client.connect();
        success=client.ping().equalsIgnoreCase("pong");
        client.disconnect();
      }
     catch (  IOException e) {
         
        return false;
      }
      return success;
    }

Code Example 7:

![vote][like.png]

From project *abiquo*, under directory  */am/src/main/java/com/abiquo/appliancemanager/web/servlet/*.

Source *CheckServlet.java*

public synchronized boolean checkRedis(){
         
      Jedis redis=null;
      try {
         
        redis=REDIS_POOL.getResource();
        return "PONG".equalsIgnoreCase(redis.ping());
      }
     catch (  final JedisConnectionException e) {
         
        return false;
      }
     finally {
         
        if (redis != null) {
         
          REDIS_POOL.returnResource(redis);
        }
      }
    }

Code Example 8:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *AsyncTaskRep.java*

public Task save(Task task){
         
      Jedis jedis=jedisPool.getResource();
      Transaction transaction=jedis.multi();
      boolean discard=true;
      try {
         
        for (    Job job : task.getJobs()) {
         
          job.setParentTaskId(task.getTaskId());
          jobDao.save(job,transaction);
        }
        taskDao.save(task,transaction);
        transaction.exec();
        discard=false;
      }
      finally {
         
        if (discard) {
         
          transaction.discard();
        }
        jedisPool.returnResource(jedis);
      }
      return task;
    }

Code Example 9:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *AsyncTaskRep.java*

public Job save(Job job){
         
      Jedis jedis=jedisPool.getResource();
      Transaction transaction=jedis.multi();
      boolean discard=true;
      try {
         
        jobDao.save(job,transaction);
        transaction.exec();
        discard=false;
      }
      finally {
         
        if (discard) {
         
          transaction.discard();
        }
        jedisPool.returnResource(jedis);
      }
      return job;
    }

Code Example 10:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *AsyncTaskRep.java*

public void delete(Task task){
         
      Jedis jedis=jedisPool.getResource();
      Transaction transaction=jedis.multi();
      boolean discard=true;
      try {
         
        for (    Job job : task.getJobs()) {
         
          jobDao.delete(job,transaction);
        }
        taskDao.delete(task,transaction);
        transaction.exec();
        discard=false;
      }
      finally {
         
        if (discard) {
         
          transaction.discard();
        }
        jedisPool.returnResource(jedis);
      }
    }

Code Example 11:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *AsyncTaskRep.java*

public List<Task> findTasksByOwnerId(final TaskOwnerType type,final String ownerId){
         
      Jedis jedis=jedisPool.getResource();
      try {
         
        List<Task> tasks=taskDao.findByOwnerId(type,ownerId,jedis);
        for (    Task task : tasks) {
         
          if (task != null) {
         
            task.getJobs().addAll(jobDao.findJobs(taskDao.getTaskJobsEntityKey(task.getIdAsString()),jedis));
          }
        }
        return tasks;
      }
      finally {
         
        jedisPool.returnResource(jedis);
      }
    }

Code Example 12:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *CacheEntryRep.java*

public CacheEntry save(CacheEntry entry){
         
      Jedis jedis=jedisPool.getResource();
      Transaction transaction=jedis.multi();
      boolean discard=true;
      try {
         
        entryDao.save(entry,transaction);
        transaction.exec();
        discard=false;
      }
      finally {
         
        if (discard) {
         
          transaction.discard();
        }
        jedisPool.returnResource(jedis);
      }
      return entry;
    }

Code Example 13:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *CacheEntryRep.java*

public void delete(CacheEntry entry){
         
      Jedis jedis=jedisPool.getResource();
      Transaction transaction=jedis.multi();
      boolean discard=true;
      try {
         
        entryDao.delete(entry,transaction);
        transaction.exec();
        discard=false;
      }
      finally {
         
        if (discard) {
         
          transaction.discard();
        }
        jedisPool.returnResource(jedis);
      }
    }

Code Example 14:

![vote][like.png]

From project *abiquo*, under directory  */vsm/src/main/java/com/abiquo/vsm/redis/pubsub/*.

Source *RedisSubscriber.java*

/** 
     * Subscribe to redis eventing channel.
     */
    @Override public void run(){
         
      try {
         
        Jedis redis=new Jedis(host,port,0);
        redis.connect();
        running=true;
        RedisSubscriberCallback callback=new RedisSubscriberCallback(host,port);
        redis.subscribe(callback,EventingChannel);
        redis.disconnect();
      }
     catch (  Exception e) {
         
        RedisDaoFactory.refreshConnectionsPool();
        logger.error("Error on redis subscription. {}.",e);
        logger.error("VSM is not able to notify events. Please check redis server at {}:{}.",host,port);
      }
     finally {
         
        running=false;
      }
    }

Code Example 15:

![vote][like.png]

From project *abiquo*, under directory  */vsm/src/test/java/com/abiquo/vsm/migration/*.

Source *MigratorTest.java*

@Test(enabled=false) public void test_NonPersistedMigration() throws UnknownHostException, IOException {
         
      Jedis jedis=new Jedis(TEST_HOST,TEST_PORT);
      jedis.select(TEST_DATABASE);
      jedis.connect();
      jedis.lpush(Migrator.MachineListKey,"10.60.1.74,8889,root,temp0,XEN_3");
      jedis.lpush(Migrator.MachineListKey,"10.60.1.71,443,root,temp1,VMX_04");
      jedis.disconnect();
      new Migrator(TEST_HOST,TEST_PORT,TEST_DATABASE).migrateNonPersistedModelFromRedis();
      jedis.connect();
      jedis.select(TEST_DATABASE);
      assertFalse(jedis.exists(Migrator.MachineListKey));
      jedis.disconnect();
      RedisTestDaoFactory.selectDatabase(TEST_HOST,TEST_PORT,TEST_DATABASE);
      assertEquals(dao.findAllPhysicalMachines().size(),2);
      PhysicalMachine machine0=dao.findPhysicalMachineByAddress("http://10.60.1.74:8889/");
      PhysicalMachine machine1=dao.findPhysicalMachineByAddress("http://10.60.1.71:443/");
      assertNotNull(machine0);
      assertNotNull(machine1);
      assertEquals(machine0.getAddress(),"http://10.60.1.74:8889/");
      assertEquals(machine0.getType(),"XEN_3");
      assertEquals(machine0.getUsername(),"root");
      assertEquals(machine0.getPassword(),"temp0");
      assertEquals(machine1.getAddress(),"http://10.60.1.71:443/");
      assertEquals(machine1.getType(),"VMX_04");
      assertEquals(machine1.getUsername(),"root");
      assertEquals(machine1.getPassword(),"temp1");
    }

Code Example 16:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *CacheEntryDAO.java*

public CacheEntry findById(final String id,Jedis jedis){
         
      String key=getEntityKey(CacheEntry.class,id);
      CacheEntry entry=null;
      if (jedis.exists(key)) {
         
        entry=new CacheEntry(id);
        entry.getValues().addAll(jedis.lrange(key,0,-1));
      }
      return entry;
    }

Code Example 17:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *JobDAO.java*

public List<Job> findJobs(final String jobsKey,Jedis jedis){
         
      List<Job> jobs=new LinkedList<Job>();
      for (  String jobKey : jedis.lrange(jobsKey,0,-1)) {
         
        Job job=find(jobKey,jedis);
        if (job != null) {
         
          jobs.add(job);
        }
      }
      return jobs;
    }

Code Example 18:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *JobDAO.java*

protected Job find(final String jobKey,Jedis jedis){
         
      Map<String,String> hashed=jedis.hgetAll(jobKey);
      if (hashed.isEmpty()) {
         
        return null;
      }
      Job job=new Job();
      job.setId(hashed.get("id"));
      job.setType(JobType.valueOf(hashed.get("type")));
      job.setState(JobState.valueOf(hashed.get("state")));
      job.setRollbackState(JobState.valueOf(hashed.get("rollbackState")));
      job.setDescription(hashed.get("description"));
      job.setTimestamp(Long.parseLong(hashed.get("timestamp")));
      job.setParentTaskId(hashed.get("parentTaskId"));
      Map<String,String> data=jedis.hgetAll(getJobDataKey(job.getIdAsString()));
      if (data != null && !data.isEmpty()) {
         
        job.getData().putAll(data);
      }
      return job;
    }

Code Example 19:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *TaskDAO.java*

public List<Task> findByOwnerId(final TaskOwnerType type,final String ownerId,Jedis jedis){
         
      List<Task> tasks=new ArrayList<Task>();
      String ownerKey=getOwnerTaskEntityKey(type,ownerId);
      for (  String taskKey : jedis.lrange(ownerKey,0,-1)) {
         
        Task task=find(taskKey,jedis);
        if (task != null) {
         
          tasks.add(task);
        }
      }
      return tasks;
    }

Code Example 20:

![vote][like.png]

From project *abiquo*, under directory  */model/src/main/java/com/abiquo/server/core/task/*.

Source *TaskDAO.java*

protected Task find(final String taskKey,Jedis jedis){
         
      Map<String,String> hashed=jedis.hgetAll(taskKey);
      if (hashed.isEmpty()) {
         
        return null;
      }
      Task task=new Task();
      task.setOwnerId(hashed.get("ownerId"));
      task.setTaskId(hashed.get("taskId"));
      task.setUserId(hashed.get("userId"));
      task.setType(TaskType.valueOf(hashed.get("type")));
      task.setState(TaskState.valueOf(hashed.get("state")));
      task.setTimestamp(Long.parseLong(hashed.get("timestamp")));
      return task;
    }

[like.png]: http://www.programcreek.com/java-api-examples/includes/images/like.png