resubmit漸進式防重復(fù)提交框架示例
更新時間：2022年08月03日 16:25:49 作者：老馬嘯西風
這篇文章主要為大家介紹了resubmit漸進式防重復(fù)提交框架示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
resubmit
resubmit 是一款為 java 設(shè)計的漸進式防止重復(fù)提交框架。
推薦閱讀：
創(chuàng)作目的
有時候手動加防止重復(fù)提交很麻煩，每次手動編寫不利于復(fù)用。
所以希望從從簡到繁實現(xiàn)一個工具，便于平時使用。
特性
- 漸進式實現(xiàn)，可獨立 spring 使用
- 基于注解+字節(jié)碼，配置靈活
- 支持編程式的調(diào)用
- 支持注解式，完美整合 spring
- 支持整合 spring-boot
maven 引入
<dependency>
<group>com.github.houbb</group>
<artifact>resubmit-core</artifact>
<version>1.0.0</version>
</dependency>
編碼
- UserService.java
@Resubmit 對應(yīng)的屬性如下：
| 屬性 | 說明 | 默認值 |
|---|---|---|
| value() | 多久內(nèi)禁止重復(fù)提交，單位為毫秒。 | 60000 |
@Resubmit(5000)
public void queryInfo(final String id) {
System.out.println("query info: " + id);
}
- 測試代碼
如果在指定時間差內(nèi)，重復(fù)請求，則會拋出異常 ResubmitException
@Test(expected = ResubmitException.class)
public void errorTest() {
UserService service = ResubmitProxy.getProxy(new UserService());
service.queryInfo("1");
service.queryInfo("1");
}
相同的參數(shù)直接提交2次，就會報錯。
- 測試場景2
如果等待超過指定的 5s，就不會報錯。
@Test
public void untilTtlTest() {
UserService service = ResubmitProxy.getProxy(new UserService());
service.queryInfo("1");
DateUtil.sleep(TimeUnit.SECONDS, 6);
service.queryInfo("1");
}
自定義
ResubmitProxy.getProxy(new UserService());
可以獲取 UserService 對應(yīng)的代理。
等價于：
ResubmitBs resubmitBs = ResubmitBs.newInstance()
.cache(new CommonCacheServiceMap())
.keyGenerator(new KeyGenerator())
.tokenGenerator(new HttpServletRequestTokenGenerator());
UserService service = ResubmitProxy.getProxy(new UserService(), resubmitBs);
其中 ResubmitBs 作為引導(dǎo)類，對應(yīng)的策略都支持自定義。
| 屬性 | 說明 | 默認值 |
|---|---|---|
| cache() | 緩存實現(xiàn)策略 | 默認為基于 ConcurrentHashMap 實現(xiàn)的基于內(nèi)存的緩存實現(xiàn) |
| keyGenerator() | key 實現(xiàn)策略，用于唯一標識一個方法+參數(shù)，判斷是否為相同的提交 | md5 策略 |
| tokenGenerator() | token 實現(xiàn)策略，用于唯一標識一個用戶。 | 從 HttpServletRequest 中的 header 屬性 resubmit_token 中獲取 |
spring 整合使用
maven 引入
<dependency>
<group>com.github.houbb</group>
<artifact>resubmit-spring</artifact>
<version>1.0.0</version>
</dependency>
代碼編寫
- UserService.java
@Service
public class UserService {
@Resubmit(5000)
public void queryInfo(final String id) {
System.out.println("query info: " + id);
}
}
- SpringConfig.java
@ComponentScan("com.github.houbb.resubmit.test.service")
@EnableResubmit
@Configuration
public class SpringConfig {
}
@EnableResubmit 注解說明
@EnableResubmit 中用戶可以指定對應(yīng)的實現(xiàn)策略，便于更加靈活的適應(yīng)業(yè)務(wù)場景。
和 ResubmitBs 中支持自定義的屬性一一對應(yīng)。
| 屬性 | 說明 | 默認值 |
|---|---|---|
| cache() | 緩存實現(xiàn)策略 | 默認為基于 ConcurrentHashMap 實現(xiàn)的基于內(nèi)存的緩存實現(xiàn) |
| keyGenerator() | key 實現(xiàn)策略，用于唯一標識一個方法+參數(shù)，判斷是否為相同的提交 | md5 策略 |
| tokenGenerator() | token 實現(xiàn)策略，用于唯一標識一個用戶。 | 從 HttpServletRequest 中的 header 屬性 resubmit_token 中獲取 |
測試代碼
@ContextConfiguration(classes = SpringConfig.class)
@RunWith(SpringJUnit4ClassRunner.class)
public class ResubmitSpringTest {
@Autowired
private UserService service;
@Test(expected = ResubmitException.class)
public void queryTest() {
service.queryInfo("1");
service.queryInfo("1");
}
}
整合 spring-boot
maven 引入
<dependency>
<groupId>com.github.houbb</groupId>
<artifactId>resubmit-springboot-starter</artifactId>
<version>1.0.0</version>
</dependency>
代碼實現(xiàn)
- UserService.java
這個方法實現(xiàn)和前面的一樣。
@Service
public class UserService {
@Resubmit(5000)
public void queryInfo(final String id) {
System.out.println("query info: " + id);
}
}
- Application.java
啟動入口
@SpringBootApplication
public class ResubmitApplication {
public static void main(String[] args) {
SpringApplication.run(ResubmitApplication.class, args);
}
}
測試代碼
@ContextConfiguration(classes = ResubmitApplication.class)
@RunWith(SpringJUnit4ClassRunner.class)
public class ResubmitSpringBootStarterTest {
@Autowired
private UserService service;
@Test(expected = ResubmitException.class)
public void queryTest() {
service.queryInfo("1");
service.queryInfo("1");
}
}
自定義策略
上面提到 @EnableResubmit 中的策略支持自定義。
此處僅以 cache 為例，為了簡單，默認是基于本地內(nèi)存的緩存實現(xiàn)。
如果你不是單點應(yīng)用，那么基于 redis 的緩存更加合適
自定義緩存 cache
實現(xiàn)緩存
只需要實現(xiàn) ICommonCacheService 接口即可。
public class MyDefineCache extends CommonCacheServiceMap {
// 這里只是作為演示，實際生產(chǎn)建議使用 redis 作為統(tǒng)一緩存
@Override
public synchronized void set(String key, String value, long expireMills) {
System.out.println("------------- 自定義的設(shè)置實現(xiàn)");
super.set(key, value, expireMills);
}
}
core 中指定使用
在非 spring 項目中，可以在引導(dǎo)類中指定我們定義的緩存。
ResubmitBs resubmitBs = ResubmitBs.newInstance()
.cache(new MyDefineCache());
UserService service = ResubmitProxy.getProxy(new UserService(), resubmitBs);
其他使用方式保持不變。
spring 中指定使用
在 spring 項目中，我們需要調(diào)整一下配置，其他不變。
@ComponentScan("com.github.houbb.resubmit.test.service")
@Configuration
@EnableResubmit(cache = "myDefineCache")
public class SpringDefineConfig {
@Bean("myDefineCache")
public ICommonCacheService myDefineCache() {
return new MyDefineCache();
}
}
@EnableResubmit(cache = "myDefineCache") 指定我們自定義的緩存策略名稱。
Redis 的內(nèi)置緩存策略
為了便于復(fù)用，基于 redis 的緩存策略已實現(xiàn)，后續(xù)有時間進行講解。
開源地址
為了便于大家學(xué)習使用，目前防重復(fù)提交框架已開源。
歡迎大家 fork+star，鼓勵一下老馬~
以上就是resubmit漸進式防重復(fù)提交框架示例的詳細內(nèi)容，更多關(guān)于resubmit防重復(fù)提交的資料請關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了Java中的Optional類詳細解讀,Optional是Java中的一個類,它的作用是用于解決空指針異常的問題,它提供了一些有用的方法,可以幫助我們避免顯式進行空值檢測,需要的朋友可以參考下2023-08-08
這篇文章主要介紹了Java實現(xiàn)LRU緩存的實例詳解的相關(guān)資料,這里提供實例幫助大家理解掌握這部分內(nèi)容，需要的朋友可以參考下2017-08-08
這篇文章主要為大家詳細介紹了Java線程實現(xiàn)時間動態(tài)顯示，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-04-04
這篇文章主要介紹了SpringBoot中Mybatis注解一對一查詢的實現(xiàn)示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-07-07
Eclipse安裝Aptana插件(注意對應(yīng)版本問題)
這篇文章主要為大家詳細介紹了Eclipse安裝Aptana插件的相關(guān)資料，特別注意對應(yīng)版本問題，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-02-02
這篇文章主要介紹了Java多線程中的Future類詳細解讀,Future表示一個可能還沒有完成的異步任務(wù)的結(jié)果,針對這個結(jié)果可以添加Callback以便在任務(wù)執(zhí)行成功或失敗后作出相應(yīng)的操作,需要的朋友可以參考下2023-11-11
在多線程環(huán)境下，程序往往會出現(xiàn)一些線程安全問題，為此，Java提供了一些線程的同步機制來解決安全問題，比如：synchronized鎖和Lock鎖都能解決線程安全問題。下面小編就來詳細介紹該知識點,需要的朋友可以參考一下2021-09-09
這篇文章主要介紹了使用SpringBoot獲取所有接口的路由方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
SpringBoot+Redis?BitMap實現(xiàn)簽到與統(tǒng)計的項目實踐
最近項目里需要集成簽到和統(tǒng)計功能，連續(xù)簽到后會給用戶發(fā)放一些優(yōu)惠券和獎品，以此來吸引用戶持續(xù)在該品臺進行活躍，本文就詳細的介紹一下如何實現(xiàn)，感興趣的可以了解一下2023-09-09
java集合——Java中的equals和hashCode方法詳解
本篇文章詳細介紹了Java中的equals和hashCode方法詳解，Object 類是所有類的父類，非常具有實用價值，需要的朋友可以參考下。2016-10-10