当前位置： 首页 > wzjs >正文

pc端兼手机端网站模板路桥建设网站

wzjs 2025/9/6 23:28:46
pc端兼手机端网站模板,路桥建设网站,东莞最好的网站建设价格,互联网推广属于什么行业基于Spring Boot集成Redisson实现布隆过滤器 在高并发和大数据量的场景下，布隆过滤器是一种非常高效的存储结构，可以用于快速判断一个元素是否存在于集合中。本文将介绍如何在Spring Boot中集成Redisson来实现布隆过滤器，并通过一个订单查询…

基于Spring Boot集成Redisson实现布隆过滤器

在高并发和大数据量的场景下，布隆过滤器是一种非常高效的存储结构，可以用于快速判断一个元素是否存在于集合中。本文将介绍如何在Spring Boot中集成Redisson来实现布隆过滤器，并通过一个订单查询的示例来展示其应用。

1. 项目搭建

1.1 创建Spring Boot项目

首先，创建一个Spring Boot项目，并添加以下依赖：

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.redisson</groupId><artifactId>redisson-spring-boot-starter</artifactId><version>3.23.0</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency>
</dependencies>

1.2 配置Redisson

在application.yml文件中配置Redisson的连接信息：

spring:application:name: redisson-bloom-filter-demoredisson:config:single-server-config:address: "redis://127.0.0.1:6379"password: "your-redis-password"database: 0connection-pool-config:max-idle: 10min-idle: 1max-active: 100min-evictable-idle-time: 300000time-between-eviction-runs: 30000block-wait-time: 1000idle-instance-soft-abandon: falseidle-instance-close-timeout: 30000bloom:filter:expected-insertions: 1000000  # 预期插入数量，默认值为 1000000false-probability: 0.03       # 误判率，默认值为 3%

2. 布隆过滤器实现

2.1 创建布隆过滤器服务

创建一个BloomFilterService类，用于初始化和操作布隆过滤器：

