使用Java调用HDFS的API进行文件基本操作本样例主要是代码，其中包括了Java进行上传，下载，删除，创建文件夹，遍历文件夹等操作，代码环境基于MacOS，IDEA，使用Maven来配置依赖包，后面我会放出代码，和pom.xml。Hadoop是2.6 CDH版本。代码中的hmaster是我配置的虚拟机IP地址，需要修改为你的虚拟机IP地址。HDFSUtil.javapack...

更多技术文章请访问我的个人博客http://www.rain1024.com对阿里云OSS对象存储的评价阿里云的OSS对象存储其实很早就接触了，但由于收费，一直都没有使用过，如下图，阿里云数据存储是收费的，数据下载是收费的，其他都是免费，只有使用ECS服务器下载数据时，流量才不收费，所以这就很尴尬了，国内提供免费云存储服务的有很多，当然除了百度，网易，腾讯云，青云，又拍云，七牛，数阿里云提供的配额

Java实现Kafka生产者消费者功能好久没有更新博客，最近学的东西很多，但一直忙的没有时间去写，先补充一篇kafka的，最基本的功能使用，不得不感叹大数据确实难，即使只说一个简单的功能，之前也需要铺垫很多完成的功能，比如这篇博客的前提是，你已经安装了虚拟机，里面配置了Hadoop生态组件zookeeper，安装配置了kafka，学会使用Maven，springboot等些技术，而不是直接拿来代.

本次代码仅在以下版本中测试通过<dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId&gt

最后直接在scoped模式下的style，重新建一个，scoped模式会影响内部重新设置表格的样式。在vue3中使用v-html展示富文本内容时，表格的框线不展示。各种用法之后，还是不生效。

使用两种多线程模式消费数据KafkaProducer是线程安全的,然而 KafkaConsumer却是非线程安全的。 Kafka Consumer中定义了一个 acquire(方法,用来检测当前是否只有一个线程在操作,若有其他线程正在操作则会抛出 Concurrentmodifcationexception异常:java.util.ConcurrentModificationException:

Kafka实现订单超时取消的两种模拟策略在业务场景中有一个需要定时15分钟后取消用户订单的功能，可以使用Java的任务调度框架来实现，但还需要引入框架依赖和设置数据表等，对业务的侵入性很大，有点大材小用的感觉，所以这里使用延时队列就可以，Kafka本身是不支持延时队列的，需要在生产消息和消费时进行一些二次开发，以下是我对该业务具体实现的思考。1.建立不同时间区间的topicKafka内部有很多延时

SpringBoot中@ConfigurationProperties对于多层嵌套参数的正确加载方法今天想重构一下Kafka代码，将之前用@Value引入的一些参数全部替换掉，因为可读性和维护性太差，这是以前的样子。@Value("${spring.kafka.bootstrap-servers}")private String servers;@Value("${sp...

案例代码链接：https://github.com/rainweb521/My-tutorial/tree/master/Design_patterns什么是适配器因为现实中到处都有适配器。比方说: 如果你需要在欧洲国家使用美国制造的笔记本电脑,你可能需要使用个交流电的适配器，适配器的作用:它位于美式插头和欧式插座的中间,它的工作是将欧式插座转换成美式插座,好让美式插头可以插进这个插座得到电力..

Gateway网关简介及使用1. 什么是 API 网关（API Gateway）分布式服务架构、微服务架构与 API 网关在微服务架构里，服务的粒度被进一步细分，各个业务服务可以被独立的设计、开发、测试、部署和管理。这时，各个独立部署单元可以用不同的开发测试团队维护，可以使用不同的编程语言和技术平台进行设计，这就要求必须使用一种语言和平 台无关的服务协议作为各个单元间的通讯方式。AP...