高性能内存队列Disruptor初探
这段时间在学习Disruptor的使用，由于其使用略微复杂，所以记录一下防止忘记：
一、定义数据结构
这个数据可以是任何你需要用到的数据，作为一个类封装起来：
12345@Datapublic class OrderEvent { private Long id; privat
...
扩展Flink使其可以接收RocketMQ消息
从官方文档可以看到，Flink支持的数据源有如下几个：
Apache Kafka (source/sink)
Apache Cassandra (sink)
Amazon Kinesis Streams (source/sink)
Elasticsearch (sink)
Hadoop FileS
...
ThoughtWorks的面试题:Conference Track Management解题思路
会议排期管理
题目
最近看到一个ThoughtWorks的面试题，这边实现一下，问题如下：
Problem Two: Conference Track Management
You are planning a big programming conference and have received
...
RocketMQ单机部署远程访问踩到的一个坑
之前根据rocketmq.apache.org的get started步骤部署的RocketMQ单节点，在远程访问的时候会出现如下问题：
1234567Startorg.apache.rocketmq.remoting.exception.RemotingTooMuchRequestExceptio
...
改造阿里巴巴otter框架，使其支持RocketMQ配置和输出（三）
上一篇文章我们实现了RocketMQ的输出：
《改造阿里巴巴otter框架，使其支持RocketMQ配置和输出（二）》：快速链接
这篇我们将改造后的代码进行编译和部署，随后进行测试。
打包
otter已经把打包的shell脚本写好了，查看目录docker/build.sh
12345678910#!
...
改造阿里巴巴otter框架，使其支持RocketMQ配置和输出（二）
上篇文章我们分析了Otter的代码结构：
《改造阿里巴巴otter框架，使其支持RocketMQ配置和输出（一）》：快速链接
这篇我们开始正式进行改造。
改造清单
定义RocketMQ实体，定义一个RocketMQ的目标源。
改造管理系统的逻辑以及前端，支持RocketMQ的配置。
改造Trans
...
慕课网Spark大数据课程笔记-Hadoop2.6.0环境搭建
系统准备
新建文件： /home/hadoop
software ：存放软件安装包
app : 存放软件目录
data ： 存放测试数据
source ： 存放软件源码：spark
下载Hadoop
下载地址：http://archive.cloudera.com/cdh5/cdh/5/
下载版
...
改造阿里巴巴otter框架，使其支持RocketMQ配置和输出（一）
最近接到了一个需求，需要同步业务数据库至MQ，再进行相应的操作。
对于这种需求，其实阿里巴巴出品的canal（https://github.com/alibaba/canal）就可以做到，但是领导提出了更变态的需求，需要有前端界面，可以动态配置，读取什么表，发送到哪个MQ，哪个topic，哪个tag
...
填充每个节点的下一个右侧节点指针2
题目
https://leetcode-cn.com/problems/populating-next-right-pointers-in-each-node-ii/
给定一个二叉树
123456class Node { int val; Node left; Node
...
如何设计一个短链接网站
在日常生活中，我们经常需要用到短链接、短网址服务，将长链接映射为短链接，更方便该路径在互联网，短信，海报等载体中传播，在运营和销售的场景下，还可以帮助工作人员统计业绩，用处非常大。
市面上比较常见的短链接有：新浪的t.cn、淘宝的tb.am、0x3.me（数据统计报表）。作为一个数据控，我更喜欢0x
...