關(guān)于使用Redisson訂閱數(shù)問(wèn)題
更新時(shí)間：2022年01月14日 11:11:05 作者：玉樹(shù)臨楓
本文主要介紹了關(guān)于使用Redisson訂閱數(shù)問(wèn)題，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
一、前提
最近在使用分布式鎖redisson時(shí)遇到一個(gè)線上問(wèn)題：發(fā)現(xiàn)是subscriptionsPerConnection or subscriptionConnectionPoolSize 的大小不夠，需要提高配置才能解決。
二、源碼分析
下面對(duì)其源碼進(jìn)行分析，才能找到到底是什么邏輯導(dǎo)致問(wèn)題所在：
1、RedissonLock#lock() 方法
private void lock(long leaseTime, TimeUnit unit, boolean interruptibly) throws InterruptedException {
? ? ? ? long threadId = Thread.currentThread().getId();
? ? ? ? // 嘗試獲取，如果ttl == null，則表示獲取鎖成功
? ? ? ? Long ttl = tryAcquire(leaseTime, unit, threadId);
? ? ? ? // lock acquired
? ? ? ? if (ttl == null) {
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? // 訂閱鎖釋放事件，并通過(guò)await方法阻塞等待鎖釋放，有效的解決了無(wú)效的鎖申請(qǐng)浪費(fèi)資源的問(wèn)題
? ? ? ? RFuture<RedissonLockEntry> future = subscribe(threadId);
? ? ? ? if (interruptibly) {
? ? ? ? ? ? commandExecutor.syncSubscriptionInterrupted(future);
? ? ? ? } else {
? ? ? ? ? ? commandExecutor.syncSubscription(future);
? ? ? ? }
? ? ? ? // 后面代碼忽略
? ? ? ? try {
? ? ? ? ? ? // 無(wú)限循環(huán)獲取鎖，直到獲取鎖成功
? ? ? ? ? ? // ...
? ? ? ? } finally {
? ? ? ? ? ? // 取消訂閱鎖釋放事件
? ? ? ? ? ? unsubscribe(future, threadId);
? ? ? ? }
}總結(jié)下主要邏輯：
- 獲取當(dāng)前線程的線程id；
- tryAquire嘗試獲取鎖，并返回ttl
- 如果ttl為空，則結(jié)束流程；否則進(jìn)入后續(xù)邏輯；
- this.subscribe(threadId)訂閱當(dāng)前線程，返回一個(gè)RFuture；
- 如果在指定時(shí)間沒(méi)有監(jiān)聽(tīng)到，則會(huì)產(chǎn)生如上異常。
- 訂閱成功后， 通過(guò)while(true)循環(huán)，一直嘗試獲取鎖
- fially代碼塊，會(huì)解除訂閱
所以上述這情況問(wèn)題應(yīng)該出現(xiàn)在subscribe()方法中
2、詳細(xì)看下subscribe()方法
protected RFuture<RedissonLockEntry> subscribe(long threadId) {
? ? // entryName 格式：“id:name”；
? ? // channelName 格式：“redisson_lock__channel:name”；
? ? return pubSub.subscribe(getEntryName(), getChannelName());
}RedissonLock#pubSub 是在RedissonLock構(gòu)造函數(shù)中初始化的：
public RedissonLock(CommandAsyncExecutor commandExecutor, String name) {
? ? // ....
? ? this.pubSub = commandExecutor.getConnectionManager().getSubscribeService().getLockPubSub();
}而subscribeService在MasterSlaveConnectionManager的實(shí)現(xiàn)中又是通過(guò)如下方式構(gòu)造的
public MasterSlaveConnectionManager(MasterSlaveServersConfig cfg, Config config, UUID id) {
? ? this(config, id);
? ? this.config = cfg;
? ? // 初始化
? ? initTimer(cfg);
? ? initSingleEntry();
}
protected void initTimer(MasterSlaveServersConfig config) {
? ? int[] timeouts = new int[]{config.getRetryInterval(), config.getTimeout()};
? ? Arrays.sort(timeouts);
? ? int minTimeout = timeouts[0];
? ? if (minTimeout % 100 != 0) {
? ? ? ? minTimeout = (minTimeout % 100) / 2;
? ? } else if (minTimeout == 100) {
? ? ? ? minTimeout = 50;
? ? } else {
? ? ? ? minTimeout = 100;
? ? }
? ? timer = new HashedWheelTimer(new DefaultThreadFactory("redisson-timer"), minTimeout, TimeUnit.MILLISECONDS, 1024, false);
? ? connectionWatcher = new IdleConnectionWatcher(this, config);
? ? // 初始化:其中this就是MasterSlaveConnectionManager實(shí)例，config則為MasterSlaveServersConfig實(shí)例：
? ? subscribeService = new PublishSubscribeService(this, config);
}PublishSubscribeService構(gòu)造函數(shù)
private final SemaphorePubSub semaphorePubSub = new SemaphorePubSub(this);
public PublishSubscribeService(ConnectionManager connectionManager, MasterSlaveServersConfig config) {
? ? super();
? ? this.connectionManager = connectionManager;
? ? this.config = config;
? ? for (int i = 0; i < locks.length; i++) {
? ? ? ? // 這里初始化了一組信號(hào)量，每個(gè)信號(hào)量的初始值為1
? ? ? ? locks[i] = new AsyncSemaphore(1);
? ? }
}3、回到subscribe()方法主要邏輯還是交給了 LockPubSub#subscribe()里面
private final ConcurrentMap<String, E> entries = new ConcurrentHashMap<>();
public RFuture<E> subscribe(String entryName, String channelName) {
? ? ? // 從PublishSubscribeService獲取對(duì)應(yīng)的信號(hào)量。 相同的channelName獲取的是同一個(gè)信號(hào)量
? ? ?// public AsyncSemaphore getSemaphore(ChannelName channelName) {
? ? // ? ?return locks[Math.abs(channelName.hashCode() % locks.length)];
? ? // }
? ? AsyncSemaphore semaphore = service.getSemaphore(new ChannelName(channelName));
? ? AtomicReference<Runnable> listenerHolder = new AtomicReference<Runnable>(); ? ?
? ? RPromise<E> newPromise = new RedissonPromise<E>() {
? ? ? ? @Override
? ? ? ? public boolean cancel(boolean mayInterruptIfRunning) {
? ? ? ? ? ? return semaphore.remove(listenerHolder.get());
? ? ? ? }
? ? };
? ? Runnable listener = new Runnable() {
? ? ? ? @Override
? ? ? ? public void run() {
? ? ? ? ? ? // ?如果存在RedissonLockEntry， 則直接利用已有的監(jiān)聽(tīng)
? ? ? ? ? ? E entry = entries.get(entryName);
? ? ? ? ? ? if (entry != null) {
? ? ? ? ? ? ? ? entry.acquire();
? ? ? ? ? ? ? ? semaphore.release();
? ? ? ? ? ? ? ? entry.getPromise().onComplete(new TransferListener<E>(newPromise));
? ? ? ? ? ? ? ? return;
? ? ? ? ? ? }
? ? ? ? ? ? E value = createEntry(newPromise);
? ? ? ? ? ? value.acquire();
? ? ? ? ? ? E oldValue = entries.putIfAbsent(entryName, value);
? ? ? ? ? ? if (oldValue != null) {
? ? ? ? ? ? ? ? oldValue.acquire();
? ? ? ? ? ? ? ? semaphore.release();
? ? ? ? ? ? ? ? oldValue.getPromise().onComplete(new TransferListener<E>(newPromise));
? ? ? ? ? ? ? ? return;
? ? ? ? ? ? }
? ? ? ? ? ? // 創(chuàng)建監(jiān)聽(tīng)，
? ? ? ? ? ? RedisPubSubListener<Object> listener = createListener(channelName, value);
? ? ? ? ? ? // 訂閱監(jiān)聽(tīng)
? ? ? ? ? ? service.subscribe(LongCodec.INSTANCE, channelName, semaphore, listener);
? ? ? ? }
? ? };
? ? // 最終會(huì)執(zhí)行l(wèi)istener.run方法
? ? semaphore.acquire(listener);
? ? listenerHolder.set(listener);
? ? return newPromise;
}AsyncSemaphore#acquire()方法
public void acquire(Runnable listener) {
? ? acquire(listener, 1);
}
public void acquire(Runnable listener, int permits) {
? ? boolean run = false;
? ? synchronized (this) {
? ? ? ? // counter初始化值為1
? ? ? ? if (counter < permits) {
? ? ? ? ? ? // 如果不是第一次執(zhí)行，則將listener加入到listeners集合中
? ? ? ? ? ? listeners.add(new Entry(listener, permits));
? ? ? ? ? ? return;
? ? ? ? } else {
? ? ? ? ? ? counter -= permits;
? ? ? ? ? ? run = true;
? ? ? ? }
? ? }
? ? // 第一次執(zhí)行acquire， 才會(huì)執(zhí)行l(wèi)istener.run()方法
? ? if (run) {
? ? ? ? listener.run();
? ? }
}梳理上述邏輯：
1、從PublishSubscribeService獲取對(duì)應(yīng)的信號(hào)量， 相同的channelName獲取的是同一個(gè)信號(hào)量
2、如果是第一次請(qǐng)求，則會(huì)立馬執(zhí)行l(wèi)istener.run()方法， 否則需要等上個(gè)線程獲取到該信號(hào)量執(zhí)行完方能執(zhí)行；
3、如果已經(jīng)存在RedissonLockEntry， 則利用已經(jīng)訂閱就行
4、如果不存在RedissonLockEntry， 則會(huì)創(chuàng)建新的RedissonLockEntry，然后進(jìn)行。
從上面代碼看，主要邏輯是交給了PublishSubscribeService#subscribe方法
4、PublishSubscribeService#subscribe邏輯如下：
private final ConcurrentMap<ChannelName, PubSubConnectionEntry> name2PubSubConnection = new ConcurrentHashMap<>();
private final Queue<PubSubConnectionEntry> freePubSubConnections = new ConcurrentLinkedQueue<>();
public RFuture<PubSubConnectionEntry> subscribe(Codec codec, String channelName, AsyncSemaphore semaphore, RedisPubSubListener<?>... listeners) {
? ? RPromise<PubSubConnectionEntry> promise = new RedissonPromise<PubSubConnectionEntry>();
? ? // 主要邏輯入口， 這里要主要channelName每次都是新對(duì)象, 但內(nèi)部覆寫(xiě)hashCode+equals。
? ? subscribe(codec, new ChannelName(channelName), promise, PubSubType.SUBSCRIBE, semaphore, listeners);
? ? return promise;
}
private void subscribe(Codec codec, ChannelName channelName, ?RPromise<PubSubConnectionEntry> promise, PubSubType type, AsyncSemaphore lock, RedisPubSubListener<?>... listeners) {
? ? PubSubConnectionEntry connEntry = name2PubSubConnection.get(channelName);
? ? if (connEntry != null) {
? ? ? ? // 從已有Connection中取，如果存在直接把listeners加入到PubSubConnectionEntry中
? ? ? ? addListeners(channelName, promise, type, lock, connEntry, listeners);
? ? ? ? return;
? ? }
? ? // 沒(méi)有時(shí)，才是最重要的邏輯
? ? freePubSubLock.acquire(new Runnable() {
? ? ? ? @Override
? ? ? ? public void run() {
? ? ? ? ? ? if (promise.isDone()) {
? ? ? ? ? ? ? ? lock.release();
? ? ? ? ? ? ? ? freePubSubLock.release();
? ? ? ? ? ? ? ? return;
? ? ? ? ? ? }
? ? ? ? ? ? // 從隊(duì)列中取頭部元素
? ? ? ? ? ? PubSubConnectionEntry freeEntry = freePubSubConnections.peek();
? ? ? ? ? ? if (freeEntry == null) {
? ? ? ? ? ? ? ? // 第一次肯定是沒(méi)有的需要建立
? ? ? ? ? ? ? ? connect(codec, channelName, promise, type, lock, listeners);
? ? ? ? ? ? ? ? return;
? ? ? ? ? ? }
? ? ? ? ? ? // 如果存在則嘗試獲取，如果remainFreeAmount小于0則拋出異常終止了。
? ? ? ? ? ? int remainFreeAmount = freeEntry.tryAcquire();
? ? ? ? ? ? if (remainFreeAmount == -1) {
? ? ? ? ? ? ? ? throw new IllegalStateException();
? ? ? ? ? ? }
? ? ? ? ? ? PubSubConnectionEntry oldEntry = name2PubSubConnection.putIfAbsent(channelName, freeEntry);
? ? ? ? ? ? if (oldEntry != null) {
? ? ? ? ? ? ? ? freeEntry.release();
? ? ? ? ? ? ? ? freePubSubLock.release();
? ? ? ? ? ? ? ? addListeners(channelName, promise, type, lock, oldEntry, listeners);
? ? ? ? ? ? ? ? return;
? ? ? ? ? ? }
? ? ? ? ? ? // 如果remainFreeAmount=0， 則從隊(duì)列中移除
? ? ? ? ? ? if (remainFreeAmount == 0) {
? ? ? ? ? ? ? ? freePubSubConnections.poll();
? ? ? ? ? ? }
? ? ? ? ? ? freePubSubLock.release();
? ? ? ? ? ? // 增加監(jiān)聽(tīng)
? ? ? ? ? ? RFuture<Void> subscribeFuture = addListeners(channelName, promise, type, lock, freeEntry, listeners);
? ? ? ? ? ? ChannelFuture future;
? ? ? ? ? ? if (PubSubType.PSUBSCRIBE == type) {
? ? ? ? ? ? ? ? future = freeEntry.psubscribe(codec, channelName);
? ? ? ? ? ? } else {
? ? ? ? ? ? ? ? future = freeEntry.subscribe(codec, channelName);
? ? ? ? ? ? }
? ? ? ? ? ? future.addListener(new ChannelFutureListener() {
? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? public void operationComplete(ChannelFuture future) throws Exception {
? ? ? ? ? ? ? ? ? ? if (!future.isSuccess()) {
? ? ? ? ? ? ? ? ? ? ? ? if (!promise.isDone()) {
? ? ? ? ? ? ? ? ? ? ? ? ? ? subscribeFuture.cancel(false);
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? return;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? connectionManager.newTimeout(new TimerTask() {
? ? ? ? ? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? ? ? ? ? public void run(Timeout timeout) throws Exception {
? ? ? ? ? ? ? ? ? ? ? ? ? ? subscribeFuture.cancel(false);
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }, config.getTimeout(), TimeUnit.MILLISECONDS);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? });
? ? ? ? }
? ? });
}
private void connect(Codec codec, ChannelName channelName, RPromise<PubSubConnectionEntry> promise, PubSubType type, AsyncSemaphore lock, RedisPubSubListener<?>... listeners) {
? ? // 根據(jù)channelName計(jì)算出slot獲取PubSubConnection
? ? int slot = connectionManager.calcSlot(channelName.getName());
? ? RFuture<RedisPubSubConnection> connFuture = nextPubSubConnection(slot);
? ? promise.onComplete((res, e) -> {
? ? ? ? if (e != null) {
? ? ? ? ? ? ((RPromise<RedisPubSubConnection>) connFuture).tryFailure(e);
? ? ? ? }
? ? });
? ? connFuture.onComplete((conn, e) -> {
? ? ? ? if (e != null) {
? ? ? ? ? ? freePubSubLock.release();
? ? ? ? ? ? lock.release();
? ? ? ? ? ? promise.tryFailure(e);
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? // 這里會(huì)從配置中讀取subscriptionsPerConnection
? ? ? ? PubSubConnectionEntry entry = new PubSubConnectionEntry(conn, config.getSubscriptionsPerConnection());
? ? ? ? // 每獲取一次，subscriptionsPerConnection就會(huì)減直到為0
? ? ? ? int remainFreeAmount = entry.tryAcquire();
? ? ? ? // 如果舊的存在，則將現(xiàn)有的entry釋放，然后將listeners加入到oldEntry中
? ? ? ? PubSubConnectionEntry oldEntry = name2PubSubConnection.putIfAbsent(channelName, entry);
? ? ? ? if (oldEntry != null) {
? ? ? ? ? ? releaseSubscribeConnection(slot, entry);
? ? ? ? ? ? freePubSubLock.release();
? ? ? ? ? ? addListeners(channelName, promise, type, lock, oldEntry, listeners);
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? if (remainFreeAmount > 0) {
? ? ? ? ? ? // 加入到隊(duì)列中
? ? ? ? ? ? freePubSubConnections.add(entry);
? ? ? ? }
? ? ? ? freePubSubLock.release();
? ? ? ? RFuture<Void> subscribeFuture = addListeners(channelName, promise, type, lock, entry, listeners);
? ? ? ? // 這里真正的進(jìn)行訂閱（底層與redis交互）
? ? ? ? ChannelFuture future;
? ? ? ? if (PubSubType.PSUBSCRIBE == type) {
? ? ? ? ? ? future = entry.psubscribe(codec, channelName);
? ? ? ? } else {
? ? ? ? ? ? future = entry.subscribe(codec, channelName);
? ? ? ? }
? ? ? ? future.addListener(new ChannelFutureListener() {
? ? ? ? ? ? @Override
? ? ? ? ? ? public void operationComplete(ChannelFuture future) throws Exception {
? ? ? ? ? ? ? ? if (!future.isSuccess()) {
? ? ? ? ? ? ? ? ? ? if (!promise.isDone()) {
? ? ? ? ? ? ? ? ? ? ? ? subscribeFuture.cancel(false);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? return;
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? connectionManager.newTimeout(new TimerTask() {
? ? ? ? ? ? ? ? ? ? @Override
? ? ? ? ? ? ? ? ? ? public void run(Timeout timeout) throws Exception {
? ? ? ? ? ? ? ? ? ? ? ? subscribeFuture.cancel(false);
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }, config.getTimeout(), TimeUnit.MILLISECONDS);
? ? ? ? ? ? }
? ? ? ? });
? ? });
}PubSubConnectionEntry#tryAcquire方法， subscriptionsPerConnection代表了每個(gè)連接的最大訂閱數(shù)。當(dāng)tryAcqcurie的時(shí)候會(huì)減少這個(gè)數(shù)量：
?public int tryAcquire() {
????while (true) {
????????int value = subscribedChannelsAmount.get();
????????if (value == 0) {
????????????return -1;
????????}
????????if (subscribedChannelsAmount.compareAndSet(value, value - 1)) {
????????????return value - 1;
????????}
????}
}梳理上述邏輯：
1、還是進(jìn)行重復(fù)判斷， 根據(jù)channelName從name2PubSubConnection中獲取，看是否存在已經(jīng)訂閱：PubSubConnectionEntry； 如果存在直接把新的listener加入到PubSubConnectionEntry。
2、從隊(duì)列freePubSubConnections中取公用的PubSubConnectionEntry， 如果沒(méi)有就進(jìn)入connect()方法
2.1 會(huì)根據(jù)subscriptionsPerConnection創(chuàng)建PubSubConnectionEntry， 然后調(diào)用其tryAcquire()方法 - 每調(diào)用一次就會(huì)減1
2.2 將新的PubSubConnectionEntry放入全局的name2PubSubConnection， 方便后續(xù)重復(fù)使用；
2.3 同時(shí)也將PubSubConnectionEntry放入隊(duì)列freePubSubConnections中。- remainFreeAmount > 0
2.4 后面就是進(jìn)行底層的subscribe和addListener
3、如果已經(jīng)存在PubSubConnectionEntry，則利用已有的PubSubConnectionEntry進(jìn)行tryAcquire；
4、如果remainFreeAmount < 0 會(huì)拋出IllegalStateException異常；如果remainFreeAmount=0，則會(huì)將其從隊(duì)列中移除， 那么后續(xù)請(qǐng)求會(huì)重新獲取一個(gè)可用的連接
5、最后也是進(jìn)行底層的subscribe和addListener；
三 總結(jié)
根因： 從上面代碼分析， 導(dǎo)致問(wèn)題的根因是因?yàn)镻ublishSubscribeService 會(huì)使用公共隊(duì)列中的freePubSubConnections， 如果同一個(gè)key一次性請(qǐng)求超過(guò)subscriptionsPerConnection它的默認(rèn)值5時(shí)，remainFreeAmount就可能出現(xiàn)-1的情況， 那么就會(huì)導(dǎo)致commandExecutor.syncSubscription(future)中等待超時(shí)，也就拋出如上異常Subscribe timeout: (7500ms). Increase 'subscriptionsPerConnection' and/or 'subscriptionConnectionPoolSize' parameters.
解決方法： 在初始化Redisson可以可指定這個(gè)配置項(xiàng)的值。
相關(guān)參數(shù)的解釋以及默認(rèn)值請(qǐng)參考官網(wǎng)：https://github.com/redisson/redisson/wiki/2.-Configuration#23-common-settings
到此這篇關(guān)于關(guān)于使用Redisson訂閱數(shù)問(wèn)題的文章就介紹到這了,更多相關(guān)Redisson 訂閱數(shù) 內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
在單體應(yīng)用中，如果我們對(duì)共享數(shù)據(jù)不進(jìn)行加鎖操作，會(huì)出現(xiàn)數(shù)據(jù)一致性問(wèn)題，我們的解決辦法通常是加鎖。下面我們一起聊聊使用redis來(lái)實(shí)現(xiàn)分布式鎖2022-07-07
淺談Redis?中的過(guò)期刪除策略和內(nèi)存淘汰機(jī)制
本文主要介紹了Redis?中的過(guò)期刪除策略和內(nèi)存淘汰機(jī)制，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04
這篇文章主要給大家分享介紹了關(guān)于Redis獲取某個(gè)大key值的一個(gè)腳本實(shí)例，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧。2018-04-04
如何使用Redis保存用戶(hù)會(huì)話Session詳解
這篇文章主要給大家介紹了關(guān)于如何使用Redis保存用戶(hù)會(huì)話Session的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-01-01
淺談我是如何用redis做實(shí)時(shí)訂閱推送的
這篇文章主要介紹了淺談我是如何用redis做實(shí)時(shí)訂閱推送的，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03
詳解Redis數(shù)據(jù)類(lèi)型實(shí)現(xiàn)原理
這篇文章主要介紹了Redis數(shù)據(jù)類(lèi)型實(shí)現(xiàn)原理，在工作中或?qū)W習(xí)中有需要的小伙伴可以參考一下這篇文章2021-08-08
基于Redis緩存數(shù)據(jù)常見(jiàn)的三種問(wèn)題及解決
這篇文章主要介紹了基于Redis緩存數(shù)據(jù)常見(jiàn)的三種問(wèn)題及解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-06-06
這篇文章主要介紹了淺談Redis中的緩存更新策略,CacheAsidePatter是我們比較常用的緩存更新策略，其由緩存調(diào)用者在更新數(shù)據(jù)庫(kù)時(shí)，在業(yè)務(wù)邏輯中設(shè)置緩存更新,需要的朋友可以參考下2023-08-08
Redis和Nginx實(shí)現(xiàn)限制接口請(qǐng)求頻率的示例
限流就是限制API訪問(wèn)頻率,當(dāng)訪問(wèn)頻率超過(guò)某個(gè)閾值時(shí)進(jìn)行拒絕訪問(wèn)等操作,本文主要介紹了Redis和Nginx實(shí)現(xiàn)限制接口請(qǐng)求頻率的示例,具有一定的參考價(jià)值,感興趣的可以了解一下2024-02-02
啟動(dòng)redis出現(xiàn)閃退情況的解決辦法
最近使用Redis遇到啟動(dòng)閃退的問(wèn)題,查閱資料后在一位大神的文章中找到了答案,這篇文章主要給大家介紹了關(guān)于啟動(dòng)redis出現(xiàn)閃退情況的解決辦法,需要的朋友可以參考下2023-11-11