redisjava實現隊列

A. java程序怎麼連接redis

packagecom.my.test.redis;

importjava.util.Queue;
importjava.util.Set;
importjava.util.concurrent.ConcurrentMap;

importorg.redisson.Config;
importorg.redisson.Redisson;

publicclassRedisExample{

	/**
	*@paramargs
	*/
	publicstaticvoidmain(String[]args){
		//1.初始化
		Configconfig=newConfig();
		config.setConnectionPoolSize(10);
		config.addAddress("127.0.0.1:6379");
		Redissonredisson=Redisson.create(config);
		System.out.println("reids連接成功...");

		//2.測試concurrentMap,put方法的時候就會同步到redis中
		ConcurrentMap<String,Object>鍵臘map=灶亮念redisson.getMap("FirstMap");
		map.put("wuguowei"隱困,"男");
		map.put("zhangsan","nan");
		map.put("lisi","女");

		ConcurrentMapresultMap=redisson.getMap("FirstMap");
		System.out.println("resultMap=="+resultMap.keySet());

		//2.測試Set集合
		SetmySet=redisson.getSet("MySet");
		mySet.add("wuguowei");
		mySet.add("lisi");

		SetresultSet=redisson.getSet("MySet");
		System.out.println("resultSet==="+resultSet.size());
		
		//3.測試Queue隊列
		QueuemyQueue=redisson.getQueue("FirstQueue");
		myQueue.add("wuguowei");
		myQueue.add("lili");
		myQueue.add("zhangsan");
		myQueue.peek();
		myQueue.poll();

		QueueresultQueue=redisson.getQueue("FirstQueue");
		System.out.println("resultQueue==="+resultQueue);
		
		//關閉連接
		redisson.shutdown();
	}

}

B. SpringBoot 操作 Redis的各種實現

原文
SpringBoot 操作 Redis的各種實段悔弊現 (qq.com)

共同點：都提供了基於Redis操作的Java API，只是封裝程度，具體實現稍有不同。

不同點：

是Redis的Java實現的客戶端。支前鍵持基本的數據類型如：String、Hash、List、Set、Sorted Set。

特點：使用阻塞的I/O，方法調用同步，程序流需要等到socket處理完I/O才能執行，不支持非同步操作。Jedis客戶端實例不是線程安全的，需要通過連接池來使用Jedis。

優點點：分布式鎖，分布式集合，可通過Redis支持延遲隊列。

用於線程安全同步，非同步和響應使用，支持集群，Sentinel，管道和編碼器。

基於Netty框架的事件驅動的通信層，其方法調用是非同步的。Lettuce的API是線程安全的，所以可以操作單個Lettuce連接來完成各種操作。

maven配置引入，（要加上版本號，我這里是因為Parent已聲明）

application-dev.yml

redisson-config.yml

或者，配置 redisson-config.json

新建讀取配置類

或者，在 application.yml中配置如下

4.3.1 豐富的jar支持，尤其是對 Netty NIO框架

4.3.2 豐富的配置機制選擇，這里是詳細的配置說明

關於序列化機制中，就有很多

4.3.3 API支持（部分展示），具體的 Redis --> RedissonClient ,可查看這里

4.3.4 輕便的豐富的鎖機制的實現

參考 RedisTemplate 配置。

另外，還需握族要額外的配置類

基於spring緩存實現

歡迎一鍵三連

C. java 多線程讀取隊列部分元素，讀出後將讀出的元素存放進redis並且刪除原來隊列的元素

多線程去讀同一個隊列里的東西有意義么，要知道多線程的話是在同時去工作，你還要刪除原來的元素，想要不沖突只能鎖定了這個隊列去操作，那這樣多線程的意義就沒有了，除非你森局在每個線程中此老讓都設定他去讀取這個隊列的某一部分，否則沒有含唯什麼意義

D. Java工程師是如何使用Redis的

redis算是用的最多的key-value型緩存組件了！

