「jedis订阅java」Jedis

admin 2023-01-28 10:09:10 324

本篇文章给大家谈谈jedis订阅java，以及Jedis对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

1、java怎么用定时任务实现失效
2、Jedis干什么用的
3、Jedis集成与踩坑经历
4、Redis模拟多个redis客户端实现订阅功能
5、如何用java实现基于JedisCluster对象的连接池
6、SSH如何去发布订阅监听

java怎么用定时任务实现失效

1、ZSet 实现方式

通过 ZSet 实现定时任务的思路是，将定时任务存放到 ZSet 集合中，并且将过期时间存储到 ZSet 的 Score 字段中，然后通过一个无线循环来判断当前时间内是否有需要执行的定时任务，如果有则进行执行，具体实现代码如下：

import redis.clients.jedis.Jedis;

import utils.JedisUtils;

import java.time.Instant;

import java.util.Set;

public class DelayQueueExample {

private static final String _KEY = "DelayQueueExample";

public static void main(String[] args) throws InterruptedException {

Jedis jedis = JedisUtils.getJedis();

// 30s 后执行

long delayTime = Instant.now().plusSeconds(30).getEpochSecond();

jedis.zadd(_KEY, delayTime, "order_1");

// 继续添加测试数据

jedis.zadd(_KEY, Instant.now().plusSeconds(2).getEpochSecond(), "order_2");

jedis.zadd(_KEY, Instant.now().plusSeconds(2).getEpochSecond(), "order_3");

jedis.zadd(_KEY, Instant.now().plusSeconds(7).getEpochSecond(), "order_4");

jedis.zadd(_KEY, Instant.now().plusSeconds(10).getEpochSecond(), "order_5");

// 开启定时任务队列

doDelayQueue(jedis);

}

/**

* 定时任务队列消费

* @param jedis Redis 客户端

public static void doDelayQueue(Jedis jedis) throws InterruptedException {

while (true) {

// 当前时间

Instant nowInstant = Instant.now();

long lastSecond = nowInstant.plusSeconds(-1).getEpochSecond();

// 上一秒时间

long nowSecond = nowInstant.getEpochSecond();

// 查询当前时间的所有任务

Set data = jedis.zrangeByScore(_KEY, lastSecond, nowSecond);

for (String item : data) {

// 消费任务

System.out.println("消费：" + item);

}

// 删除已经执行的任务

jedis.zremrangeByScore(_KEY, lastSecond, nowSecond);

Thread.sleep(1000); // 每秒查询一次

}

登录后复制

2、键空间通知

我们可以通过 Redis 的键空间通知来实现定时任务，它的实现思路是给所有的定时任务设置一个过期时间，等到了过期之后，我们通过订阅过期消息就能感知到定时任务需要被执行了，此时我们执行定时任务即可。

默认情况下 Redis 是不开启键空间通知的，需要我们通过 config set notify-keyspace-events Ex 的命令手动开启，开启之后定时任务的代码如下

Jedis干什么用的

redis是key-value存储系统。

key-value分布式存储系统查询速度快、存放数据量大、支持高并发，非常适合通过主键进行查询，但不能进行复杂的条件查询。

如果辅以Real-Time Search Engine（实时搜索引擎）进行复杂条件检索、全文检索，就可以替代并发性能较低的MySQL等关系型数据库，达到高并发、高性能，节省几十倍服务器数量的目的。

以MemcacheDB、Tokyo Tyrant为代表的key-value分布式存储，在上万并发连接下，轻松地完成高速查询。而MySQL，在几百个并发连接下，就基本上崩溃了。

在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。

扩展资料：

Jedis主存保护是存储保护的重要环节。主存保护一般有存储区域保护和访问方式保护。存储区域保护可采用界限寄存器方式，由系统软件经特权指令给定上、下界寄存器内容，从而划定每个用户程序的区域，禁止越界访问。

Jedis当两键符合时才允许执行存取操作，从而保护别的程序区域不被侵犯，环状保护是把系统程序和用户程序按重要性分层，称为环，对每个环都规定访问它的级别，违反规定的存取操作是非法的，以此实现对正在执行的程序的保护。

参考资料来源：百度百科-Key-Value

Jedis集成与踩坑经历

Jedis是Redis的Java客户端实现，封装了对Redis的通信和命令处理等。

Jedis提供了资源池，可以很方便地实现对Redis的API调用。

之前是通过组内对Jedis封装的Spring Bean来获取和使用Jedis的，现在希望自行实现类似功能，设计目标如下：

具体思路就是针对设计目标而定的：

由于需求比较基础，还没有太多应用场景，实现也没考虑太复杂。整体逻辑不到50行，可以在我的GitHub 上大致看一下。

后续使用可以直接使用Spring将Bean注入。

由于不按常规方法使用JedisPool可能背离了JedisPool设计的使用场景，因此在其中踩了不少坑。

其次，虽然平常常用组内的Jedis组件，但实际上对Jedis的API不了解，本次根据平常使用过程中的一些感受进行“黑盒临摹”，在爬坑过程中其实也学习了其他一些方面的经验，比如Guava Reflections等。

背景

最开始通过FactoryBean提供的连接并未使用动态代理，也就是说仅提供了一个Jedis，所有线程使用同一个Jedis连接。

现象

业务中较频繁地报异常，异常信息为 java.lang.ClassCastException: java.util.ArrayList cannot be cast to [B 等，基本是 ClassCastException ，异常抛出位置为调用Jedis的位置。

原因

最终在另一篇资料指引下来到jedis/issues，在参考资料中发现了最可信最合理的原因：Jedis并非线程安全，不应当并发操作。

正确使用

正如参考资料中回答提到的，每个线程（每次调用）都从JedisPool中获取一个连接，并在使用后归还。

也正是因为这一点跟最初的FactoryBean封装方式冲突了，后来才改用提供动态代理类的方式封装FactoryBean。

背景

我使用的Jedis版本为3.0.1，网上的不少资料指出在使用连接后归还可以使用JedisPool的 void returnResource(Jedis resource) 方法，但在3.0.1版本中这个方法是protected可见的，没有间接调用方法。

另外Jedis源码中找不到注释，这有点奇怪，我想当然地认为版本升级后可以自动归还资源了，于是仅在设置最大连接数之后就部署到业务中了。

现象

业务线程启动后每访问一定次数（调用Jedis达到一定次数）后就完全不响应请求了：

还是在参考资料的指引下查看Tomcat监听的端口，的确很多连接处于 CLOSE_WAIT 状态，表明客户端已断开连接（我自己测试的时候刷新页面太多，很多就中途断开了）。

原因

结合TCP四次挥手过程，应该是中间有资源释放不了导致没有进入 LAST_ACK 状态，推测是Jedis连接资源未归还而总连接数有限制，导致很多线程在等待获取Jedis资源。

正确使用

在Jedis连接使用完毕后，需要调用Jedis的 close() 方法将资源归还JedisPool， close 方法是用于替代 returnResource 方法的。

这个方法语义比较奇怪，真实作用是“ 归还或关闭连接”，最开始其实就是考虑到资源复用的问题才没有考虑使用这个 close 方法的。

对比了一下组内的组件，思路差不多，还有以下的点能够扩展：

ClassCastException - B cannot be cast to java.lang.Long · Issue #186 · xetorthio/jedis

nginx 499状态码 - 微信-大数据从业者 - 博客园

深入分析Tomcat无响应问题及解决方法 - 月下狼的个人页面 - OSCHINA

jedis:连接池(JedisPool)使用示例 - 10km的专栏 - CSDN博客

Jedis使用|returnBrokenResource|returnResource废弃替代 - 诗人不写诗 - CSDN博客

本文搬自我的博客，欢迎参观！

Redis模拟多个redis客户端实现订阅功能

开启redis服务器,我的redis在D盘因此cmd重复开启多个redis客户端

cd D:\Redis

redis-cli.exe -h 127.0.0.1 -p 6379

模拟订阅频道

subscribe channe1 [channel ....] 监听某一频道

subscribe java

再开一个redis客户端模拟发布消息

cd D:\Redis

redis-cli.exe -h 127.0.0.1 -p 6379

publish java woyongyuanaijava

此时可以看到两个订阅了频道的客户端均能收到消息

在jedis封装好的方法中很明显的就可以看到对应的类

点进去看JedisPubSub类的源码

可以看到是一个抽象类方法空实现那就根据方法名来试一下吧

新建一个类去继承JedisPubSub类重写onMessage方法输出两个参数

再新建一个项目去发布消息可以看到订阅了的可以收到消息。

如何用java实现基于JedisCluster对象的连接池

public static void writeRedis(String inpath, int[] keyIndex) throws Exception {

InputStream in = new URL(inpath).openStream();// 输入流 ]

LineIterator br = org.apache.commons.io.IOUtils.lineIterator(in, "utf8");// 指定输入流与字符编码

JedisCluster cluster = RedisUtils.getClusterConn();

String[] line = null;

while (br.hasNext()) {

String s = br.next();

line = RedisUtils.split(s);

String key = "";

for (int i = 0; i keyIndex.length; i++) {

key += line[keyIndex[i]];// TODO:如果有必要，添加分隔符

}

cluster.setnx(key, s);

}

RedisUtils.clusterClose(cluster);

SSH如何去发布订阅监听

SSH去发布订阅监听方法如下：

1、直接使用Redis控制台发布/订阅信息

在redis中：

使用publish channel message即可向指定的channel发布信息，注意只能向一个channel发送消息

使用subscribe channel [channel2...]即可监听指定的channel，注意可以同时监听多个channel2、使用Jedis在Java程序汇总发布/订阅消息

2.1、发布消息

使用Jedis发布消息相对订阅来说比较简单，直接调用Jedis对象的publish方法即可：

public class JedisUtil{undefined

private static JedisPool jedisPool = new

JedisPool(jedisPoolConfig,"localhost");

/**

* 作为生产者publish信息到制定的redis的channel

* @param channel

* @param msg

public static void sendMsg(String channel,String msg){undefined

Jedis jedis = jedisPool.getResource();

jedis.publish(channel,msg);

if (jedis!=null)jedis.close();}}

jedis订阅java的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于Jedis、jedis订阅java的信息别忘了在本站进行查找喔。

标签：jedis订阅java