javajedis,javajedis一個線程訂閱多個channel

本文目錄一覽：

• 1、Jedis集成與踩坑經歷
• 2、redis java 有什麼用
• 3、關於java redis的操作jedis的疑問

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 java 有什麼用

Java連接redis的使用示例

Redis是開源的key-value存儲工具，redis通常用來存儲結構化的數據，因為redis的key可以包含String、hash、listset和sorted list。

Redisclient支持多種語言，包括：c、C++、C#、php、java、python、go等語言，根據自己的開發語言，選擇合適的redis client版本類型即可。我是使用java語言開發的，針對java語言，redis client也提供了多種客戶端支持，按照推薦類型依次是：Jedis、Redisson、JRedis、JDBC-Redis、RJC、redis-protocol、aredis、lettuce。前兩種類型是比較推薦的，我們採用了Redisson類型版本作為redisclient的使用。

Redisson版的redis可發工程搭建

1. 新建maven工程

2. 在pom.xml文件的dependencies節點下增加如下內容：

dependency

groupIdorg.redisson/groupId

artifactIdredisson/artifactId

version1.0.2/version

/dependency

dependency

groupIdorg.slf4j/groupId

artifactIdslf4j-log4j12/artifactId

version1.7.7/version

/dependency

3. 保存pom.xml後，等eclispe工程構建完成後即可進行開發了

開發示例

下面是演示連接redis伺服器、保存讀取concurrentMap對象、保存讀取set對象和保存讀取Queue對象的示例代碼，代碼比較簡單，這裡就不再詳細講解了，代碼如下：

[java] view plaincopy

package com.my.test.redis;

import java.util.Queue;

import java.util.Set;

import java.util.concurrent.ConcurrentMap;

import org.redisson.Config;

import org.redisson.Redisson;

public class RedisExample {

/**

* @param args

*/

public static void main(String[] args) {

// 1.初始化

Config config = new Config();

config.setConnectionPoolSize(10);

config.addAddress(“127.0.0.1:6379”);

Redisson redisson = Redisson.create(config);

System.out.println(“reids連接成功…”);

// 2.測試concurrentMap,put方法的時候就會同步到redis中

ConcurrentMapString, Object map = redisson.getMap(“FirstMap”);

map.put(“wuguowei”, “男”);

map.put(“zhangsan”, “nan”);

map.put(“lisi”, “女”);

ConcurrentMap resultMap = redisson.getMap(“FirstMap”);

System.out.println(“resultMap==” + resultMap.keySet());

// 2.測試Set集合

Set mySet = redisson.getSet(“MySet”);

mySet.add(“wuguowei”);

mySet.add(“lisi”);

Set resultSet = redisson.getSet(“MySet”);

System.out.println(“resultSet===” + resultSet.size());

//3.測試Queue隊列

Queue myQueue = redisson.getQueue(“FirstQueue”);

myQueue.add(“wuguowei”);

myQueue.add(“lili”);

myQueue.add(“zhangsan”);

myQueue.peek();

myQueue.poll();

Queue resultQueue=redisson.getQueue(“FirstQueue”);

System.out.println(“resultQueue===”+resultQueue);

// 關閉連接

redisson.shutdown();

}

}

關於java redis的操作jedis的疑問

ava操作redis的jedis的範圍查詢是怎麼寫的？ 我要從一個範圍到另一個範圍的區間

我試過了，

List userList = jedis.lrange(“userList”, 0, -1);

Set user = jedis.zrange(“user”, 0, -1);

這兩個範圍查詢的得到結果，為何都是 0

但是我用 Set str =jedis.keys(“tes2:*”);

發現是用完整的數據的，我一次性讀取這麼多數據，redis直接socket失敗了

它是專為 .NET 平台設計的一種靜態類型編程語言。 Nemerle 中的程序會被編譯成中間語言位元組碼。它支持函數式，命令式以及面向對象編程。