因為使用了key-value型，所以存取效率極好，簡單來說就類似JAVA中的hashMap，不過是用整個伺服器內存來當做map，但是redis的數據可以通過配置指令保存到硬碟(同步保存save，非同步保存bgsave)！

當然，redis在使用過程中會存在持久化失敗，緩存擊穿，擴容困難等問題，不過無論如何，redis都是一款最值得用的緩存工具！

使用過程中有任何問題，歡迎大家一起交流，redis還有什麼遺漏功能，也請大家補充，謝謝！

E. 通過redis的有序集合[zset] 實現延遲隊列

php使用redis的有序集合zset實現延遲隊列

我們通過redis的有序集合zset來實現簡單的延遲隊列，將消息數據序列化，作為zset的基本元素，把 消息生產時間戳 + 消息處理延遲時間戳 作為score，每次通過zRangeByScore獲取一條消息進行處理，後通過zRem刪除集合元激滑碰素:相當於移除需要消費的 Job。

優點:

缺點：
1.不適合延遲時間高的業務場景。延遲時間可能有幾秒鍾的誤差。
2.不適合明談大型項目 ，大型項目建議使用讓褲rabbitmq的延遲i消息隊列

下面是簡單的實現demo

F. Redis的基本使用（二） 消息隊列

使用消息中間件的時候，並非每次都需要非常專業的消息中間件，假如只有一個消息隊列，只有一個消費者，那就沒有必要去使用專業的消息中間件，這種情況可以直接使用 Redis 來做消息大敬則隊列。

Redis 的消息隊列不是特別專業，他沒有很多高級特性，適用簡單的場景，如果對稿擾於消息可靠性有著極高的追求，那麼不適合使用 Redis 做消息隊列。

Redis 做消息隊列，使用它里邊的 List 數據結構就可以實現，使用 lpush/rpush 操作來實現入隊，然後使用 lpop/rpop 來實現出隊。

在客戶端（例如 Java 端），我們會維護一個死循環來不停的從隊列中讀取消息，並處理，如果隊列中有消息，則直

接獲取到，如果沒有消息，就會陷入死循環，直到下一次有消息進入，這種死循環會造成大量的資源浪費，這個滾棚時候，

可以使用之前講的 blpop/brpop 。

blpop 阻塞式的彈出，相當於 lpop 的阻塞版。

延遲隊列可以通過 zset 來實現，因為 zset 中有一個 score，我們可以把時間作為 score，將 value 存到redis 中，然後通過輪詢的方式，去不斷的讀取消息出來。

首先，如果消息是一個字元串，直接發送即可，如果是一個對象，則需要對對象進行序列化，這里我們
使用 JSON 來實現序列化和反序列化。

首先在項目中，添加 JSON 依賴：

接下來，構造一個消息對象：

接下來封裝一個消息隊列：

測試：

G. 如何用Java和Redis設計一個高效的先入先出的隊列

分析：
redis的list底層是多個ziplist結構組成的「雙向」鏈表。中間部分還壓縮了一下。
最外層是由兩個哈希表構成的dict。
哈希表的get(key)時間復雜度為O(1),而且這個O(1)理論上不會因為所佔內存的大小和元素數目所改變。list的出隊列和入隊操作也都是O(1)。
Java的隊列時間復雜度也應為O(1)。

可不可以直接用redis的list做先進先出？

情況1，數據數量不多，可以用
情況2，數據量多，但存的數據是激活碼這樣簡單值一類，可以用。
情況3，list存的是要獲取數據的索引，大量數據的值已經存在redis的KV結構中。
這時候，如果數據每次獲取下一個數據都要執行redis的hash查找（O(1)）然後redis的list從頭或者末尾出一個。經過網路IO返回，Java程序在用出來的key去請求redis去get(key) （O(1)）。這里是兩次網路IO或者進程間的IO。
這時候，可以不用redis的list存索引而只是用redis大的KV哈希結構存鍵值。用①Java的隊列先進先出獲取下一個key或者②使用預先規定好的鍵生成的規則，讓鍵是有規則有順序的，比如自增ID，然後每次獲取都是ID++，而直接從redis.get(ID.next());來獲取值。

