关于怎么在用java在redis上实现秒杀

为什么用redis来实现秒杀功能 ，这么不加赘述。

一、需要准备的插件和包

Spring data  redis 

jedis

redisson

jdk1.8等

二、思路

想要使用redis来实现秒杀，首先需要链接上redis，对redis进行操作，这里需要使用jedis来实现。

那么，先来实现jedis.在source下创建一个（Maven项目）spring-redis.xml文件。

代码如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
	xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="
	http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.0.xsd
	http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
	http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/context/spring-context-3.0.xsd">


    <!-- 连接池 -->
	<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
	</bean>

    <!-- 集群节点 -->
	<bean id="redisClusterConfig"
		class="org.springframework.data.redis.connection.RedisClusterConfiguration">
		
		<property name="clusterNodes">
			<set>
				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="192.168.10.130"></constructor-arg>
					<constructor-arg name="port" value="7001"></constructor-arg>
				</bean>

				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="192.168.10.130"></constructor-arg>
					<constructor-arg name="port" value="7002"></constructor-arg>
				</bean>

				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="192.168.10.130"></constructor-arg>
					<constructor-arg name="port" value="7003"></constructor-arg>
				</bean>


				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="192.168.10.130"></constructor-arg>
					<constructor-arg name="port" value="7004"></constructor-arg>
				</bean>


				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="192.168.10.130"></constructor-arg>
					<constructor-arg name="port" value="7005"></constructor-arg>
				</bean>


				<bean class="org.springframework.data.redis.connection.RedisNode">
					<constructor-arg name="host" value="192.168.10.130"></constructor-arg>
					<constructor-arg name="port" value="7006"></constructor-arg>
				</bean>

			</set>
		</property>
	</bean>


	<!-- ReDis连接工厂 -->
	<bean id="redis4CacheConnectionFactory"
		class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
		<constructor-arg name="clusterConfig" ref="redisClusterConfig" />
		<property name="timeout" value="1000" />
		<property name="poolConfig" ref="jedisPoolConfig" />
	</bean>
	
	<!-- 存储序列化 -->
    <bean name="stringRedisSerializer"
        class="org.springframework.data.redis.serializer.StringRedisSerializer" />


    <!-- 集群Resis使用模板 -->
    <bean id="clusterRedisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
        <property name="connectionFactory" ref="redis4CacheConnectionFactory" />
        <property name="keySerializer" ref="stringRedisSerializer" />
        <property name="hashKeySerializer" ref="stringRedisSerializer" />
        <property name="valueSerializer" ref="stringRedisSerializer" />
        <property name="hashValueSerializer" ref="stringRedisSerializer" />
    </bean>


</beans>

 

不清楚标签可以自行百度。用时，直接更改Ip和port 即可。

2、为了防止多线程并发出现数据混乱的问题，需要对秒杀进行加锁。使用redisson客户端即可实现。

在source下创建一个spring-redisson.xml的文件，配置代码如下：

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:redisson="http://redisson.org/schema/redisson"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context.xsd
       http://redisson.org/schema/redisson
       http://redisson.org/schema/redisson/redisson.xsd">

 
  <!--
    <redisson:client id="redissonClient">
        <redisson:single-server address="127.0.0.1:6379" connection-pool-size="30"/>
    </redisson:client>
  -->
    
    <redisson:client id="redissonClient" >
        <redisson:cluster-servers scan-interval="10000">   <!-- //scan-interval:集群状态扫描间隔时间，单位是毫秒 -->
        	<redisson:node-address value="redis://192.168.10.130:7001"></redisson:node-address>
        	<redisson:node-address value="redis://192.168.10.130:7002"></redisson:node-address>
        	<redisson:node-address value="redis://192.168.10.130:7003"></redisson:node-address>
        	<redisson:node-address value="redis://192.168.10.130:7004"></redisson:node-address>
        	<redisson:node-address value="redis://192.168.10.130:7005"></redisson:node-address>
        	<redisson:node-address value="redis://192.168.10.130:7006"></redisson:node-address>
        </redisson:cluster-servers>
    </redisson:client>
    
    
</beans>

只需要更改value值即可。

3、创建一个Spring的配置文件。用于整合上面的两个文件。代码如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:util="http://www.springframework.org/schema/util"
	xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="
	http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.3.xsd
	http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd
	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
	http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/context/spring-context-4.3.xsd">
  
    <context:component-scan base-package="com.service"></context:component-scan>
    
	<import resource="spring-redis.xml"/>
	<import resource="spring-redisson.xml"/>
 </beans>

4、创建一个java类，实现一个叫做miaosha的方法。代码如下：

package com.service;

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;


@Service
public class MiaoShaService {
	@Autowired
	private RedisTemplate redisTemplate;
	
	@Autowired 
	private RedissonClient redissonClient;
	
	
	public Integer miaosha(){
		//上锁
		RLock lock = redissonClient.getLock("redis_lock");
		lock.lock();
		//得到库存
		int num = Integer.parseInt(redisTemplate.boundValueOps("iphone").get().toString());
		if(num<1){
			return 1;
		}
		redisTemplate.boundValueOps("iphone").increment(-1);
		System.out.println("秒杀成功！");
		lock.unlink();
		return 0;
	}
	
}

 

4、测试

package com.test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.service.MiaoShaService;

