1、介绍
Jedis是java开发的操作redis的工具包。
2、Jedis的用法
2.1、引入maven依赖
redis.clients
jedis
4.2.1
2.2、使用redis的api操作redis
案例代码如下，重点在于 Jedis 工具类，这个类中包含了操作redis的所有方法。
import org.junit.After; import org.junit.Before; import org.junit.Test; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPubSub; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; / * @className JedisDemo * @date 2022/6/21 / public class JedisDemo { Jedis jedis; @Before public void before() { this.jedis = new Jedis("127.0.0.1", 6379); } @After public void after() { //关闭jedis this.jedis.close(); } / * 测试redis是否连通 */ @Test public void test1() { String ping = jedis.ping(); System.out.println(ping); } / * string类型测试 */ @Test public void stringTest() { jedis.set("site", "http://www.itsoku.com"); System.out.println(jedis.get("site")); System.out.println(jedis.ttl("site")); } / * list类型测试 */ @Test public void listTest() { jedis.rpush("courses", "java", "spring", "springmvc", "springboot"); List
courses = jedis.lrange("courses", 0, -1); for (String course : courses) { System.out.println(course); } } / * set类型测试 */ @Test public void setTest() { jedis.sadd("users", "tom", "jack", "ready"); Set
users = jedis.smembers("users"); for (String user : users) { System.out.println(user); } } / * hash类型测试 */ @Test public void hashTest() { jedis.hset("user:1001", "id", "1001"); jedis.hset("user:1001", "name", "张三"); jedis.hset("user:1001", "age", "30"); Map
userMap = jedis.hgetAll("user:1001"); System.out.println(userMap); } / * zset类型测试 */ @Test public void zsetTest() { jedis.zadd("languages", 100d, "java"); jedis.zadd("languages", 95d, "c"); jedis.zadd("languages", 70d, "php"); List
languages = jedis.zrange("languages", 0, -1); System.out.println(languages); } / * 订阅消息 * * @throws InterruptedException */ @Test public void subscribeTest() throws InterruptedException { // subscribe(消息监听器,频道列表) jedis.subscribe(new JedisPubSub() { @Override public void onMessage(String channel, String message) { System.out.println(channel + ":" + message); } }, "sitemsg"); TimeUnit.HOURS.sleep(1); } / * 发布消息 * * @throws InterruptedException */ @Test public void publishTest() { jedis.publish("sitemsg", "hello redis"); } }
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请联系我们举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/215962.html原文链接：https://javaforall.net