最後一種就是最高效的辦法，為了特殊場景的高效出隊列而設計。但是如果只是一般的數據量，使用redis的list也未嘗不可。

H. 怎樣使用redis緩存，java代碼

應用Redis實現數據的讀寫，同時利用隊列處理器定時將數據寫入mysql。
同時要注意避免沖突，在redis啟動時去mysql讀取所有表鍵值存入redis中，往redis寫數據時，對redis主鍵自增並進行讀取，若mysql更新失敗，則需要及時清除緩存及同步redis主鍵。
這樣處理，主要是實時讀寫redis，而mysql數據則通過隊列非同步處理，緩解mysql壓力，不過這種方法應用場景主要基於高並發，而且redis的高可用集群架構相對更復雜，一般不是很推薦。

I. 基於Redisson實現延遲隊列

假設有友扮這樣一個場景，我們有一個訂單，或者工單等等。需要在超時30分鍾後進行關閉。這個時候我們最先想到的應該是採用定時任務去進行輪訓判斷，但是呢，每個訂單的創建時間是不一樣的，這個時間怎麼確定才好呢，5分鍾。。1分鍾。。執行一次嗎。這樣就會非常影響性能。且時間誤差很大。基於以上業務需要我們想到了有以下解決方案。

我們好橘灶首先來回顧下JDK的延遲隊列

基於延遲隊列要實現介面 Delayed ，並且實現 getDelay 方法和 compareTo 方法

訂單的實體,為了簡單就定義基礎幾個欄位。

為了簡單我們暫且定義延遲時間為10s

輸出結果

2022-07-01T15:00
當前時間：2022-07-01T15:10:37.375

當然今天的主角是它了，我們主要圍繞著基於Redisson的延遲隊列來說。

其實Redisson延遲隊列內部也是基於redis來實現的，我們先來進行整合使用看看效果。基於springboot

1.依賴：

2.創建redisson.yml

3.創建配置類RedissonConfig,這里是為了讀取我們剛剛創建在配置文件中的yml

4.測試

控制台輸出：

訂單生成時間2022-07-01T15:22:10.304
訂單關閉時間2022-07-01T15:22:20.414

我們首先來了解兩個API

那麼為什麼會涉及到兩個隊列呢，這兩個隊列到底有什麼用呢？

首先我們實際操作的是RBlockingQueue阻塞隊列，並不是RDelayedQueue隊列，RDelayedQueue對接主要是提供中間轉發的一個隊列，類似中間商的意思

畫個小圖理解下

這里不難看出我們都是基於 RBlockingQueue 目標隊列在進行消費，而 RDelayedQueue 就是會把過期的消息放入到我們的目標隊列中

我們只要從 RBlockingQueue 隊列中取數據即可。

好像還是不夠深入，我們接著看。我們知道 Redisson 是基於redis來實現的那麼我們看看裡面到底做了什麼事

打開redis客戶端，執行monitor命令，看下在執行上面訂單操作時redis到底執行了哪些命令

monitor命令可以看到操作redis時執行了什麼命令

這里參考： https://zhuanlan.hu.com/p/343811173

我們知道Zset是按照分數升序的也就是最小的分數在最前面，基於這個特點，大致明白，利用過期時間的時間戳作為分數放入到Zset中，那麼即將過期的就在最上面。伍物

直接上個圖解

J. 誰有好用的Java使用redis的封裝的示例

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>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>1.0.2</version>
</dependency>

<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.7</version>
</dependency>

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

開發示例
下面是演示連接redis伺服器、保存讀取concurrentMap對象、保存讀取set對象和保存讀取Queue對象的示例代碼，代碼比較簡單，這里就不再詳細講解基讓了，代碼如下：
[java] view plain
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中
ConcurrentMap<String, 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();
}

}