這篇文章主要介紹如何基于Redis結合SpringBoot實現秒殺，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！
搭建名為quickbuy的springboot項目，相關的依賴包如下所示：
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.13.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.baizhi</groupId> <artifactId>quickbuy</artifactId> <version>0.0.1-SNAPSHOT</version> <name>quickbuy</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> <version>4.5.5</version> </dependency> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpcore</artifactId> <version>4.4.10</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
引入了Redis、HttpClient等依賴包。
項目結構
package com.baizhi;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class QuickbuyApplication {
public static void main(String[] args) {
SpringApplication.run(QuickbuyApplication.class, args);
}
}@RestController
public class QuickBuyController {
@Autowired
private SellService sellService;
@RequestMapping("/quickBuy/{item}/{owner}")
public String quickbuy(@PathVariable String item,@PathVariable String owner){
String result=sellService.quickBuy(item,owner);
if(!result.equals("0")){
return owner+"success";
}else{
return owner+"fail";
}
}
}??通過@RequestMapping注解們可以把"/quickBuy/{item}/{owner}"格式的url映射到quickBuy方法上。
?? quickBuy是秒殺接口，該接口包含的兩個參數是item和owner，分別表示待秒殺的商品名和發起秒殺請求的用戶。這兩個參數均被@PathVariable注解修飾，說明來自于url里的{item}和{owner}部分。
??在這個quickBuy秒殺接口中調用了SellService類里的quickBuy方法實現了秒殺功能，并根據SellService類quickBuy方法返回的結果，向外部返回“秒殺成功”或“秒殺失敗”的字符串語句。
package com.baizhi.service;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.connection.ReturnType;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class SellService {
@Resource
private RedisTemplate redisTemplate;
public String quickBuy(String item, String owner) {
//用lua腳本實現秒殺
String luaScript="local owner=ARGV[1]\n" +
"local item=KEYS[1] \n" +
"local leftNum=tonumber(redis.call('get',item)) \n" +
"if(leftNum>=1)\n" +
"then redis.call('decrby',item,1)\n" +
"redis.call('rpush','ownerList',owner)\n" +
"return 1 \n" +
"else \n" +
"return 0 \n" +
"end\n" +
"\n";
String key=item;
String args=owner;
DefaultRedisScript<String> redisScript=new DefaultRedisScript<String>();
redisScript.setScriptText(luaScript);
//調用lua腳本，請注意傳入的參數
Object luaResult=redisTemplate.execute((RedisConnection connection)->connection.eval(
redisScript.getScriptAsString().getBytes(),
ReturnType.INTEGER,
1,
key.getBytes(),
args.getBytes()
));
//根據lua腳本的執行情況返回結果
return luaResult.toString();
}
}對lua腳本的解釋如下：
?? 通過ARGV[1]參數傳入發起秒殺請求的用戶，用KEYS[1]參數傳入待秒殺的商品。通過get item命令判斷item商品在Redis里還有多少庫存。
??if語句中判定剩余庫存大于等于1，就會先執行decrby命令把庫存數減1，隨后調用第6行的rpush命令，在ownerList里記錄當前秒殺成功的用戶，并通過return 1表示秒殺成功。如果判斷庫存數已經小于1，那么return 0表示秒殺失敗。
??其中將lua腳本賦予redisScript對象，并通過redisTemplate.execute方法執行lua腳本。
在調用redisTemplate.execute方法執行lua腳本時請注意以下三點：
需要以butes方式傳入腳本
需要指定返回類型
傳入該lua腳本所包含的KEYS類型參數的個數是1.
傳入的KEYS和ARGV類型的參數需要轉換成bytes類型
application.properties
server.port=8081 spring.redis.host=192.168.159.22 spring.redis.port=6379
我用的剛搭建的redis主從復制集群，一主二從
設置10個商品
??在瀏覽器訪問http://localhost:8081/quickBuy/Computer/abc,測試秒殺接口，該url傳入的商品名是“Computer”,需要和上面設置的商品名稱一致，傳入的發起秒殺請求的客戶端名字為abc。輸入該url后，能看到表示秒殺成功的如下輸出。
進入redis查看
發現商品數量變成了9，且能看到秒殺成功的用戶列表。
QuickBuyClients.java
package com.baizhi.client;
import org.apache.http.HttpEntity;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
public class QuickBuyClients extends Thread{
@Override
public void run() {
QuickBuyUtil.quickBuy();
}
public static void main(String[] args) {
//開啟15個線程，線程數多余秒殺商品數
for(int cnt=0;cnt<15;cnt++){
new QuickBuyClients().start();
}
}
}
//封裝秒殺方法的工具類
class QuickBuyUtil{
//在這個方法里，用HttpGet對象發起秒殺請求
public static void quickBuy(){
String user=Thread.currentThread().getName();
CloseableHttpClient httpClient= HttpClientBuilder.create().build();
//創建秒殺Get類型的url請求
HttpGet httpGet=new HttpGet("http://localhost:8081/quickBuy/Computer/"+user);
//得到響應結果
CloseableHttpResponse res=null;
try{
res=httpClient.execute(httpGet);
HttpEntity responseEntity=res.getEntity();
if(res.getStatusLine().equals("200")&&responseEntity!=null){
System.out.println("秒殺結果："+ EntityUtils.toString(responseEntity));
}
}catch (ClientProtocolException e){
e.printStackTrace();
}catch (Exception e){
e.printStackTrace();
}finally {
try{
//回收http連接資源
if(httpClient!=null){
httpClient.close();
}
if(res!=null){
res.close();
}
}catch (Exception e){
e.printStackTrace();
}
}
}
}先重新設置商品數量為10
啟動上面的程序
再次進入Redis查看商品數量和秒殺成功的用戶
可以看到，15個線程秒殺商品，最終成功的只有10個。
以上是“如何基于Redis結合SpringBoot實現秒殺”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
