RabbitMQ实现数据库与ElasticSearch的数据同步和分享文件过期处理

🎈 1 参考文档

RabbitMQ实现数据库与ElasticSearch的数据同步 | Hannya。-CSDN

企业级开发项目实战——基于RabbitMQ实现数据库、elasticsearch的数据同步 | 波总说先赚它一个小目标-CSDN

SPringBoot集成RabbitMQ实现30秒过期删除功能 | 军大君-CSDN

🔍 2 个人需求

  1. 当进行文件上传、文件创建、文件重命名等操作时：

    通过RabbitMQ：

    • 生产者：文件服务，执行上传、创建、重命名等文件操作，将用户文件信息（例如文件名、文件ID等）发送到RabbitMQ新增队列。
    • 消费者：查询服务，监听RabbitMQ新增队列，一旦收到消息，将用户文件信息新增或更新到Elasticsearch中。

  2. 文件删除时：

    通过RabbitMQ：

    • 生产者：文件服务，执行文件删除操作，将用户文件ID发送到RabbitMQ删除队列。
    • 消费者：查询服务，监听 RabbitMQ 队列，一旦收到消息，通过用户文件ID从Elasticsearch中删除相应的用户文件信息。

  3. 根据文件名进行文件模糊查询：

    通过OpenFeign：

    • 生产者：文件服务，查询服务调用文件服务提供的OpenFeign接口，通过用户文件ID从查询该用户文件是否存在。
    • 消费者：查询服务，如果不存在，将数据根据用户文件ID从Elasticsearch中删除。

  4. 分享文件时间到期处理：

    通过RabbitMQ的TTL（生存时间） + 死信队列：

    • 生产者：文件服务， 使用TTL模拟一个“延时队列”，在文件分享时间到期后，将消息传递到死信队列。
    • 消费者：文件服务，死信监听器监听到之后，将分享文件的分享状态改为已过期状态。

🔈3 声明

只是提供思路，代码不是很完整，直接复制运行不了。

最后面有完整网盘项目代码。

🚀4 OpenFeign相关部分（查询服务）

4.1 引入依赖

<!-- nacos -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- openfeign -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<!-- loadbalancer -->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>

4.2 application.yml

spring:# nacos注册的服务名application:name: netdisk-searchcloud:nacos:discovery:# 配置注册服务的IP地址server-addr: （IP地址）:8848username: nacospassword: nacos

4.3 FileFeignService 接口

@FeignClient(name = "netdisk-file", configuration = FeignInterceptor.class)
public interface FileFeignService {@RequestMapping("/file/getUserFile/{userFileId}")ResultResponse<Boolean> getUserFile(@PathVariable Long userFileId);
}

4.4 @EnableFeignClients 注解

@ComponentScan(value = "com.cauli.search.*")
@EnableFeignClients(basePackages = "com.cauli.search")
@SpringBootApplication
public class NetdiskSearchApplication {public static void main(String[] args) {SpringApplication.run(NetdiskSearchApplication.class, args);}
}

🚀5 Elasticsearch相关部分（查询服务）

5.1 引入依赖

<!-- elasticsearch -->
<dependency><groupId>co.elastic.clients</groupId><artifactId>elasticsearch-java</artifactId><version>8.0.1</version>
</dependency>
<dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.12.3</version>
</dependency>
<dependency><groupId>jakarta.json</groupId><artifactId>jakarta.json-api</artifactId><version>2.0.1</version>
</dependency>

5.2 application.yml

# elasticsearch相关的配置
elasticsearch:# ES网关地址hostname: （IP地址）# ES网关端口port: 9200# ES网官方方案scheme: http

5.3 ElasticSearchConfig 配置类