package com.example.redission.service;import org.redisson.api.RBloomFilter;
import org.redisson.api.RedissonClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;@Service
public class BloomFilterService {private static final Logger logger = LoggerFactory.getLogger(BloomFilterService.class);@Value("${bloom.filter.expected-insertions:1000000}")private long expectedInsertions;@Value("${bloom.filter.false-probability:0.03}")private double falseProbability;private static final String BLOOM_FILTER_NAME = "bloomFilter";private final RedissonClient redissonClient;private RBloomFilter<String> bloomFilter;public BloomFilterService(RedissonClient redissonClient) {this.redissonClient = redissonClient;}public synchronized void initBloomFilter() {if (bloomFilter == null) {bloomFilter = redissonClient.getBloomFilter(BLOOM_FILTER_NAME);// 检查布隆过滤器是否已经初始化if (!bloomFilter.isExists()) {bloomFilter.tryInit(expectedInsertions, falseProbability);logger.info("Bloom filter initialized with expected insertions: {} and false probability: {}",expectedInsertions, falseProbability);} else {logger.info("Bloom filter already exists, using existing instance");}}}public void add(String key) {if (key == null) {logger.warn("Attempt to add null key to Bloom filter");return;}bloomFilter.add(key);logger.debug("Added key: {} to Bloom filter", key);}public boolean contains(String key) {if (key == null) {logger.warn("Attempt to check null key in Bloom filter");return false;}boolean result = bloomFilter.contains(key);logger.debug("Checked key: {} in Bloom filter, result: {}", key, result);return result;}/*** 重新初始化布隆过滤器（仅在需要清空时调用）*/public synchronized void reinitialize() {bloomFilter.delete();bloomFilter.tryInit(expectedInsertions, falseProbability);logger.info("Bloom filter reinitialized");}/*** 获取布隆过滤器的错误概率*/public double getFalseProbability() {return falseProbability;}/*** 获取布隆过滤器的预期插入数量*/public long getExpectedInsertions() {return expectedInsertions;}
}

2.2 初始化布隆过滤器

创建一个BloomFilterInitializer类，在应用启动时初始化布隆过滤器：

package com.example.redission.runner;import com.example.redission.dto.OrderDetailDTO;
import com.example.redission.service.BloomFilterService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;import java.math.BigDecimal;
import java.util.Arrays;
import java.util.List;@Component
public class BloomFilterInitializer implements CommandLineRunner {private static final Logger logger = LoggerFactory.getLogger(BloomFilterInitializer.class);private final BloomFilterService bloomFilterService;@Autowiredpublic BloomFilterInitializer(BloomFilterService bloomFilterService) {this.bloomFilterService = bloomFilterService;}@Overridepublic void run(String... args) throws Exception {// 在应用启动时初始化布隆过滤器bloomFilterService.initBloomFilter();logger.info("Bloom filter initialized during application startup");// 模拟订单数据并写入布隆过滤器List<OrderDetailDTO> orderData = generateSampleOrderData();initializeBloomFilterWithOrderData(orderData);}private void initializeBloomFilterWithOrderData(List<OrderDetailDTO> orderData) {// 将订单数据写入布隆过滤器for (OrderDetailDTO order : orderData) {// 将订单号写入布隆过滤器bloomFilterService.add(order.getOrderNumber());// 将订单中的商品 SKU ID 写入布隆过滤器for (OrderDetailDTO.OrderItemDTO item : order.getItems()) {bloomFilterService.add(item.getSkuId());}}logger.info("Bloom filter initialized with {} orders and their items", orderData.size());}private List<OrderDetailDTO> generateSampleOrderData() {// 使用 Arrays.asList 替代 List.of（JDK 8 兼容）return Arrays.asList(new OrderDetailDTO("1","ORD-001",new BigDecimal("100.00"),"COMPLETED","PAID","2024-01-01 12:00:00",Arrays.asList(new OrderDetailDTO.OrderItemDTO("SKU-001","Product 1","image1.jpg",2,new BigDecimal("50.00"),new BigDecimal("100.00")))),new OrderDetailDTO("2","ORD-002",new BigDecimal("200.00"),"COMPLETED","PAID","2024-01-02 12:00:00",Arrays.asList(new OrderDetailDTO.OrderItemDTO("SKU-002","Product 2","image2.jpg",1,new BigDecimal("200.00"),new BigDecimal("200.00")))));}
}

3. 订单查询功能实现

3.1 创建订单查询服务

创建一个OrderDetailDTO类：

package com.example.redission.dto;import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;import java.math.BigDecimal;
import java.util.List;@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class OrderDetailDTO {private String orderId; // 订单IDprivate String orderNumber; // 订单号private BigDecimal totalAmount; // 总金额private String orderStatus; // 订单状态private String paymentStatus; // 支付状态private String createTime; // 创建时间private List<OrderItemDTO> items; // 订单商品项@Data@AllArgsConstructor@NoArgsConstructor@Builderpublic static class OrderItemDTO {private String skuId; // 商品SKU IDprivate String skuName; // 商品名称private String skuImage; // 商品图片private int quantity; // 商品数量private BigDecimal price; // 商品单价private BigDecimal subtotal; // 商品小计}}

创建一个OrderQueryService类，用于查询订单信息：

package com.example.redission.service;import com.example.redission.dto.OrderDetailDTO;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.math.BigDecimal;
import java.util.Arrays;@Service
public class OrderQueryService {private static final Logger logger = LoggerFactory.getLogger(OrderQueryService.class);private final BloomFilterService bloomFilterService;@Autowiredpublic OrderQueryService(BloomFilterService bloomFilterService) {this.bloomFilterService = bloomFilterService;}/*** 查询订单信息** @param orderNumber 订单号* @return 订单信息，如果不存在则返回 null*/public OrderDetailDTO getOrderDetails(String orderNumber) {// 先通过布隆过滤器判断订单号是否存在if (!bloomFilterService.contains(orderNumber)) {logger.info("Order {} does not exist in Bloom filter", orderNumber);return null;}// 模拟订单数据OrderDetailDTO order = generateSampleOrderData(orderNumber);if (order != null) {logger.info("Order {} found in simulated data", orderNumber);return order;} else {logger.info("Order {} exists in Bloom filter but not found in simulated data", orderNumber);return null;}}/*** 模拟生成订单数据** @param orderNumber 订单号* @return 模拟的订单数据*/private OrderDetailDTO generateSampleOrderData(String orderNumber) {// 模拟的订单数据if ("ORD-001".equals(orderNumber)) {return new OrderDetailDTO("1","ORD-001",new BigDecimal("100.00"),"COMPLETED","PAID","2024-01-01 12:00:00",Arrays.asList(new OrderDetailDTO.OrderItemDTO("SKU-001","Product 1","image1.jpg",2,new BigDecimal("50.00"),new BigDecimal("100.00"))));} else if ("ORD-002".equals(orderNumber)) {return new OrderDetailDTO("2","ORD-002",new BigDecimal("200.00"),"COMPLETED","PAID","2024-01-02 12:00:00",Arrays.asList(new OrderDetailDTO.OrderItemDTO("SKU-002","Product 2","image2.jpg",1,new BigDecimal("200.00"),new BigDecimal("200.00"))));}return null;}
}

3.2 创建订单查询控制器

创建一个OrderQueryController类，用于处理订单查询的HTTP请求：

package com.example.redission.controller;import com.example.redission.dto.OrderDetailDTO;
import com.example.redission.service.OrderQueryService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/api/orders")
public class OrderQueryController {private static final Logger logger = LoggerFactory.getLogger(OrderQueryController.class);private final OrderQueryService orderQueryService;@Autowiredpublic OrderQueryController(OrderQueryService orderQueryService) {this.orderQueryService = orderQueryService;}/*** 查询订单信息** @param orderNumber 订单号* @return 订单信息，如果不存在则返回 null*/@GetMapping("/{orderNumber}")public OrderDetailDTO getOrderDetails(@PathVariable String orderNumber) {OrderDetailDTO order = orderQueryService.getOrderDetails(orderNumber);logger.info("Query order {}: result = {}", orderNumber, order);return order;}
}

4. 测试与验证

启动应用后，可以通过以下API接口进行测试：

  • 查询订单信息：GET /api/orders/{orderNumber}

示例请求

查询订单信息
GET /api/orders/ORD-001

示例响应

如果订单存在：

{"orderId": "1","orderNumber": "ORD-001","totalAmount": 100.00,"orderStatus": "COMPLETED","paymentStatus": "PAID","createTime": "2024-01-01 12:00:00","items": [{"skuId": "SKU-001","skuName": "Product 1","skuImage": "image1.jpg","quantity": 2,"price": 50.00,"subtotal": 100.00}]
}

5. 总结

通过本文的示例，我们展示了如何在Spring Boot中集成Redisson来实现布隆过滤器，并通过订单查询功能展示了其应用。布隆过滤器可以有效地减少数据库查询的次数，提高系统的性能和响应速度。在实际应用中，可以根据业务需求调整布隆过滤器的参数，以达到最佳的性能和误判率平衡。


文章转载自：

http://tlrR6Q8c.thzgd.cn
http://UUbs6pEn.thzgd.cn
http://h4mDT2ik.thzgd.cn
http://dflp07nD.thzgd.cn
http://o0dwCm6b.thzgd.cn
http://49RRfS1k.thzgd.cn
http://nsNrKsi1.thzgd.cn
http://9Kmp7YfW.thzgd.cn
http://5V9N8XjL.thzgd.cn
http://cLQxZQHP.thzgd.cn
http://qKDLA3Wl.thzgd.cn
http://0QB4aqTp.thzgd.cn
http://o0pOx1Oi.thzgd.cn
http://2ka5E1b9.thzgd.cn
http://c23yfuT9.thzgd.cn
http://L9OD2DQx.thzgd.cn
http://r5fJqugI.thzgd.cn
http://vTE1A3YZ.thzgd.cn
http://vfEizd7a.thzgd.cn
http://K2oj3yjy.thzgd.cn
http://Uz0Pl6pR.thzgd.cn
http://EqpdQgK6.thzgd.cn
http://UaHUxwHN.thzgd.cn
http://0jgpASFy.thzgd.cn
http://jkjpz4KR.thzgd.cn
http://ib2XzZxB.thzgd.cn
http://CNq0GCv5.thzgd.cn
http://YDxdC7KJ.thzgd.cn
http://K91FOpJf.thzgd.cn
http://x5eZ8yOE.thzgd.cn
http://www.dtcms.com/wzjs/636234.html

相关文章：

  • 网上如何建网站卖量具西宁网站建设哪家好
  • dz论坛做分类网站自助建站帮助网
  • 中山网站软件品牌营销咨询
  • 泰安集团网站建设网页设计个人总结800字
  • 做书app下载网站有哪些内容商城网站设计需要哪些技术
  • 游戏网站logo制作小程序开发平台好牌子推荐
  • 网站后台的搭建嘉兴首页
  • 怎么在网站上做下载做网站租用那个服务器好
  • 简述网站设计的原则泉州手机网站开发
  • 德阳网站开发熊掌号深圳网络运营推广公司
  • 网站开发人员职能职业技能培训学校
  • 建设银行网站上不去了房地产网站建设策划方案
  • 凡科建站代理登录微信静首页制作代码
  • 龙腾盛世网站建设肥东网站建设
  • 顺德品牌网站建设信息如何做好一个外贸进网站的编辑
  • 信用中国 网站 支持建设住房与城市建设部网站
  • 北京自助企业建站模板汽修网站建设免费
  • 网站检测报告哪里做wordpress还有价值么
  • 400网站推广备案 网站名
  • wap网站建设公司公司网站建设素材
  • 哪个网站可以找题目给小孩做市场营销策划咨询
  • 正规网站建设费用鄂州网上房地产
  • 网站开发综合课程设计网站上线后
  • 青岛网站空间公司建站网站
  • 网站建设租用服务器网站怎么做引流
  • 2023来个网站可以看的视频拍摄报价单
  • 台州做微网站自己创建一个网站
  • 网站设计开发制作建立网站程序
  • 代刷网站建设ps网页设计流程
  • 网站建设细节邢台建网站找谁