发简信
IP属地：广东
-
简单实现并整合AOP和IOC
最近在看Spring的ioc和aop相关的知识点，看了一点官方的源码，一知半解，只能说对这俩个东西有个宏观的大致的了解，具体实现细节还是不是很清...
-
使用Curator去做分布式的实时参数配置
Curator简介 Apache Curator是一个比较完善的ZooKeeper客户端框架，通过封装的一套高级API 简化了ZooKeeper...
-
采用一致性Hash去搭建Redis多机系统
最近项目使用Redis缓存很多实时的数据，很多还是HashMap形式的，比较吃资源，查询还比较频繁，单机版的Redis性能上有点跟不上。节点上数...
-
NIO实现TCP文件传输最近这段时间学习了一下NIO，就想把FileChannel和SocketChannel方面的知识结合一下，于是就练习了这个基于NIO的TCP文件...
-
Structured Streaming自定义Output Sink到多个输出源
最近有个需求，需要把我们Structured Streaming处理后的实时数据，发送到Redis一份。官网并没有提供redis输出方式。之前我...
-
重写JdbcRDD实现条件查询Mysql数据库
虽然Spark使用关系型数据库作为数据源的场景并不多，但是有时候我们还是希望能够能够从MySql等数据库中读取数据，并封装成RDD。Spark官...
-
Zookeeper的认证方式
Zookeeper对权限的控制是节点级别的，而且不继承，即对父节点设置权限，其子节点不继承父节点的权限。Zookeeper提供了几种认证方式 w...
-
flink学习(2)flink Streaming从kafka接收数据
今天测试今天尝试了flink从kafka获取数据的测试程序编写，主要测试的kafka发送json的接收例子，尝试了几个kafka的Deseria...
-
flink学习(1)读取文件并求和
今天尝试了flink读取文件的测试程序编写，代码比较简单，途中遇到了一个问题，自定义封装类型的时候编译抛出如下异常： 这个问题是因为程序需要一个...