@Configuration
public class ElasticSearchConfig {@Value("${elasticsearch.hostname}")String hostname;@Value("${elasticsearch.port}")int port;@Value("${elasticsearch.scheme}")String scheme;@Beanpublic ElasticsearchClient elasticsearchClient(){// 创建低级客户端RestClient client = RestClient.builder(new HttpHost(hostname, port,scheme)).build();// 创建API客户端，使用Jackson映射器创建传输层ElasticsearchTransport transport = new RestClientTransport(client,new JacksonJsonpMapper());return new ElasticsearchClient(transport);}
}

5.4 Elasticsearch 服务类和服务实现类

public interface ElasticsearchService {/*** 更新ES数据** @param fileSearchDTO*/void uploadES(FileSearchDTO fileSearchDTO);/*** 删除ES数据** @param userFileId*/void deleteES(Long userFileId);/*** 搜索ES数据** @return*/List<SearchFileVO> searchES(SearchFileQueryDTO searchFileVO);
}
@Slf4j
@Service
public class ElasticsearchServiceImpl implements ElasticsearchService {@Autowiredprivate ElasticsearchClient elasticsearchClient;@Resourceprivate FileFeignService feignService;private final ThreadPoolExecutor executor = new ThreadPoolExecutor(12, // 核心线程数20, // 最大线程数1, // 线程存活时间TimeUnit.SECONDS, // 存活时间单位new ArrayBlockingQueue<>(1000) // 任务队列);public void uploadES(FileSearchDTO fileSearchDTO) {executor.execute(() -> {try {elasticsearchClient.index(i -> i.index("file_search").id(fileSearchDTO.getUserFileId()).document(fileSearchDTO));} catch (IOException e) {throw new RuntimeException(e);}});}public void deleteES(Long userFileId) {executor.execute(() -> {try {elasticsearchClient.delete(d -> d.index("file_search").id(String.valueOf(userFileId)));} catch (Exception e) {log.debug("ES删除操作失败，请检查配置");}});}@Overridepublic List<SearchFileVO> searchES(SearchFileQueryDTO searchFileQueryDTO) {int pageNum = (int) searchFileQueryDTO.getPageNum() - 1;int pageSize = (int) (searchFileQueryDTO.getPageSize() == 0 ? 10 : searchFileQueryDTO.getPageSize());SearchResponse<FileSearchDTO> search = null;try {search = elasticsearchClient.search(s -> s.index("file_search").query(_1 -> _1.bool(_2 -> _2.must(_3 -> _3.bool(_4 -> _4.should(_5 -> _5.match(_6 -> _6.field("fileName").query(searchFileQueryDTO.getFileName()))).should(_5 -> _5.wildcard(_6 -> _6.field("fileName").wildcard("*" + searchFileQueryDTO.getFileName() + "*"))))).must(_3 -> _3.term(_4 -> _4.field("userId").value(StpUtil.getLoginIdAsLong()))))).from(pageNum).size(pageSize).highlight(h -> h.fields("fileName", f -> f.type("plain").preTags("<span class='keyword'>").postTags("</span>")).encoder(HighlighterEncoder.Html)), FileSearchDTO.class);} catch (IOException e) {e.printStackTrace();}List<SearchFileVO> searchFileVOList = new ArrayList<>();if (search != null) {for (Hit<FileSearchDTO> hit : search.hits().hits()) {SearchFileVO searchFileVO = new SearchFileVO();BeanUtil.copyProperties(hit.source(), searchFileVO);searchFileVO.setHighLight(hit.highlight());searchFileVOList.add(searchFileVO);// 如果文件不存在，也从ES中删除if (!feignService.getUserFile(searchFileVO.getUserFileId()).getData()) {executor.execute(() -> this.deleteES(searchFileVO.getUserFileId()));}}}return searchFileVOList;}
}

5.5 ElasticsearchController 前端控制器

@RestController
@RequestMapping("/search")
public class ElasticsearchController {@Autowiredprivate ElasticsearchService elasticService;@GetMapping(value = "/searchFile")public RestResult<SearchFileVO> searchFile(SearchFileQueryDTO searchFileQueryDTO) {List<SearchFileVO> searchFileVOList = elasticService.searchES(searchFileQueryDTO);return RestResult.success().dataList(searchFileVOList, searchFileVOList.size());}
}

5.6 相关实体类

/*** 文件搜索VO*/
@Data
public class SearchFileVO {@JsonSerialize(using = ToStringSerializer.class)private Long userFileId;private String fileName;private String filePath;private String extendName;private Long fileSize;private String fileUrl;private Map<String, List<String>> highLight;private Integer isDir;
}

/*** 文件搜索DTO*/
@Data
@JsonIgnoreProperties(ignoreUnknown = true)
public class FileSearchDTO {private String indexName;private String userFileId;private String fileId;private String fileName;private String content;private String fileUrl;private Long fileSize;private Integer storageType;private String identifier;private Long userId;private String filePath;private String extendName;private Integer isDir;private String deleteTime;private String deleteBatchNum;
}

/*** 文件查询条件DTO*/
@Data
public class SearchFileQueryDTO {@ApiModelProperty("文件名")private String fileName;@ApiModelProperty("当前页")private long pageNum;@ApiModelProperty("每页数量")private long pageSize;
}

🚀6 RabbitMQ相关部分

6.1 生产者部分（文件服务）

6.1.1 引入依赖

<!-- nacos -->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- RabbitMQ（我的SpringBoot是2.6.8的） -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

6.1.2 完整application.yml

server:port: 8083
spring:# MySQL配置datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/（数据库名）?characterEncoding=utf8&serverTimezone=Asia/Shanghai&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: （MySQL密码）# nacos注册的服务名application:name: netdisk-filecloud:nacos:discovery:# 配置注册服务的IP地址server-addr: （IP地址）:8848username: nacospassword: nacos# rabbitmq相关的配置rabbitmq:host: （IP地址）port: 5672virtual-host: （虚拟主机名，比如：/file）username: （用户名，默认：guest）password: （密码，默认：guest）

6.1.3 RabbitMQConfig 配置类

@Configuration
public class RabbitMQConfig {// 普通交换机public static final String FILE_EXCHANGE = "file.exchange";// 文件保存相关public static final String QUEUE_FILE_SAVE = "queue.file.save";public static final String KEY_FILE_SAVE = "key.file.save";// 文件删除相关public static final String QUEUE_FILE_REMOVE = "queue.file.remove";public static final String KEY_FILE_REMOVE = "key.file.remove";// 死信相关public static final String DEAD_LETTER_EXCHANGE = "deadLetter.exchange";public static final String DEAD_LETTER_QUEUE = "deadLetter.queue";public static final String KEY_FILE_DEAD_LETTER = "key.file.dead.letter";//延迟队列public static final String DELAY_QUEUE = "delay.queue";/*** 文件保存队列** @return*/@Beanpublic Queue queueFileSave() {return new Queue(QUEUE_FILE_SAVE);}/*** 文件删除队列** @return*/@Beanpublic Queue queueFileRemove() {return new Queue(QUEUE_FILE_REMOVE);}/*** 交换机** @return*/@Beanpublic TopicExchange topicExchange() {return new TopicExchange(FILE_EXCHANGE);}/*** 绑定文件保存队列到交换机** @return*/@Beanpublic Binding bindFileSave() {return BindingBuilder.bind(queueFileSave()).to(topicExchange()).with(KEY_FILE_SAVE);}/*** 绑定文件删除队列到交换机** @return*/@Beanpublic Binding bindFileRemove() {return BindingBuilder.bind(queueFileRemove()).to(topicExchange()).with(KEY_FILE_REMOVE);}/*** 定义延时队列** @return*/@Beanpublic Queue delayQueue() {//设置死信交换机和路由keyreturn QueueBuilder.durable(DELAY_QUEUE)//如果消息过时，则会被投递到当前对应的死信交换机.withArgument("x-dead-letter-exchange", DEAD_LETTER_EXCHANGE)//如果消息过时，死信交换机会根据routing-key投递消息到对应的队列.withArgument("x-dead-letter-routing-key", KEY_FILE_DEAD_LETTER).build();}/*** 定义死信交换机** @return*/@Beanpublic TopicExchange deadLetterExchange() {return new TopicExchange(DEAD_LETTER_EXCHANGE);}/*** 定义死信队列** @return*/@Beanpublic Queue deadLetterQueue() {return new Queue(DEAD_LETTER_QUEUE);}/*** 绑定死信队列到死信交换机** @return*/@Beanpublic Binding deadLetterBinding() {return BindingBuilder.bind(deadLetterQueue()).to(deadLetterExchange()).with(KEY_FILE_DEAD_LETTER);}
}

6.1.4 FileDealComp 文件逻辑处理组件伪代码

/*** 文件逻辑处理组件*/
@Slf4j
@Component
public class FileDealComp {@Autowiredprivate RabbitTemplate rabbitTemplate;private final ThreadPoolExecutor executor = new ThreadPoolExecutor(12, // 核心线程数20, // 最大线程数1, // 线程存活时间TimeUnit.SECONDS, // 存活时间单位new ArrayBlockingQueue<>(1000) // 任务队列);/*** 更新ES数据** @param userFileId*/public void uploadES(Long userFileId) {executor.execute(() -> {FileSearchDTO fileSearchDTO = new FileSearchDTO();// 通过用户文件ID查询用户文件信息...// 通过文件ID查询文件信息...// 将用户文件信息和文件信息同步到fileSearchDTO对象...  // 消息队列更新ESrabbitTemplate.convertAndSend(RabbitMQConfig.FILE_EXCHANGE, RabbitMQConfig.KEY_FILE_SAVE, fileSearchDTO);});}/*** 删除ES数据** @param userFileId*/public void deleteES(Long userFileId) {// 消息队列删除ESrabbitTemplate.convertAndSend(RabbitMQConfig.FILE_EXCHANGE, RabbitMQConfig.KEY_FILE_REMOVE, userFileId);}/*** 分享文件过期处理** @param shareBatchNum 分享批次号*/public void expiredShareFile(String shareBatchNum) {Share share = new Share();// 根据分享批次号获取分享信息...// 将分享信息同步到share对象...// 定义日期格式SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");long differenceInMillis = 0;try {// 解析日期字符串为日期对象Date shareDate = sdf.parse(share.getShareTime());Date endDate = sdf.parse(share.getEndTime());// 计算时间差（毫秒数）differenceInMillis = endDate.getTime() - shareDate.getTime();} catch (ParseException e) {e.printStackTrace();}// 存活时间String expiration = Long.toString(differenceInMillis);// 延时队列rabbitTemplate.convertAndSend(RabbitMQConfig.DELAY_QUEUE, share, message -> {message.getMessageProperties().setExpiration(expiration);return message;});}
}

6.1.5 ExpiredShareFileListener 过期的分享文件处理监听器

@Slf4j
@Component
@RabbitListener(queues = "my-dlx-queue")
public class ExpiredShareFileListener {@Autowiredprivate ShareService shareService;// 死信相关public static final String DEAD_LETTER_EXCHANGE = "deadLetter.exchange";public static final String DEAD_LETTER_QUEUE = "deadLetter.queue";public static final String KEY_FILE_DEAD_LETTER = "key.file.dead.letter";@RabbitListener(bindings = {@QueueBinding(key = KEY_FILE_DEAD_LETTER,value = @Queue(value = DEAD_LETTER_QUEUE, durable = "true"),exchange = @Exchange(value = DEAD_LETTER_EXCHANGE, type = ExchangeTypes.TOPIC, ignoreDeclarationExceptions = "true"))})public void receiveShareMessage(Share share) {log.info("监听到文件过期处理操作：{}", share);// 将share的分享状态改为已过期 → 将share的shareStatus由0改为1...log.info("操作完成：{}", share);}
}

6.2 消费者部分（查询服务）

6.2.1 引入依赖

<!-- RabbitMQ （我的SpringBoot是2.6.8的） -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

6.2.2 完整application.yml

server:port: 8084
spring:# MySQL配置datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://127.0.0.1:3306/（数据库名）?characterEncoding=utf8&serverTimezone=Asia/Shanghai&useSSL=false&allowPublicKeyRetrieval=trueusername: rootpassword: （MySQL密码）# nacos注册的服务名application:name: netdisk-searchcloud:nacos:discovery:# 配置注册服务的IP地址server-addr: （IP地址）:8848username: nacospassword: nacosmvc:path match:matching-strategy: ant_path_matcherservlet:multipart:enabled: true# 单个文件最大限制max-file-size: 1024MB# 多个文件最大限制max-request-size: 2048MB# rabbitmq相关的配置rabbitmq:host: （IP地址）port: 5672virtual-host: （虚拟主机名，比如：/file）username: （用户名，默认：guest）password: （密码，默认：guest）# elasticsearch相关的配置
elasticsearch:# ES网关地址hostname: （IP地址）# ES网关端口port: 9200# ES网官方方案scheme: http

6.2.3 FileMQListener 文件处理消息队列监听

@Slf4j
@Component
public class FileMQListener {// 普通交换机public static final String FILE_EXCHANGE = "file.exchange";// 文件保存相关public static final String QUEUE_FILE_SAVE = "queue.file.save";public static final String KEY_FILE_SAVE = "key.file.save";// 文件删除相关public static final String QUEUE_FILE_REMOVE = "queue.file.remove";public static final String KEY_FILE_REMOVE = "key.file.remove";@Autowiredprivate ElasticsearchService elasticsearchService;/*** 监听文件信息添加操作** @param fileSearchDTO*/@RabbitListener(bindings = {@QueueBinding(key = KEY_FILE_SAVE,value = @Queue(value = QUEUE_FILE_SAVE, durable = "true"),exchange = @Exchange(value = FILE_EXCHANGE, type = ExchangeTypes.TOPIC, ignoreDeclarationExceptions = "true"))})public void receiveFileSaveMessage(FileSearchDTO fileSearchDTO) {try {log.info("监听到文件信息添加操作：{}", fileSearchDTO);// 更新ES数据elasticsearchService.uploadES(fileSearchDTO);log.info("添加完成：{}", fileSearchDTO);} catch (Exception ex) {ex.printStackTrace();}}/*** 监听文件信息删除操作** @param userFileId*/@RabbitListener(bindings = {@QueueBinding(key = KEY_FILE_REMOVE,value = @Queue(value = QUEUE_FILE_REMOVE, durable = "true"),exchange = @Exchange(value = FILE_EXCHANGE, type = ExchangeTypes.TOPIC, ignoreDeclarationExceptions = "true"))})public void receiveFileDeleteMessage(Long userFileId) {try {log.info("监听到文件信息删除操作：{}", userFileId);// 删除ES数据elasticsearchService.deleteES(userFileId);log.info("文件信息删除完成：{}", userFileId);} catch (Exception ex) {ex.printStackTrace();}}
}

📫7 代码仓库

netdisk-cloud | Gitee

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/75819.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

conda和Python的虚拟环境如何结合使用，以及二者之间到底有什么区别？

conda和Python的虚拟环境如何结合使用，以及二者之间到底有什么区别？

问题描述 今天在复现streamlit的代码时&#xff08;参考Streamlit 讲解专栏&#xff08;一&#xff09;&#xff1a;安装以及初步应用&#xff09;&#xff0c;根据这篇博文指导&#xff0c;要先用以下指令创建一个虚拟环境&#xff1a; # 创建虚拟环境&#xff08;使用venv&a…
阅读更多...
【python】读取.dat格式文件

【python】读取.dat格式文件

import binascii# 打开二进制文件以只读二进制模式 with open(EXCEL/文件.dat, rb) as file:binary_data file.read()print(binary_data)# 将二进制数据转换为十六进制字符串 hex_data binascii.hexlify(binary_data).decode(utf-8) # binary_data 现在包含了文件的二进制内容…
阅读更多...
git标签基础

git标签基础

打标签:git可以给仓库历史中某个提交打上标签,以示重要,比较有代表人们会使用这个功能来标记发布结点(V1.0,V2.0) 列出本地标签: git tag --list git tag -l "V1.85*" 列出远端仓库的中所有标签 git ls-remote --tags给标签添加一些描述信息 git tag -a v1.3 -m …
阅读更多...
热释电矢量传感器设计

热释电矢量传感器设计

1 概述 使用4个热释电传感器组成一个2X2的矩阵。通过曲线的相位差、 峰峰值等特征量来计算相关信息。本文使用STM32单片机设计、制作了热释电传感器矩阵&#xff1b;使用C#.NET设计了上位机软件。为以上研究做了试验平台。 2 硬件电路设计 2.1 热释电传感器介绍 热释电红外…
阅读更多...
c++异步框架workflow分析

c++异步框架workflow分析

简述 workflow项目地址 &#xff1a; https://github.com/sogou/workflow workflow是搜狗开源的一个开发框架。可以满足绝大多数日常服务器开发&#xff0c;性能优异&#xff0c;给上层业务提供了易于开发的接口&#xff0c;却只用了少量的代码&#xff0c;举重若轻&#xff…
阅读更多...
电子元器件选型与实战应用—04 LDO选型、特性及应用

电子元器件选型与实战应用—04 LDO选型、特性及应用

文章目录 1. 参数详解1.1 输出电流1.2 输入电压1.3 输出电压1.4 功耗1.5 PSRR1.6 精度1.7 耗散功率1.8 热阻2. 特性详解2.1 OVP2.2 UVLO2.3 压差2.4 线性瞬态响应2.5 动态负载调整2.6 效率2.7 软启动2.8 输出自放电3. 工作原理4. 和DC-DC区别5. 使能脚设计6. layout7. 二极管和…
阅读更多...
Fastjson_1.2.24_unserialize_rce漏洞复现

Fastjson_1.2.24_unserialize_rce漏洞复现

fastjson_1.2.24_unserialize_rce 说明内容漏洞编号CNVD-2017-02833漏洞名称FastJson < 1.2.24 远程代码执行漏洞评级高危影响范围1.2.24漏洞描述通过parseObject/parse将传入的字符串反序列化为Java对象时由于没有进行合理检查修复方案升级组件&#xff0c;打补丁&#xf…
阅读更多...
9.11C高级day4

9.11C高级day4

实现一个对数组求和的函数&#xff0c;数组通过实参传递给函数 sum0 function add() {for i in $*　　#$*接收传来的所有参数do((sumi))doneecho $sum }#定义一个数组 arr(1 2 3 4 5 7 9)#向函数传参 add ${arr[*]}写一个函数&#xff0c;输出当前用户的uid和gid&#xff0c;并…
阅读更多...
SQL6 查找学校是北大的学生信息

SQL6 查找学校是北大的学生信息

描述 题目&#xff1a;现在运营想要筛选出所有北京大学的学生进行用户调研&#xff0c;请你从用户信息表中取出满足条件的数据&#xff0c;结果返回设备id和学校。 示例&#xff1a;user_profile iddevice_idgenderageuniversityprovince12138male21北京大学Beijing23214male…
阅读更多...
干了三年的功能测试，让我女朋友跑了，太难受了...

干了三年的功能测试，让我女朋友跑了，太难受了...

简单概括一下 先说一下自己的情况&#xff0c;普通本科&#xff0c;19年通过校招进入深圳某软件公司&#xff0c;干了3年多的功能测试&#xff0c;21年的那会&#xff0c;因为大环境不好&#xff0c;我整个人心惊胆战的&#xff0c;怕自己卷铺盖走人了&#xff0c;我感觉自己不…
阅读更多...
【RabbitMQ】介绍及消息收发流程

【RabbitMQ】介绍及消息收发流程

介绍 RabbitMQ 是实现 AMQP&#xff08;高级消息队列协议&#xff09;的消息中间件的一种&#xff0c;最初起源于金融系统&#xff0c;用于在分布式系统中存储转发消息&#xff0c;在易用性、扩展性、高可用性等方面表现不俗。 RabbitMQ 主要是为了实现系统之间的双向解耦而实…
阅读更多...
对Excel表中归类的文件夹进行自动分类

对Excel表中归类的文件夹进行自动分类

首先把excel表另存为.txt文件&#xff08;注意&#xff1a;刚开始可能是ANSI格式&#xff0c;需要转成UTF-8格式&#xff09;&#xff1b;再新建一个.txt文件&#xff0c;重命名成.bat文件(注意&#xff1a;直接创建的如果是是UTF-8格式&#xff0c;最好转成ANSI格式&#xff0…
阅读更多...
【HDFS】Hadoop-RPC：客户端侧通过Client.Connection#sendRpcRequest方法发送RPC序列化数据

【HDFS】Hadoop-RPC：客户端侧通过Client.Connection#sendRpcRequest方法发送RPC序列化数据

org.apache.hadoop.ipc.Client.Connection#sendRpcRequest： 这个方法是客户端侧向服务端发送RPC请求的地方。调用点是Client#call方法过来的。 此方法代码注释里描述了一个细节：这个向服务端发送RPC请求数据的过程并不是由Connection线程发送的，而是其他的线程（sendParams…
阅读更多...
ToBeWritten之基于ATTCK的模拟攻击：闭环的防御与安全运营

ToBeWritten之基于ATTCK的模拟攻击：闭环的防御与安全运营

也许每个人出生的时候都以为这世界都是为他一个人而存在的&#xff0c;当他发现自己错的时候&#xff0c;他便开始长大 少走了弯路&#xff0c;也就错过了风景&#xff0c;无论如何&#xff0c;感谢经历 转移发布平台通知&#xff1a;将不再在CSDN博客发布新文章&#xff0c;敬…
阅读更多...
智慧安防/视频分析云平台EasyCVR不显示告警图片该如何解决？

智慧安防/视频分析云平台EasyCVR不显示告警图片该如何解决？

安防视频监控平台EasyCVR可拓展性强、视频能力灵活、部署轻快&#xff0c;可支持的主流标准协议有国标GB28181、RTSP/Onvif、RTMP等&#xff0c;以及支持厂家私有协议与SDK接入&#xff0c;包括海康Ehome、海大宇等设备的SDK等。平台既具备传统安防视频监控的能力&#xff0c;也…
阅读更多...
电脑硬盘数据恢复一般需要收费多少钱

电脑硬盘数据恢复一般需要收费多少钱

随着电子信息时代的发展&#xff0c;个人和企业对电脑硬盘中存储的数据越发重视。然而&#xff0c;由于各种原因&#xff0c;硬盘数据丢失的情况屡见不鲜。如果您正陷入这样的困境&#xff0c;您可能会好奇恢复失去的数据需要花费多少钱。本文将为您介绍电脑硬盘数据恢复的一般…
阅读更多...
LabVIEW利用局部放电分析高压电气设备状态诊断

LabVIEW利用局部放电分析高压电气设备状态诊断

LabVIEW利用局部放电分析高压电气设备状态诊断 目前&#xff0c;高压电气设备状态的监控系统解决了早期故障检测的问题。局部放电起源于电力电气装置的绝缘。局部放电会导致绝缘层逐渐磨损和加速老化&#xff0c;因此可能导致绝缘完全击穿。因此&#xff0c;局部放电检测及其特…
阅读更多...
Linux 6.6 初步支持AMD 新一代 Zen 5 处理器

Linux 6.6 初步支持AMD 新一代 Zen 5 处理器

AMD 下一代 Zen 5 CPU 现已开始为 Linux 6.6 支持提交相关代码&#xff0c;最新补丁包括提供温度监控和 EDAC 报告等。 最新的 Linux 6.6 代码中已经加入了包括支持硬件监视器温度监控和 EDAC 报告的补丁。此外&#xff0c;新版本还加入了 x86 / misc 补丁&#xff0c;Phoronix…
阅读更多...
git：.gitignore的使用

git：.gitignore的使用

.gitignore的使用 1、简介 .gitignore文件用于指定哪些文件或目录应该被Git忽略&#xff0c;即它们不会被Git跟踪和提交到版本控制中。 2、简单语法规则 1、注释&#xff1a;使用#符号进行注释。 2、文件和目录规则&#xff1a;每行一个规则&#xff0c;指定要忽略的文件、…
阅读更多...
C++在C语言基础上的优化

C++在C语言基础上的优化

目录 一、命名空间 1、命名空间的定义 2、命名空间的使用 二、输入&输出 三、缺省参数 1、缺省参数的概念 2、缺省参数的分类 四、函数重载 五、引用 1.引用的概念 2.引用的特性 3、引用和指针的区别 六、内联函数 七、基于范围的for循环 一、命名空间 命名空…
阅读更多...
最新文章

Copyright @ 2022~2023