189 8069 5689
本篇内容主要讲解“redis的介绍及应用”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Redis的介绍及应用”吧!
成都创新互联专注于云和企业网站建设,响应式网站,商城网站建设。云和网站建设公司,为云和等地区提供建站服务。全流程按需网站策划，专业设计，全程项目跟踪，成都创新互联专业和态度为您提供的服务
官网下不了，这里找了这个地址，版本比较老
下载驱动,搜索jedis
参考
基本操作
public class RedisTest {
public static void main(String[] args) {
/**
* 地址 端口 超时时间
*/
Jedis jedis = new Jedis("localhost", 6379, 100000);
/**
* 测试是否通
*/
System.out.println("服务正在运行: "+jedis.ping());
/**
* set：设置key值
* get：获取key值
* del：删除key
* append：追加key值
* incr：key值自增1
* incrBy：key值自增，指定步长
* decr：key值自减1
* decrBy：key值自减，指定步长
* expire：为key设置过期时间（秒数）
* setex：设置key值，可指定存活时间（秒数）
* setnx：设置key值。key不存在才会设置，如果key存在则回滚操作，结果返回0，表示没有设置成功
* ttl：time to live，获取key的存活时间（秒），-1表示永不过期
* persist：去掉key的expire设置，不再有失效时间
*/
jedis.set("first", "Hello World!");
System.out.println(jedis.get("first"));
/**
* LIST
* 可以实现队列的功能
* lpush: 从列表头部插入多个元素
* rpush：从列表尾部插入多个元素
* llen：返回列表中的元素的数量
* lpop：从列表头部移除并返回list的第一个元素
* lrem：从头部开始找，删除n个值
* lrange：从列表中获取指定范围的子集
*/
jedis.del("list");
jedis.lpush("list", "1","2","3");
jedis.lpush("list", "4");
Long count=jedis.llen("list");
List list=jedis.lrange("list", 0, count);
System.out.println(list.toString());
/**
* sadd：往set对象中添加一个值
* smembers：取得set中所有的值
* sismember：判断一个值是否在set中存在
* srandmember：从set中随机取得一个值
* srem：从set中删除一个值
* scard：返回set的item个数
*/
jedis.del("set");
jedis.sadd("set", "1","2","3");
jedis.sadd("set", "4");
jedis.sadd("set", "4");
Set set=jedis.smembers("set");
System.out.println(set.toString());
/**
* hmset：设置key值，值类型为map对象
* type：返回key值的类型，可能值有none, string, hash, set, list, zset
* hkeys：获取所有key
* hvals：获取所有key对应的值
* hmget：一次性获取多个field的值
* hexists：判断field是否存在
* hset：设置field的值
* hgetAll：获取全部内容
* hget：获取field的值
* hdel：删除field
* hincrBy：field值自增1
* hlen：计算field的数目
* hsetnx：设置key值。field不存在才会设置，如果field存在则回滚操作，结果返回0，表示没有设置成功。可以用来实现分布式锁
*/
jedis.del("user");
Map map = new HashMap();
map.put("name", "cjm");
map.put("age", "33");
map.put("qq", "123456");
jedis.hmset("user", map);
System.out.println("type: " + jedis.type("user"));
System.out.println("hkeys: " + jedis.hkeys("user"));
System.out.println("hvals: " + jedis.hvals("user"));
System.out.println("hmget: " + jedis.hmget("user", "name", "age"));
System.out.println("hexists: " + jedis.hexists("user", "name"));
jedis.hset("user", "pwd", "123");
System.out.println("hgetAll: " + jedis.hgetAll("user"));
System.out.println("hget: " + jedis.hget("user", "pwd"));
jedis.hdel("user", "qq");
System.out.println("hincrBy: " + jedis.hincrBy("user", "count", 1));
System.out.println("hlen: " + jedis.hlen("user"));
Long r = jedis.hsetnx("user", "pwd2", "456");
System.out.println(r);
}
} 消息订阅、
订阅
public class Consumer {
public static void main(String[] args) {
/**
* 地址 端口 超时时间
*/
Jedis jedis = new Jedis("localhost", 6379, 100000);
/**
* 消息订阅
*/
JedisPubSub jps=new JedisPubSub() {
public void onPMessage(String pattern, String channel, String message) {
System.out.println("onPMessage()," + pattern + "=" + channel + "="
+ message);
}
public void onMessage(String channel, String message) {
System.out.println("onMessage()," + channel + "=" + message);
}
};
jedis.psubscribe(jps, "test*");
}
}
//发布
jedis.publish("test1", "message from test1");
jedis.publish("test2", "message from test2");redis分布式锁
public class RedisTool {
private static final String LOCK_SUCCESS = "OK";
private static final Long RELEASE_SUCCESS = 1L;
/**
* 尝试获取分布式锁
* @param jedis Redis客户端
* @param lockKey 锁
* @param requestId 请求标识
* @param expireTime 超期时间
* @return 是否获取成功
*/
public static boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) {
String result = jedis.set(lockKey, requestId,new SetParams().nx().ex(expireTime));
if (LOCK_SUCCESS.equals(result)) {
return true;
}
return false;
}
/**
* 释放分布式锁
* @param jedis Redis客户端
* @param lockKey 锁
* @param requestId 请求标识
* @return 是否释放成功
*/
public static boolean releaseDistributedLock(Jedis jedis, String lockKey, String requestId) {
String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));
if (RELEASE_SUCCESS.equals(result)) {
return true;
}
return false;
}
}
public class LockTest {
public static void main(String[] args) {
Runnable rn = new Runnable() {
@Override
public void run() {
Jedis jedis = new Jedis("localhost", 6379, 100000);
String uuid = UUID.randomUUID().toString().replaceAll("-", "");
int tryCount=5;
while (true) {
Boolean lock = RedisTool.tryGetDistributedLock(jedis, "lock", uuid, 10);
if (lock) {
System.out.println(Thread.currentThread().getName() + "获取锁");
try {
Thread.sleep(1000L);
} catch (InterruptedException e) {
e.printStackTrace();
}
Boolean unlock = RedisTool.releaseDistributedLock(jedis, "lock", uuid);
if (unlock) {
System.out.println(Thread.currentThread().getName() + "释放锁");
break;
}
}
if(tryCount<0) {
break;
}else {
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "尝试次数:"+tryCount);
tryCount--;
}
}
}
};
for (int i = 0; i < 20; i++) {
Thread t = new Thread(rn);
t.start();
}
LockSupport.park();
}
}锁测试
package com.redis;
import java.util.UUID;
import java.util.concurrent.locks.LockSupport;
import redis.clients.jedis.Jedis;
public class ProductServer {
/**
* 向服务端添加货
*
* @return
*/
public boolean addProduct(Jedis jedis, String key, int i) {
System.out.println("货物:" + key + "添加库存:" + i);
if (i > 0) {
System.out.println("---添加货物:" + key + "数量:" + i + "---");
// 获取值
String count = jedis.get(key);
System.out.println("剩余库存:" + count);
if (null == count || Integer.valueOf(count) <= 0) {
System.out.println("---当前货物:" + key + "数量已销售完毕");
System.out.println("---当前货物:" + key + "添加开始");
jedis.set(key, i + "");
System.out.println("---当前货物:" + key + "添加结束");
return true;
}
}
return false;
}
/**
* 消费数据
*/
public boolean decryProduct(Jedis jedis, String key, String requestID) {
try {
Boolean lock = RedisTool.tryGetDistributedLock(jedis, "lock", requestID, 100);
if (!lock) {
System.out.println("请稍后重试...");
return false;
}
System.out.println("货物:" + key + "线程:" + Thread.currentThread().getName() + "消费数据:" + requestID);
String count = jedis.get(key);
if (null != count && Integer.valueOf(count) > 0) {
jedis.decr(key);
count = jedis.get(key);
System.out.println("剩余库存:" + count);
return true;
}
} catch (Exception e) {
} finally {
RedisTool.releaseDistributedLock(jedis, "lock", requestID);
}
return false;
}
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost", 6379, 10000);
ProductServer ps = new ProductServer();
ps.addProduct(jedis, "shouji", 10);
Runnable rn = new Runnable() {
@Override
public void run() {
String uuid = UUID.randomUUID().toString().replaceAll("-", "");
Jedis jedis = new Jedis("localhost", 6379, 10000);
ps.decryProduct(jedis, "shouji", uuid);
}
};
for (int i = 0; i < 15; i++) {
Thread td = new Thread(rn);
td.start();
}
LockSupport.park();
}
}到此，相信大家对“Redis的介绍及应用”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！