Compare commits
5 Commits
02c744d8ca
...
9b1336f408
| Author | SHA1 | Date |
|---|---|---|
heqijun
|
9b1336f408 | 4 months ago |
|
heqijun
|
af29eb818c | 4 months ago |
|
heqijun
|
7f38c0bf75 | 4 months ago |
|
heqijun
|
9c0e6cb4e3 | 4 months ago |
|
heqijun
|
51a80b9099 | 4 months ago |
@ -1,42 +0,0 @@
|
||||
package com.mashibing.api.feignClient;
|
||||
|
||||
import org.springframework.cloud.openfeign.FeignClient;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: BeaconCacheClient
|
||||
* @Description: 缓存模块openFeignClient接口
|
||||
* @date 2025/6/5 20:13
|
||||
*/
|
||||
|
||||
@FeignClient("beacon-cache")
|
||||
@RequestMapping("cache")
|
||||
public interface CacheClient {
|
||||
@GetMapping("get/{key}")
|
||||
String get(@PathVariable String key);
|
||||
|
||||
@GetMapping("set/{key}/{value}")
|
||||
void set(@PathVariable String key, @PathVariable String value);
|
||||
|
||||
@GetMapping("hget/{key}")
|
||||
Map hget(@PathVariable String key);
|
||||
|
||||
@GetMapping("/hget/{key}/{field}")
|
||||
Object hget(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
|
||||
|
||||
@GetMapping("/hgetString/{key}/{field}")
|
||||
String hgetString(@PathVariable(value = "key") String key, @PathVariable(value = "field") String field);
|
||||
|
||||
@PostMapping("hset/{key}")
|
||||
void hset(@PathVariable String key, @RequestBody Map hash);
|
||||
|
||||
@PostMapping("/sadd/{key}")
|
||||
void sadd(@PathVariable(value = "key") String key, @RequestBody Map<String, Object>... maps);
|
||||
|
||||
@PostMapping("/smember/{key}")
|
||||
Set<Map> smember(@PathVariable(value = "key") String key);
|
||||
}
|
||||
@ -0,0 +1,20 @@
|
||||
package com.mashibing.api.feignclient;
|
||||
|
||||
import com.mashibing.common.clients.BeaconCacheClient;
|
||||
import org.springframework.cloud.openfeign.FeignClient;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: BeaconCacheClient
|
||||
* @Description: 缓存模块openFeignClient接口
|
||||
* @date 2025/6/5 20:13
|
||||
*/
|
||||
|
||||
@FeignClient("beacon-cache")
|
||||
public interface CacheClient extends BeaconCacheClient {
|
||||
|
||||
}
|
||||
@ -0,0 +1,58 @@
|
||||
<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
<parent>
|
||||
<groupId>com.mashibing</groupId>
|
||||
<artifactId>beacon-cloud</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
<relativePath>../pom.xml</relativePath>
|
||||
</parent>
|
||||
|
||||
<artifactId>beacon-strategy</artifactId>
|
||||
|
||||
|
||||
<dependencies>
|
||||
<!-- web -->
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-web</artifactId>
|
||||
</dependency>
|
||||
<!-- nacos注册中心 -->
|
||||
<dependency>
|
||||
<groupId>com.alibaba.cloud</groupId>
|
||||
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
|
||||
</dependency>
|
||||
<!-- nacos配置中心 -->
|
||||
<dependency>
|
||||
<groupId>com.alibaba.cloud</groupId>
|
||||
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.cloud</groupId>
|
||||
<artifactId>spring-cloud-starter-openfeign</artifactId>
|
||||
</dependency>
|
||||
<!-- AMQP -->
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-amqp</artifactId>
|
||||
</dependency>
|
||||
<!-- 测试 -->
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-test</artifactId>
|
||||
</dependency>
|
||||
<!-- lombok -->
|
||||
<dependency>
|
||||
<groupId>org.projectlombok</groupId>
|
||||
<artifactId>lombok</artifactId>
|
||||
</dependency>
|
||||
<!-- common公共组件 -->
|
||||
<dependency>
|
||||
<groupId>com.mashibing</groupId>
|
||||
<artifactId>beacon-common</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
</project>
|
||||
@ -0,0 +1,22 @@
|
||||
package com.mashibing.strategy;
|
||||
|
||||
import org.springframework.boot.SpringApplication;
|
||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
|
||||
import org.springframework.cloud.openfeign.EnableFeignClients;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: StragyApplication
|
||||
* @Description: TODO(这里用一句话描述这个类的作用)
|
||||
* @date 2025/6/7 19:03
|
||||
*/
|
||||
|
||||
@SpringBootApplication
|
||||
@EnableFeignClients
|
||||
@EnableDiscoveryClient
|
||||
public class StragyApplication {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(StragyApplication.class, args);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,26 @@
|
||||
package com.mashibing.strategy.config;
|
||||
|
||||
import com.mashibing.common.constant.RabbitMQConstant;
|
||||
import org.springframework.amqp.core.Queue;
|
||||
import org.springframework.amqp.core.QueueBuilder;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: RabbitMQConfig
|
||||
* @Description: RabbitMQConfig
|
||||
* @date 2025/6/8 17:46
|
||||
*/
|
||||
|
||||
@Configuration
|
||||
public class RabbitMQConfig {
|
||||
|
||||
/**
|
||||
* 构建策略模块发送【手机号归属地和运营商】到后台管理模块的队列名称
|
||||
*/
|
||||
@Bean
|
||||
public Queue preSendQueue() {
|
||||
return QueueBuilder.durable(RabbitMQConstant.MOBILE_AREA_OPERATOR).build();
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,43 @@
|
||||
package com.mashibing.strategy.config;
|
||||
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.amqp.core.Message;
|
||||
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
|
||||
import org.springframework.amqp.rabbit.connection.CorrelationData;
|
||||
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: RabbitMQTemplateConfig
|
||||
* @Description: 配置RabbitMQTemplate的confirm和return机制
|
||||
* @date 2025/6/8 17:52
|
||||
*/
|
||||
|
||||
@Configuration
|
||||
@Slf4j
|
||||
public class RabbitMQTemplateConfig {
|
||||
|
||||
@Bean
|
||||
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
|
||||
|
||||
//设置connectionFactory
|
||||
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
|
||||
|
||||
//配置confirm机制回调
|
||||
rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
|
||||
//消息妹有发送到交换机
|
||||
if (!ack) {
|
||||
log.error("【策略模块-发送消息】消息没有发送到交换机。。。" +
|
||||
"\n correlationData={},ack={},cause:{} ", correlationData, ack, cause);
|
||||
}
|
||||
});
|
||||
|
||||
//配置return机制回调
|
||||
rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> log.error("【策略模块-发送消息】消息没有路由到指定的队列。。。" +
|
||||
"\nmessage={},exchange={},routingKey={}", new String(message.getBody()), exchange, routingKey));
|
||||
|
||||
return rabbitTemplate;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,21 @@
|
||||
package com.mashibing.strategy.config;
|
||||
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
import org.springframework.web.client.RestTemplate;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: RestTemplateConfig
|
||||
* @Description: TODO(这里用一句话描述这个类的作用)
|
||||
* @date 2025/6/8 16:33
|
||||
*/
|
||||
|
||||
@Configuration
|
||||
public class RestTemplateConfig {
|
||||
|
||||
@Bean
|
||||
public RestTemplate restTemplate() {
|
||||
return new RestTemplate();
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,23 @@
|
||||
package com.mashibing.strategy.feignclient;
|
||||
|
||||
import com.mashibing.common.clients.BeaconCacheClient;
|
||||
import org.springframework.cloud.openfeign.FeignClient;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.PathVariable;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RequestBody;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: BeaconCacheClient
|
||||
* @Description: 缓存模块openFeignClient接口
|
||||
* @date 2025/6/7 20:16
|
||||
*/
|
||||
|
||||
@FeignClient("beacon-cache")
|
||||
public interface CacheClient extends BeaconCacheClient {
|
||||
|
||||
}
|
||||
@ -0,0 +1,31 @@
|
||||
package com.mashibing.strategy.pojo;
|
||||
|
||||
import com.mashibing.common.annotation.Description;
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: PhasePOJO
|
||||
* @Description: TODO(这里用一句话描述这个类的作用)
|
||||
* @date 2025/6/8 16:39
|
||||
*/
|
||||
|
||||
@Data
|
||||
public class PhasePojo {
|
||||
|
||||
@Description("目标手机号的运营商id")
|
||||
private Integer operatorId;
|
||||
|
||||
@Description("目标手机号的运营商na")
|
||||
private String operatorNa;
|
||||
|
||||
@Description("目标手机号的归属地 哈尔滨， 绥化~")
|
||||
private String area;
|
||||
|
||||
public PhasePojo unknown() {
|
||||
this.operatorId = 0;
|
||||
this.operatorNa = "未知";
|
||||
this.area = "未知 未知";
|
||||
return this;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,19 @@
|
||||
package com.mashibing.strategy.service.strategyfilter;
|
||||
|
||||
import com.mashibing.common.pojo.StandardSubmit;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: StrategyFilter
|
||||
* @Description: 策略校验父接口
|
||||
* @date 2025/6/7 20:24
|
||||
*/
|
||||
|
||||
public interface StrategyFilter {
|
||||
|
||||
/**
|
||||
* 策略校验
|
||||
*/
|
||||
void strategy(StandardSubmit standardSubmit);
|
||||
|
||||
}
|
||||
@ -0,0 +1,47 @@
|
||||
package com.mashibing.strategy.service.strategyfilter;
|
||||
|
||||
import com.mashibing.common.constant.CacheConstant;
|
||||
import com.mashibing.common.pojo.StandardSubmit;
|
||||
import com.mashibing.strategy.feignclient.CacheClient;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang.StringUtils;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: StrategyFilterContext
|
||||
* @Description: 策略模块校验链的执行
|
||||
* @date 2025/6/7 20:32
|
||||
*/
|
||||
|
||||
@Slf4j
|
||||
@Service
|
||||
public class StrategyFilterContext {
|
||||
|
||||
@Autowired
|
||||
private Map<String, StrategyFilter> strategyFilters;
|
||||
|
||||
@Autowired
|
||||
CacheClient cacheClient;
|
||||
|
||||
private final String CLIENT_FILTERS = "clientFilters";
|
||||
|
||||
public void strategy(StandardSubmit standardSubmit) {
|
||||
String s = cacheClient.hgetString(CacheConstant.CLIENT_BUSINESS + standardSubmit.getApikey(), CLIENT_FILTERS);
|
||||
if (StringUtils.isBlank(s)) {
|
||||
log.info("【策略模块-策略为空】没有校验。。。");
|
||||
return;
|
||||
}
|
||||
String[] strategyFilterArr = s.split(",");
|
||||
for (String strategyFilter : strategyFilterArr) {
|
||||
StrategyFilter check = strategyFilters.get(strategyFilter);
|
||||
if (check != null) {
|
||||
check.strategy(standardSubmit);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,23 @@
|
||||
package com.mashibing.strategy.service.strategyfilter.impl;
|
||||
|
||||
import com.mashibing.common.pojo.StandardSubmit;
|
||||
import com.mashibing.strategy.service.strategyfilter.StrategyFilter;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: BlackStrategyFilter
|
||||
* @Description: 黑名单校验
|
||||
* @date 2025/6/7 20:26
|
||||
*/
|
||||
|
||||
@Slf4j
|
||||
@Service(value = "black")
|
||||
public class BlackStrategyFilter implements StrategyFilter {
|
||||
|
||||
@Override
|
||||
public void strategy(StandardSubmit standardSubmit) {
|
||||
log.info("【策略模块-黑名单校验】。。。");
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,23 @@
|
||||
package com.mashibing.strategy.service.strategyfilter.impl;
|
||||
|
||||
import com.mashibing.common.pojo.StandardSubmit;
|
||||
import com.mashibing.strategy.service.strategyfilter.StrategyFilter;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: DirtyWordStrategyFilter
|
||||
* @Description: 敏感词校验
|
||||
* @date 2025/6/7 20:26
|
||||
*/
|
||||
|
||||
@Slf4j
|
||||
@Service(value = "dirtyword")
|
||||
public class DirtyWordStrategyFilter implements StrategyFilter {
|
||||
|
||||
@Override
|
||||
public void strategy(StandardSubmit standardSubmit) {
|
||||
log.info("【策略模块-敏感词校验】。。。");
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,23 @@
|
||||
package com.mashibing.strategy.service.strategyfilter.impl;
|
||||
|
||||
import com.mashibing.common.pojo.StandardSubmit;
|
||||
import com.mashibing.strategy.service.strategyfilter.StrategyFilter;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: RouteStrategyFilter
|
||||
* @Description: 路由校验
|
||||
* @date 2025/6/7 20:26
|
||||
*/
|
||||
|
||||
@Slf4j
|
||||
@Service(value = "route")
|
||||
public class RouteStrategyFilter implements StrategyFilter {
|
||||
|
||||
@Override
|
||||
public void strategy(StandardSubmit standardSubmit) {
|
||||
log.info("【策略模块-路由校验】。。。");
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
# 服务名称
|
||||
spring:
|
||||
application:
|
||||
name: beacon-strategy
|
||||
# 多环境
|
||||
profiles:
|
||||
active: dev
|
||||
# nacos注册中心地址
|
||||
cloud:
|
||||
nacos:
|
||||
discovery:
|
||||
server-addr: 192.168.1.13:8848
|
||||
# nacos配置中心地址:
|
||||
config:
|
||||
server-addr: 192.168.1.13:8848
|
||||
file-extension: yml
|
||||
# beacon-strategy-dev.yml
|
||||
@ -0,0 +1,165 @@
|
||||
package com.mashibing.test.entity;
|
||||
|
||||
public class MobileArea {
|
||||
|
||||
private long id;
|
||||
|
||||
private String mobileNumber;
|
||||
|
||||
private String mobileArea;
|
||||
|
||||
private String mobileType;
|
||||
|
||||
private String areaCode;
|
||||
|
||||
private String postCode;
|
||||
|
||||
private String provinceCode;
|
||||
|
||||
private java.sql.Timestamp created;
|
||||
|
||||
private long createId;
|
||||
|
||||
private java.sql.Timestamp updated;
|
||||
|
||||
private long updateId;
|
||||
|
||||
private long isDelete;
|
||||
|
||||
private String extend1;
|
||||
|
||||
private String extend2;
|
||||
|
||||
private String extend3;
|
||||
|
||||
private String extend4;
|
||||
|
||||
public long getId() {
|
||||
return id;
|
||||
}
|
||||
|
||||
public void setId(long id) {
|
||||
this.id = id;
|
||||
}
|
||||
|
||||
public String getMobileNumber() {
|
||||
return mobileNumber;
|
||||
}
|
||||
|
||||
public void setMobileNumber(String mobileNumber) {
|
||||
this.mobileNumber = mobileNumber;
|
||||
}
|
||||
|
||||
public String getMobileArea() {
|
||||
return mobileArea;
|
||||
}
|
||||
|
||||
public void setMobileArea(String mobileArea) {
|
||||
this.mobileArea = mobileArea;
|
||||
}
|
||||
|
||||
public String getMobileType() {
|
||||
return mobileType;
|
||||
}
|
||||
|
||||
public void setMobileType(String mobileType) {
|
||||
this.mobileType = mobileType;
|
||||
}
|
||||
|
||||
public String getAreaCode() {
|
||||
return areaCode;
|
||||
}
|
||||
|
||||
public void setAreaCode(String areaCode) {
|
||||
this.areaCode = areaCode;
|
||||
}
|
||||
|
||||
public String getPostCode() {
|
||||
return postCode;
|
||||
}
|
||||
|
||||
public void setPostCode(String postCode) {
|
||||
this.postCode = postCode;
|
||||
}
|
||||
|
||||
public String getProvinceCode() {
|
||||
return provinceCode;
|
||||
}
|
||||
|
||||
public void setProvinceCode(String provinceCode) {
|
||||
this.provinceCode = provinceCode;
|
||||
}
|
||||
|
||||
public java.sql.Timestamp getCreated() {
|
||||
return created;
|
||||
}
|
||||
|
||||
public void setCreated(java.sql.Timestamp created) {
|
||||
this.created = created;
|
||||
}
|
||||
|
||||
public long getCreateId() {
|
||||
return createId;
|
||||
}
|
||||
|
||||
public void setCreateId(long createId) {
|
||||
this.createId = createId;
|
||||
}
|
||||
|
||||
public java.sql.Timestamp getUpdated() {
|
||||
return updated;
|
||||
}
|
||||
|
||||
public void setUpdated(java.sql.Timestamp updated) {
|
||||
this.updated = updated;
|
||||
}
|
||||
|
||||
public long getUpdateId() {
|
||||
return updateId;
|
||||
}
|
||||
|
||||
public void setUpdateId(long updateId) {
|
||||
this.updateId = updateId;
|
||||
}
|
||||
|
||||
public long getIsDelete() {
|
||||
return isDelete;
|
||||
}
|
||||
|
||||
public void setIsDelete(long isDelete) {
|
||||
this.isDelete = isDelete;
|
||||
}
|
||||
|
||||
public String getExtend1() {
|
||||
return extend1;
|
||||
}
|
||||
|
||||
public void setExtend1(String extend1) {
|
||||
this.extend1 = extend1;
|
||||
}
|
||||
|
||||
public String getExtend2() {
|
||||
return extend2;
|
||||
}
|
||||
|
||||
public void setExtend2(String extend2) {
|
||||
this.extend2 = extend2;
|
||||
}
|
||||
|
||||
public String getExtend3() {
|
||||
return extend3;
|
||||
}
|
||||
|
||||
public void setExtend3(String extend3) {
|
||||
this.extend3 = extend3;
|
||||
}
|
||||
|
||||
public String getExtend4() {
|
||||
return extend4;
|
||||
}
|
||||
|
||||
public void setExtend4(String extend4) {
|
||||
this.extend4 = extend4;
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
package com.mashibing.test.feignClient;
|
||||
|
||||
import org.springframework.cloud.openfeign.FeignClient;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: BeaconCacheClient
|
||||
* @Description: 缓存模块openFeignClient接口
|
||||
* @date 2025/6/5 20:13
|
||||
*/
|
||||
|
||||
@FeignClient("beacon-cache")
|
||||
@RequestMapping("cache")
|
||||
public interface BeaconCacheClient {
|
||||
@GetMapping("get/{key}")
|
||||
public String get(@PathVariable String key);
|
||||
|
||||
@GetMapping("set/{key}/{value}")
|
||||
public void set(@PathVariable String key, @PathVariable String value);
|
||||
|
||||
@GetMapping("hget/{key}")
|
||||
public Map hget(@PathVariable String key);
|
||||
|
||||
@PostMapping("hset/{key}")
|
||||
public void hset(@PathVariable String key, @RequestBody Map hash);
|
||||
|
||||
@PostMapping("/sadd/{key}")
|
||||
public void sadd(@PathVariable(value = "key") String key, @RequestBody Map<String, Object>... maps);
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,19 @@
|
||||
package com.mashibing.test.feignClient;
|
||||
|
||||
import com.mashibing.common.clients.BeaconCacheClient;
|
||||
import org.springframework.cloud.openfeign.FeignClient;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: BeaconCacheClient
|
||||
* @Description: 缓存模块openFeignClient接口
|
||||
* @date 2025/6/5 20:13
|
||||
*/
|
||||
|
||||
@FeignClient("beacon-cache")
|
||||
public interface CacheClient extends BeaconCacheClient {
|
||||
|
||||
}
|
||||
@ -0,0 +1,20 @@
|
||||
package com.mashibing.test.mapper;
|
||||
|
||||
import com.mashibing.test.entity.MobileArea;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
import org.apache.ibatis.annotations.Select;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: MobileAreaMapper
|
||||
* @Description: TODO(这里用一句话描述这个类的作用)
|
||||
* @date 2025/6/8 14:47
|
||||
*/
|
||||
|
||||
public interface MobileAreaMapper {
|
||||
|
||||
@Select("select mobile_number,mobile_area,mobile_type from mobile_area ")
|
||||
List<MobileArea> findAllMobileArea();
|
||||
}
|
||||
@ -0,0 +1,19 @@
|
||||
package com.mashibing.test.mapper;
|
||||
|
||||
import com.mashibing.test.entity.MobileArea;
|
||||
import org.apache.ibatis.annotations.Select;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @author heqijun
|
||||
* @ClassName: MobileAreaMapper
|
||||
* @Description: TODO(这里用一句话描述这个类的作用)
|
||||
* @date 2025/6/8 14:47
|
||||
*/
|
||||
|
||||
public interface MobileDirtywordMapper {
|
||||
|
||||
@Select("select dirtyword from mobile_dirtyword")
|
||||
List<String> findAllDirtyword();
|
||||
}
|
||||
@ -0,0 +1,45 @@
|
||||
package com.mashibing.test.mapper;
|
||||
|
||||
import com.mashibing.test.entity.MobileArea;
|
||||
import com.mashibing.test.feignClient.CacheClient;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
@Slf4j
|
||||
@SpringBootTest
|
||||
@RunWith(SpringRunner.class)
|
||||
class MobileAreaMapperTest {
|
||||
@Autowired
|
||||
CacheClient cacheClient;
|
||||
|
||||
@Autowired
|
||||
MobileAreaMapper mapper;
|
||||
|
||||
@Test
|
||||
void findAllMobileArea() {
|
||||
long startTime = System.currentTimeMillis();
|
||||
List<MobileArea> allMobileArea = mapper.findAllMobileArea();
|
||||
long endTime = System.currentTimeMillis();
|
||||
log.info("【数据库查询耗时】: {} ms", endTime - startTime);
|
||||
Map<String, String> map = new HashMap<>(allMobileArea.size());
|
||||
startTime = System.currentTimeMillis();
|
||||
allMobileArea.forEach(mobileArea -> {
|
||||
map.put("phase:" + mobileArea.getMobileNumber(),
|
||||
mobileArea.getMobileArea() + "," + mobileArea.getMobileType());
|
||||
});
|
||||
endTime = System.currentTimeMillis();
|
||||
log.info("【List转Map耗时】: {} ms", endTime - startTime);
|
||||
startTime = System.currentTimeMillis();
|
||||
cacheClient.pipelineString(map);
|
||||
endTime = System.currentTimeMillis();
|
||||
log.info("【写入Redis耗时】: {} ms", endTime - startTime);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,34 @@
|
||||
package com.mashibing.test.mapper;
|
||||
|
||||
import com.mashibing.common.constant.CacheConstant;
|
||||
import com.mashibing.test.feignClient.CacheClient;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.*;
|
||||
|
||||
@Slf4j
|
||||
@SpringBootTest
|
||||
@RunWith(SpringRunner.class)
|
||||
class MobileDirtywordMapperTest {
|
||||
|
||||
@Autowired
|
||||
CacheClient cacheClient;
|
||||
|
||||
@Autowired
|
||||
MobileDirtywordMapper mapper;
|
||||
|
||||
@Test
|
||||
void findAllDirtyword() {
|
||||
|
||||
List<String> dirtywords = mapper.findAllDirtyword();
|
||||
cacheClient.saddStr(CacheConstant.DIRTY_WORD, dirtywords.toArray(new String[]{}));
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue