一、Jedis基本用法

1、访问流程

连接池建立-〉访问密码设置-〉连接超时等参数设置

2、在pom文件引入相关依赖:

		<dependency>
			<groupId>redis.clients</groupId>
			<artifactId>jedis</artifactId>
			<version>2.9.0</version>
		</dependency>

二、使用方式

1、Jedis直接连接redis如下:

redis系列十一:redis客户端细解

2、使用连接池方式

redis系列十一:redis客户端细解
生产环境一般使用连接池进行操作,jedis连接redis对象放在连接池里,每次用的时候去POOL借用,用完后归还。

3、连接池代码

redis系列十一:redis客户端细解

三、redis简单使用实例

1、生产者

package com.james.redis.queue1;

import com.james.redis.utils.JedisUtils;

public class RedisProducer {  
  
    /**  
     * jedis操作List  
     */    
    public static void main(String[] args){  
  
        JedisUtils jedis = new JedisUtils("192.168.1.111", 6379,"12345678");   
        for(int i = 0;i<10;i++) {  
            jedis.lpush("informList","orderIdadb_" + i);    
        }  
    }  
  
} 

2、消费者

package com.james.redis.queue1;

public class RedisConsumer {  
  
    /**  
     * jedis操作List  
     */    
    public static void main(String[] args){  
  
       ScheduleMQ mq = new ScheduleMQ();  
       mq.start();  
    }     
  
} 
package com.james.redis.queue1;

import java.util.List;

import com.james.redis.utils.JedisUtils;

class ScheduleMQ extends Thread {  
    JedisUtils jedis = new JedisUtils("192.168.1.111", 6379,"12345678");   
  
    @Override  
    public void run() {  
        while(true) {  
            //阻塞式brpop,List中无数据时阻塞  
            //参数0表示一直阻塞下去,直到List出现数据  
            List<String> list = jedis.brpop(0, "informList");  
            for(String s : list) {  
            	//处理业务逻辑
                System.out.println(s);  
            }  
  
        }  
    }  
}  

补充:JedisUtils和剩余的配置等内容可以到此下载:redis简单使用实例

相关文章:

  • 2022-12-23
  • 2022-03-07
  • 2021-11-20
  • 2022-02-19
  • 2022-12-23
  • 2021-12-02
  • 2021-07-16
猜你喜欢
  • 2022-03-08
  • 2021-05-25
  • 2021-05-31
  • 2021-05-28
  • 2021-04-25
相关资源
相似解决方案