public class 多线程测试 {
	public static void main(String[] args) {
		ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
	    final MiaoShaService miaoShaService = applicationContext.getBean(MiaoShaService.class);
	    //创建线程池
	    ExecutorService es =  Executors.newFixedThreadPool(10);
	    for (int i=0;i<200;i++)
	    {
	    	es.execute(new Runnable() {
				@Override
				public void run() {
					miaoShaService.miaosha();
				}
				
			});
	    }
	}

}

 

其中porm.xml的配置如下：

<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>redis-02</groupId>
	<artifactId>redis-02</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>war</packaging>
	<name>redis-02</name>
	<description />
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
	</properties>
	<dependencies>
		<!-- https://mvnrepository.com/artifact/org.springframework/spring-webmvc -->
		<dependency> 
			<groupId>org.springframework</groupId>
			<artifactId>spring-webmvc</artifactId>
			<version>5.0.0.RELEASE</version>
		</dependency>

		<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
		<dependency>
			<groupId>redis.clients</groupId>
			<artifactId>jedis</artifactId>
			<version>2.9.0</version>
		</dependency>
 
		<!-- https://mvnrepository.com/artifact/org.springframework.data/spring-data-redis -->
		<dependency> 
			<groupId>org.springframework.data</groupId>
			<artifactId>spring-data-redis</artifactId>
			<version>2.0.0.RELEASE</version>
		</dependency>

		<!-- https://mvnrepository.com/artifact/org.redisson/redisson -->
		<dependency>
			<groupId>org.redisson</groupId>
			<artifactId>redisson</artifactId>
			<version>3.5.0</version>
		</dependency>





		<dependency>
			<groupId>javax</groupId>
			<artifactId>javaee-api</artifactId>
			<version>7.0</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>org.glassfish.web</groupId>
			<artifactId>javax.servlet.jsp.jstl</artifactId>
			<version>1.2.2</version>
		</dependency>
	</dependencies>
	<build>
		<plugins>
			<plugin>
				<artifactId>maven-compiler-plugin</artifactId>
				<version>2.3.2</version>
				<configuration>
					<source>1.7</source>
					<target>1.7</target>
				</configuration>
			</plugin>
			<plugin>
				<artifactId>maven-war-plugin</artifactId>
				<version>2.2</version>
				<configuration>
					<version>3.1</version>
					<failOnMissingWebXml>false</failOnMissingWebXml>
				</configuration>
			</plugin>
		</plugins>
	</build>
</project>

 

全部评论

相关推荐

头像
Nobitaxi
05-09 10:05
昆明理工大学 电子信息类
点赞 评论 收藏
转发
头像
泥电第一华孝子
05-13 21:02
电子科技大学 计算机类
点赞 评论 收藏
转发
头像 会员标识 头像
牛客296407561号
04-28 00:49
中山大学 数学类
点赞 评论 收藏
转发
头像
kikizl
05-13 15:02
美团_前端工程师
【内推】【校招】【组内直招】美团到店-前端&移动【直通笔试】
2025年转正实习，内推！【北京】简历直达组内【部门记得要选&ldquo;核心本地商业&rdquo;】【工作意向地&ldquo;北京&rdquo;】！招聘对象：2025届应届毕业生内推投递方式按照以下A或者B两种方式都可以，进行美团的内推投递：（投递后，强烈建议在牛客网私聊我，确认是否内推成功）&nbsp;A.（建议）&nbsp;PC端，文字内推码：mtRPNRS&nbsp;1、第一步：进内推系统&nbsp;登录「美团招聘」官网https://campus.meituan.com/，在上图所示的界面输入框中，填入文字内推码&nbsp;「mtRPNRS」&nbsp;，即可完成内推！&nbsp;2、&nbsp;（重要）找我确认&nbsp;确认途径：牛客网私聊我。我会在美团的内推系统中，帮大家查询并确认。&nbsp;B.&nbsp;手机...
投递美团等公司10个岗位 >
点赞 评论 收藏
转发
点赞 1 评论
分享

全站热榜

正在热议
# 牛客帮帮团来啦！有问必答 #
700662次浏览 11443人参与
# 许愿池 #
76789次浏览 1539人参与
# 你的秋招进展怎么样了 #
498914次浏览 13403人参与
# 如何缓解入职前的焦虑 #
33316次浏览 339人参与
# 找工作时遇到的神仙HR #
176651次浏览 1739人参与
# 如何写一份好简历 #
257941次浏览 3901人参与
# 找工作，你会甘心进小厂还是猛冲大厂 #
34641次浏览 352人参与
# 通信硬件人笔面经互助 #
106254次浏览 2161人参与
# 市场营销面经 #
4391次浏览 124人参与
# 互联网公司评价 #
78898次浏览 1083人参与
# 无实习如何秋招上岸 #
222890次浏览 3492人参与
# 投了多少份简历才上岸 #
56333次浏览 945人参与
# 面试中的破防瞬间 #
82128次浏览 1011人参与
# 产品人求职现状 #
50395次浏览 744人参与
# 通信硬件薪资爆料 #
194313次浏览 1739人参与
# 软件开发投递记录 #
467106次浏览 7129人参与
# 23届的你们都什么时候入职？ #
84449次浏览 736人参与
# 互联网公司爆料 #
36262次浏览 367人参与
# 运营面经 #
11168次浏览 272人参与
# 科大讯飞求职进展汇总 #
36306次浏览 369人参与
牛客网
牛客企业服务