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

短链接服务

news 来源：原创 2025/6/17 14:02:18

一功能描述

1.短链接是将长连接转化为短连接使得链接变得美观清爽，让用户点击率更高，同时规避原始链接中一些关键词、域名屏蔽等问题，最终利用短链每次跳转都需要经过后端的特性，在跳转过程中做异步埋点，用于效果数据统计

2.本系统支持，同一个短链，不同浏览器跳转不同链接地址(如：谷歌，火狐，360浏览器等)，不同区域跳转不同链接地址(如：cn,us等)，不同系统跳转不同链接地址(如android,ios,windows等)，不同平台跳转不同地址(如：手机端，pc端)

二难点

1.短链接生成规则(保证唯一且简短)
这里的"短链码"，在本文中它的含义是短链接URL的路径部分（为了节省长度，除了协议和域名部分，短链的URL只有第一段路径）：
其中，协议部分基本是固定为https://（从安全性来看不建议使用http://），短链域名可以购买尽可能长度短的域名如t.cn，不过有先见之明的资本家一般会把所有优质的短域名买下并且把价格提到很高，所以域名的长度基本也是很难控制的因素，剩下可控的就是短链码部分。短链码部分是可控的，但因为它是URL的一部分，只要确保所使用的字符不会被URL编码转义，那么长度是人为可控的。假设我们使用的是26个字母的大小写，加上10个数字，那么对于N位压缩码可以表示的最大组合数量为：

N = 4，组合数为62 ^ 4 = 14_776_336，147万接近148万

N = 5，组合数为62 ^ 5 = 916_132_832，9.16亿左右

N = 6，组合数为62 ^ 6 = 56_800_235_584，568亿左右

下面是短链码生成规则：

  public String getCompressionCode(int length) {long sequence = snowflakeHelper.next();String code = ConversionUtils.X.encode62(sequence);if(length>code.length()) {throw new RuntimeException("输入的压缩码长度超过序列长度,压缩码长度不能超过"+code.length());}code = code.substring(code.length() - length);return code;}

2.重定向安全与高并发设计
黑名单，限流等手段的设计保证了重定向的安全性，同时缓存的设计保证了并发的性能，布隆过滤器对恶意请求的拦截保证了系统的稳定性

三代码结构

在这里插入图片描述

四架构设计

在这里插入图片描述

五技术栈

1.springboot
2.redis缓存
3.ipbd,ip2region
4.布隆过滤器

六项目演示

在这里插入图片描述

七部分代码

1.限流代码

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface ApiRateLimiter {String name();
}

@Component
@Aspect
public class ApiRateLimitAspect {@Autowiredprivate RedissonClient redissonClient;@Autowiredprivate ShlinkProperties shlinkProperties;@Pointcut("@annotation(com.zenglx.shlink.server.helper.aop.ApiRateLimiter)")public void rateLimitPoint() {}@Around("rateLimitPoint()")public Object aroundAop(ProceedingJoinPoint joinPoint) throws Throwable {if(shlinkProperties.getRateLimit().getEnabled()) {Method method = ((MethodSignature) joinPoint.getSignature()).getMethod();ApiRateLimiter apiRateLimiter = AnnotationUtils.getAnnotation(method, ApiRateLimiter.class);if (null == apiRateLimiter) {return joinPoint.proceed();}ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();HttpServletRequest request = attributes.getRequest();String accessKey = request.getHeader(ShlinkConstant.ACCESS_KEY);List<String> rateLimtAccessKeyList = shlinkProperties.getRateLimit().getAccessKeyList();if(rateLimtAccessKeyList.contains(accessKey)) {log.debug("限流启动...:{}",accessKey);long rate = shlinkProperties.getRateLimit().getRate();long rateInterval = shlinkProperties.getRateLimit().getRateInterval();//时效时间，分钟long expire = shlinkProperties.getRateLimit().getExpire();RRateLimiter rateLimiter = redissonClient.getRateLimiter(accessKey);//设置过期时间rateLimiter.expire(Duration.ofMinutes(expire));//1s内总许可数不超过3个rateLimiter.trySetRate(RateType.OVERALL, rate, rateInterval, RateIntervalUnit.SECONDS);//申请1份许可，如果2s内未申请到就放弃if (rateLimiter.tryAcquire(shlinkProperties.getRateLimit().getPermits(), shlinkProperties.getRateLimit().getTimeout(), TimeUnit.SECONDS)) {return joinPoint.proceed();} else {throw new RuntimeException("服务器繁忙，请稍后重试......");}} else {return joinPoint.proceed();}} else {return joinPoint.proceed();}}
}

  @ApiRateLimiter(name = "generator")public SingleResult<ShortLinkVo> generator(@RequestBody ShortLinkFo shortLinkFo, HttpServletRequest request) {String accessKey = request.getHeader(ShlinkConstant.ACCESS_KEY);ShortLinkVo shortLinkVo = shortLinkService.generator(shortLinkFo,accessKey);return SingleResult.success(shortLinkVo);}

2.布隆过滤器使用

@Order(value = Integer.MIN_VALUE + 2)
@Component
public class BloomFilter implements WebFilter, InitializingBean,BaseFilter {@Autowiredprivate WebFluxServerResponseWriter webFluxServerResponseWriter;@Autowiredprivate ShortLinkMapper shortLinkMapper;@Autowiredprivate ShlinkProperties shlinkProperties;@Autowiredprivate RedissonClient redissonClient;private RBloomFilter<Object> bloomFilter;@Override@NonNullpublic Mono<Void> filter(ServerWebExchange exchange, @NonNull WebFilterChain chain) {ServerHttpRequest request = exchange.getRequest();String path = request.getPath().toString();if(ignore(path)) {return chain.filter(exchange);}if(shlinkProperties.getBloom().getEnabled()) {String compressCode = path.replace("/","");if(bloomFilter.contains(compressCode)) {return chain.filter(exchange);}log.warn("请求异常,bloom异常压缩码[compressCode:{}:{}]", compressCode, request.getURI());return webFluxServerResponseWriter.redirect(exchange, shlinkProperties.getBloom().getErrorPage());} else {return chain.filter(exchange);}}@Overridepublic void afterPropertiesSet() throws Exception {if(shlinkProperties.getBloom().getEnabled()) {bloomFilter = redissonClient.getBloomFilter(CacheKey.BLOOM_FILTER.getKey());if(!bloomFilter.isExists()) {bloomFilter.tryInit(shlinkProperties.getBloom().getExpectedSize(),shlinkProperties.getBloom().getFpp());log.warn("bloom过滤器初始化......");}//查询最近两天的，初始化List<String> compressCodeList = shortLinkMapper.listCompressCode();if(CollectionUtils.isEmpty(compressCodeList)) {bloomFilter.add("init");}Optional.of(compressCodeList).orElse(new ArrayList<>()).forEach(compressCode -> {if(!bloomFilter.contains(compressCode)) {bloomFilter.add(compressCode);}});log.warn("bloom过滤器初始化......完成，数量：{}",compressCodeList.size());}}
}

一 功能描述

二 难点

三 代码结构

四 架构设计

五 技术栈

六 项目演示

七 部分代码

1.限流代码

2.布隆过滤器使用

相关文章：

一功能描述

二难点

三代码结构

四架构设计

五技术栈

六项目演示

七部分代码