fork/join和線程池

問題：

啟用了Spring且其范圍設(shè)置為Request的緩存需要由不在請(qǐng)求范圍內(nèi)的singleton bean訪問。

解：

Spring使您能夠創(chuàng)建緩存，該緩存為請(qǐng)求范圍保留數(shù)據(jù)。 例如

import org.springframework.cache.concurrent.ConcurrentMapCache; import org.springframework.cache.interceptor.SimpleCacheResolver; import org.springframework.cache.support.SimpleCacheManager; import org.springframework.context.annotation.Scope; import org.springframework.context.annotation.ScopedProxyMode; import org.springframework.stereotype.Component; import org.springframework.web.context.WebApplicationContext; import java.util.ArrayList; import java.util.Collection; @Component @Scope(value = WebApplicationContext.SCOPE_REQUEST, proxyMode = ScopedProxyMode.TARGET_CLASS) public class RequestScopeCache extends SimpleCacheResolver { public RequestScopeCache() { SimpleCacheManager cacheManager = new SimpleCacheManager(); Collection caches = new ArrayList((Collection) new ConcurrentMapCache( "myCache" , true )); cacheManager.setCaches(caches); cacheManager.initializeCaches(); setCacheManager(cacheManager); } }

您可以在要緩存的任何方法周圍使用此緩存

@Cacheable(value = "myCache" , cacheResolver = "requestScopeCache" ) public String getName(String id) { //logic to get name from id }

現(xiàn)在，如果您從具有請(qǐng)求上下文的任何控制器中調(diào)用此方法，那就很好了，即，該方法是從服務(wù)Web請(qǐng)求的Spring bean的任何其他方法中調(diào)用的。

但是，如果您需要從線程池或fork連接池中調(diào)用它，事情就會(huì)變得棘手。 假設(shè)您收到一個(gè)請(qǐng)求，并且需要生成多個(gè)線程以同時(shí)運(yùn)行以收集數(shù)據(jù)以將請(qǐng)求存儲(chǔ)到服務(wù)器。

這些線程耗盡了Web請(qǐng)求線程的上下文，因此在Web請(qǐng)求線程上設(shè)置的任何“線程本地”值將對(duì)這些線程不可用。

因此，如果最終從這些池線程中調(diào)用上述方法（注釋為使用緩存），則會(huì)從spring中獲取異常，例如：

Scope 'session' is not active for the current thread ; IllegalStateException: No ; IllegalStateException: No thread -bound request found

但是有一種簡(jiǎn)單的方法可以修復(fù)它：

從Web請(qǐng)求線程獲取請(qǐng)求屬性

RequestAttributes attributes = RequestContextHolder.getRequestAttributes();

2.將此屬性傳遞給來自pool或fork / join的自定義線程。 基本上可以通過在構(gòu)造函數(shù)中使用此屬性創(chuàng)建可運(yùn)行對(duì)象來完成

3.在調(diào)用標(biāo)記為使用請(qǐng)求范圍緩存的方法之前，設(shè)置請(qǐng)求屬性

RequestContextHolder.setRequestAttributes(attributes);

這將在當(dāng)前線程的本地線程中設(shè)置屬性，該屬性可用于調(diào)用上述方法。

測(cè)試用例中的綜合要求

現(xiàn)在，如果您正在從junit測(cè)試方法，則可能根本沒有請(qǐng)求對(duì)象。

因此，您可以創(chuàng)建一個(gè)并按上述方法使用它來填充要測(cè)試的屬性

RequestContextHolder.setRequestAttributes( new ServletRequestAttributes( new DummyRequest()));

翻譯自: https://www.javacodegeeks.com/2020/05/access-spring-request-scope-cache-in-singelton-bean-called-from-fork-join-thread-pool.html

fork/join和線程池

總結(jié)

以上是生活随笔為你收集整理的fork/join和线程池_从fork-join /线程池调用的Singelton bean中的访问spring请求范围缓存...的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。