技术标签: spring boot rabbitmq redis
本方案采用rabbitMQ、redis的原因:
- redis 用来存储商品库存信息,用来缓解DB的压力;
- rabbitMQ 来做 redis 和 DB 之间的商品库存数据同步,以及代码解耦;
方案缺点:
缺点1:多了层MQ,也就是会有很大的概率导致同步延迟问题.
缺点2:要对MQ的可用性做预防
缺点3:如果人为改数据库,那就没法同步了
方案优点:
优点1:可以大幅减少接口的延迟返回的问题
优点2:身有重试机制,无需人工去写重试代码
优点3:解耦,把查询Mysql和同步Redis完全分离,互不干扰
Spring Boot 2.7.15
JDK8
Redis 3.2.10
RabbitMQ 3.10.2
MySQL 8.0.32
CREATE TABLE `goods` (
`id` bigint NOT NULL AUTO_INCREMENT,
`goodsname` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '商品名称',
`goodsnum` int NULL DEFAULT NULL COMMENT '商品库存',
PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci ROW_FORMAT = Dynamic;
pom.xml 的依赖配置:
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- rabbitMQ-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<!-- JDBC驱动-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!-- redis 缓存操作 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- mysql-->
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- lombok-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<!-- mybatis plus -->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.3.2</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
application.yml 配置文件:
spring:
# rabbitmq配置
rabbitmq:
host: localhost
publisher-returns: true
publisher-confirm-type: correlated
username: admin
password: admin
port: 5672
listener:
simple:
acknowledge-mode: manual
# mysql8.0配置
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3399/ry-cloud?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT&allowPublicKeyRetrieval=true
username: root
password: qwe123
#redis配置
redis:
host: localhost
port: 6379
database: 0
password:
timeout: 10s
lettuce:
pool:
min-idle: 0
max-idle: 8
max-active: 8
max-wait: -1ms
GoodsMapper.xml.xml:
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.mysqlredismqdemo.mapper.GoodsMapper">
<resultMap type="com.example.mysqlredismqdemo.entity.Goods" id="GoodsResult">
<result property="id" column="id" />
<result property="goodsname" column="goodsname" />
<result property="goodsnum" column="goodsnum" />
</resultMap>
<select id="selectAll" resultMap="GoodsResult">
select id,goodsname,goodsnum from goods
</select>
<select id="selectGoodsNum" resultType="Integer">
SELECT COUNT(id)nums FROM `goods`
</select>
</mapper>
Mapper的接口文件:
import com.example.mysqlredismqdemo.entity.Goods;
import java.util.List;
/**
* 用户表 数据层
*
* @author ruoyi
*/
public interface GoodsMapper
{
/**
* @return {@link List}<{@link Goods}>
*/
public List<Goods> selectAll();
public Integer selectGoodsNum();
}
rabbitMQ的队列、交换机配置文件- ------- MQConfig.java:
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
@Configuration
public class MQConfig {
@Resource
private RabbitTemplate rabbitTemplate;
@Bean
public Queue directQueue1() {
return new Queue("queue1",false);
}
@Bean
public Queue directQueue2() {
return new Queue("queue2",false);
}
@Bean
public DirectExchange directExchange() {
return new DirectExchange("DirectExchange",false,true);
}
@Bean
public Binding bindingDirect() {
return BindingBuilder.bind(directQueue1()).to(directExchange()).with("queue1-1");
}
@Bean
public Binding bindingDirect2() {
return BindingBuilder.bind(directQueue2()).to(directExchange()).with("queue2-1");
}
@PostConstruct
public void confirmCallbackAck() {
rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
if (!ack)
System.out.println("发送失败");
else
System.out.println("发送成功");
});
}
}
redis 工具类 ------- RedisCache.java:
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.BoundSetOperations;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.stereotype.Component;
import java.util.*;
import java.util.concurrent.TimeUnit;
/**
* spring redis 工具类
*
* @author ruoyi
**/
@SuppressWarnings(value = {
"unchecked", "rawtypes"})
@Component
public class RedisCache {
@Autowired
public RedisTemplate redisTemplate;
/**
* 缓存基本的对象,Integer、String、实体类等
*
* @param key 缓存的键值
* @param value 缓存的值
*/
public <T> void setCacheObject(final String key, final T value) {
redisTemplate.opsForValue().set(key, value);
}
/**
* 缓存基本的对象,Integer、String、实体类等
*
* @param key 缓存的键值
* @param value 缓存的值
* @param timeout 时间
* @param timeUnit 时间颗粒度
*/
public <T> void setCacheObject(final String key, final T value, final Integer timeout, final TimeUnit timeUnit) {
redisTemplate.opsForValue().set(key, value, timeout, timeUnit);
}
/**
* 设置有效时间
*
* @param key Redis键
* @param timeout 超时时间
* @return true=设置成功;false=设置失败
*/
public boolean expire(final String key, final long timeout) {
return expire(key, timeout, TimeUnit.SECONDS);
}
/**
* 设置有效时间
*
* @param key Redis键
* @param timeout 超时时间
* @param unit 时间单位
* @return true=设置成功;false=设置失败
*/
public boolean expire(final String key, final long timeout, final TimeUnit unit) {
return redisTemplate.expire(key, timeout, unit);
}
/**
* 获得缓存的基本对象。
*
* @param key 缓存键值
* @return 缓存键值对应的数据
*/
public <T> T getCacheObject(final String key) {
ValueOperations<String, T> operation = redisTemplate.opsForValue();
return operation.get(key);
}
/**
* 删除单个对象
*
* @param key
*/
public boolean deleteObject(final String key) {
return redisTemplate.delete(key);
}
/**
* 删除集合对象
*
* @param collection 多个对象
* @return
*/
public long deleteObject(final Collection collection) {
return redisTemplate.delete(collection);
}
/**
* 缓存List数据
*
* @param key 缓存的键值
* @param dataList 待缓存的List数据
* @return 缓存的对象
*/
public <T> long setCacheList(final String key, final List<T> dataList) {
Long count = redisTemplate.opsForList().rightPushAll(key, dataList);
return count == null ? 0 : count;
}
/**
* 获得缓存的list对象
*
* @param key 缓存的键值
* @return 缓存键值对应的数据
*/
public <T> List<T> getCacheList(final String key) {
return redisTemplate.opsForList().range(key, 0, -1);
}
/**
* 缓存Set
*
* @param key 缓存键值
* @param dataSet 缓存的数据
* @return 缓存数据的对象
*/
public <T> BoundSetOperations<String, T> setCacheSet(final String key, final Set<T> dataSet) {
BoundSetOperations<String, T> setOperation = redisTemplate.boundSetOps(key);
Iterator<T> it = dataSet.iterator();
while (it.hasNext()) {
setOperation.add(it.next());
}
return setOperation;
}
/**
* 获得缓存的set
*
* @param key
* @return
*/
public <T> Set<T> getCacheSet(final String key) {
return redisTemplate.opsForSet().members(key);
}
/**
* 缓存Map
*
* @param key
* @param dataMap
*/
public <T> void setCacheMap(final String key, final Map<String, T> dataMap) {
if (dataMap != null) {
redisTemplate.opsForHash().putAll(key, dataMap);
}
}
/**
* 缓存Map
*
* @param key
*/
public <T> void setOneMap(final String key, Object hashKey, Object value) {
redisTemplate.opsForHash().put(key, hashKey, value);
}
/**
* 获得缓存的Map
*
* @param key
* @return
*/
public <T> Map<String, T> getCacheMap(final String key) {
return redisTemplate.opsForHash().entries(key);
}
/**
* 往Hash中存入数据
*
* @param key Redis键
* @param hKey Hash键
* @param value 值
*/
public <T> void setCacheMapValue(final String key, final String hKey, final T value) {
redisTemplate.opsForHash().put(key, hKey, value);
}
/**
* 获取Hash中的数据
*
* @param key Redis键
* @param hKey Hash键
* @return Hash中的对象
*/
public <T> T getCacheMapValue(final String key, final String hKey) {
HashOperations<String, String, T> opsForHash = redisTemplate.opsForHash();
return opsForHash.get(key, hKey);
}
/**
* 获取多个Hash中的数据
*
* @param key Redis键
* @param hKeys Hash键集合
* @return Hash对象集合
*/
public <T> List<T> getMultiCacheMapValue(final String key, final Collection<Object> hKeys) {
return redisTemplate.opsForHash().multiGet(key, hKeys);
}
/**
* 获得缓存的基本对象列表
*
* @param pattern 字符串前缀
* @return 对象列表
*/
public Collection<String> keys(final String pattern) {
return redisTemplate.keys(pattern);
}
}
import com.example.mysqlredismqdemo.entity.Goods;
import com.example.mysqlredismqdemo.mapper.GoodsMapper;
import com.example.mysqlredismqdemo.utils.RedisCache;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author wen
* @date 2023/09/19
*/
@Component
@Slf4j
public class SystemAddOrderConfig {
@Resource
private RedisCache redisCache;
@Resource
private GoodsMapper goodsMapper;
@PostConstruct
public void addOrder() {
redisCache.deleteObject("goods");//删除redis中的商品库存信息
Integer integer = goodsMapper.selectGoodsNum();//获取商品数量
if (integer != 0) {
List<Goods> goodsList = goodsMapper.selectAll();//获取商品库存信息
Map goodMap = new HashMap();
goodsList.forEach(c->{
//将数据库的商品库存信息放入redis,存储形式Map: goods:商品id:库存数量
goodMap.put(c.getId(), c.getGoodsnum());
});
redisCache.setCacheMap("goods",goodMap);
return;
}
log.info("有缓存商品库存");
}
}
import com.example.mysqlredismqdemo.utils.RedisCache;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
@RestController
public class ConfirmOrderController {
@Resource
private RedisCache redisCache;
@Resource
private AmqpTemplate amqpTemplate;
/**
* 下单(扣库存)
*
* @param orderId 商品编号
* @param number 数量
* @return {@link String}
*/
@PostMapping("/confirm")
public String confirmOrder(Long orderId, Integer number) throws JsonProcessingException {
//todo 校验入参和库存
Map<String, Object> goodsMap = redisCache.getCacheMap("goods");//获取商品库存信息
//同步锁
synchronized (this){
Integer goodsnum =(Integer) goodsMap.get(orderId);
if (goodsnum == null) {
throw new RuntimeException("商品为空");
}
if (goodsnum == 0) {
throw new RuntimeException("库存不足");
}
if (goodsnum < number) {
throw new RuntimeException("库存不足");
}
//扣库存
redisCache.setOneMap("goods", orderId, goodsnum - number);
//将商品信息发送至MQ
Map sendMessageMap = new HashMap<>();
sendMessageMap.put("id",orderId);
sendMessageMap.put("num",goodsnum - number);
ObjectMapper objectMapper = new ObjectMapper();
String s = objectMapper.writeValueAsString(sendMessageMap);
amqpTemplate.convertAndSend("DirectExchange", "queue1-1", s);
}
return "成功";
}
}
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import java.io.IOException;
@Component
public class RevieMQ {
@RabbitListener(queues = "queue1")
public void review(String msg, Message message, Channel channel) throws IOException {
System.out.println("监听到队列1发送的消息:"+msg);
//todo 同步数据库
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);//MQ回调
}
}
欢迎大家提出自己的疑惑点
文章浏览阅读424次。Lookup所有相关的函数全在net包下的doc.go中LookupHost(host string) (addrs []string, err error)对某个主机名执行DNS查询,返回主机名,注意返回的是字符窜slice.可能有多个IP地址 addr, _ := net.LookupHost("www.baidu.com") fmt.Println(addr) // ..._net.lookhost
文章浏览阅读2.2w次,点赞13次,收藏136次。来自:开源最前线(ID:OpenSourceTop)链接:https://fosspost.org/lists/open-source-speech-recognition-speec..._c语言 开源 图片转文字
文章浏览阅读2.7k次。原文第一版发表于我的个人空间:https://www.imhou.com写在前面:项目过程中,有些需要维护的项目是用的php5版本,但是新项目却是用的php7版本,难免在代码和服务器上有些许不兼容,导致在一台服务器上搭建环境也不太好配置,要考虑软件的兼容问题,实在麻烦。所以就想到用Docker来创建镜像,各自运行在对应的容器中,互不干扰,很好地利用来服务器资源。准备:阿里云账户..._dockerfile from php5
文章浏览阅读5.6k次。maven默认是使用tomcat6跑项目的,这段是让maven用tomcat7去跑在pom.xml中添加<build> <!-- we dont want the version to be part of the generated war file name --> <finalName>${project.artifactId}<..._tomcat8-maven-plugin 修改t端口
文章浏览阅读1.2k次。本文翻译自vdbench的使用手册中的数据校验章节,如有纰漏,还请不吝赐教。vdbench源码下载地址:https://www.oracle.com/downloads/server-storage/vdbench-source-downloads.html数据校验在性能测试的时候不应该被使用,处理器开销可能影响性能测试的结果。在我开始之前,我想问一个想了很多次的问题:“为什么我使用vdbench去检查数据冲突?我也可以写一个大文件,计算校验和,然后重新读这个文件并比较校验和。”当然,你可._vdbench 'data_errors=50' requested
文章浏览阅读8.8k次。目的:使用.netcore自带的kestrel加载自己指定的ssl首先准备ssl文件:(密码为:123456)代码如下:using System;using System.Collections.Generic;using System.IO;using System.Linq;using System.Threading.Tasks;using Microsoft.AspNe..._asp.net core3.1配置ssl证书
文章浏览阅读1.2k次。1.表中是道琼斯工业指数(DJIA)和标准普尔500种股票指数(S&P500)1988年至1997年对应股票的收益率资料:年份DJIA收益率(%)S&P500收益率(%)年份DJIA收益率(%)S&P500收益率(%)198816.016.6199316.810.1198931.731.519944.91.31990-0.4-3.2199536.437.6199123.93..._matlab polyfit f检验显著性检验
文章浏览阅读694次。通过调节PWM占空比,我们可以控制LED的亮度。为了实现这一功能,我们可以利用单片机的PWM(脉冲宽度调制)功能来调节LED的亮度。在仿真过程中,你将看到LED的亮度逐渐增加然后逐渐降低,这是由代码中的循环控制的。通过这种方式,我们可以验证代码的正确性,并确保LED的亮度可以按预期进行调节。首先,将单片机的一个PWM输出引脚连接到LED的正极,将LED的负极连接到单片机的地(GND)引脚。确保连接正确无误后,我们可以开始编写代码。下面是一个简单的示例代码,演示如何使用单片机的PWM功能来控制LED的亮度。_单片机pwm控制led亮度程序
文章浏览阅读7k次,点赞6次,收藏20次。1、ubuntu 下播放 yuv 格式的文件1)使用ffplaysudo apt-get install ffmpeg查看图片ffplay -f rawvideo -video_size 640x360 test_input_640x360_bak.yuv另外,windows下面可以使用yuvplayer.exe,打开需要设置size,软件下载链接http://..._安装ufraw
文章浏览阅读7.4k次,点赞6次,收藏16次。项目主要有zxing的基本使用,包含扫描回调、连续扫描、自定义扫描框:一、依赖库implementation 'com.journeyapps:zxing-android-embedded:4.3.0'Github这个库是zxing Android端的,封装了一些基本的使用方法二、基本使用这里使用的是startActivityForResult的替代方法,registerForActivityResult..._scanoptions scancontract zxing
文章浏览阅读6.1k次,点赞6次,收藏33次。路由器是一种网络设备,它的主要功能是在不同的网络之间转发数据包,实现网络互联。路由器根据数据包的目的地址,选择最佳的路径,将数据包发送到下一跳。路由器可以连接不同的网络类型,如以太网、帧中继、PPP等。路由器上有多种不同的接口,用于连接不同的网络或设备。其中最常见的两种接口是以太网接口和串口。本文就给大家介绍一下以太网接口和串口,让我们直接开始!_网口和串口的区别
文章浏览阅读1.8k次,点赞3次,收藏2次。这里写自定义目录标题欢迎使用Markdown编辑器新的改变功能快捷键合理的创建标题,有助于目录的生成如何改变文本的样式插入链接与图片如何插入一段漂亮的代码片生成一个适合你的列表创建一个表格设定内容居中、居左、居右SmartyPants创建一个自定义列表如何创建一个注脚注释也是必不可少的KaTeX数学公式新的甘特图功能,丰富你的文章UML 图表FLowchart流程图导出与导入导出导入欢迎使用Markdown编辑器你好! 这是你第一次使用 Markdown编辑器 所展示的欢迎页。如果你想学习如何使用Mar_unity 两个空白报错