liyonghui160com
- 浏览: 781708 次
- 性别:
- 来自: 北京
-
最新评论
-
liyonghui160com：
RAYFUXK 写道您好，我最近也在使用Canal，但是遇到了 ...
canal使用配置详解 -
xinglianxlxl：
订阅发布对我有用
redis-2.8.13 jedis实现订阅发布-publish/subscribe -
liyonghui160com：
这个不能按照一条一条的读取数据。使用需要完善。
flume文件监控的source，支持断点续传功能 -
RAYFUXK：
您好，我最近也在使用Canal，但是遇到了一个问题。ERROR ...
canal使用配置详解 -
yicong：
非常感谢！发现github里面的log4net版本太 ...
Zookeeper .Net客户端代码
文章列表
List<String> commands=new ArrayList();
cmds.add("sh");
cmds.add("-c");
cmds.add("ps -ef | grep -v grep");
ProcessBuilder=new ProcessBuilder(commands);
//...其它参数添加
processBuilder.command(commands);
processBuilder.directory(path);//切换工作目录
process ...
1.发布订阅的基本概念
1.发布订阅模式可以看成一对多的关系：多个订阅者对象同时监听一个主题对象，这个主题对象在自身状态发生变化时，会通知所有的订阅者对象，使他们能够自动的更新自己的状态。 ...
ValidateCode.java 验证码生成类
package cn.dsna.util.images;
import java.awt.Color;
import java.awt.Font;
import java.awt.Graphics2D;
import java.awt.image.BufferedImage;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java ...
版本：java7 netty5 protobuf-java-2.5.0
protobuf 消息定义如下：
Auth.proto
option java_package = "com.xinli.netty.protobuf";
package auth;
message AuthRequest{ // (1)
required string user_id=1;
required string password=2;
}
message AuthResponse{ //(2)
required int32 result_ ...
http://hbxflihua.iteye.com/blog/2231878
本实例使用netty4+protobuf-2.5.0，在win7下执行，并且假设已经安装jdk和maven。
1、下载Protobuf的Windows版，网址如下：https://developers.google.com/protocol-buffers/docs/downloads?hl=zh-cn，本示例基于protoc-2.6.1-win32.zip
2、下载Protobuf Java语言所需的jar包，网址如下：http://repo2.maven.org/maven2/com ...
EasyMock使用注解的方式，进行springmvc的代码测试，测试代码如下：
pom文件引用
<!-- for junit start -->
<dependency>
<groupId>org.easymock</groupId>
<artifactId>easymock</artifactId>
<version>3.4</version>
< ...
Highcharts 中默认开启了UTC（世界标准时间），由于中国所在时区为+8，所以经过 Highcharts 的处理后会减去8个小时。
如果不想使用 UTC，有2种方法可供使用：
1、在使用Highcharts的页面中添加如下代码：
<script type="text/javascript">
Highcharts.setOptions({ global: { useUTC: false } });
</script>
2、在Highcharts源文件中进行设置，Highcharts/j ...
基于flume-ng中原有exec的source类型，通过tail依赖于操作系统去监听文件内容变化，其次，不支持断点续传的功能：
https://github.com/cwtree/flume-filemonitor-source
该组件特点如下：
1、一个source对应一个文件监控
2、实时监控文件变化
3、增量传输文件内容
4、支持断点续传功能，即使flume进程挂掉，下一次重启仍然可以继续接着上次断开的地方传输
5、能自动判断是否log文件滚动了（前提，必须做好flume进程的监控，监控到进程不在了，要立即进行重启）
使用只需如下配置即可：
a1. ...
1. 创建
keyspace CREATE KEYSPACE twissandra WITHstrategy_class = 'SimpleStrategy'
AND strategy_options:replication_factor = '1'; 创建一个名为twissandra的keyspace，副本策略SimpleStrategy，复制因子
2. 创建Column family
cqlsh> USE twissandra; cqlsh> CREATE COLUMNFAMILY users (
创建一个名为
users的
colum ...
import java.util.ArrayList;
import java.util.HashMap;
import java.util.IdentityHashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import org.apache.commons.lang3.StringUtils;
public class SQLQueryUtil {
private static final long serialVersio ...
原有的spooling source的方式只支持一级目录的文件变动的检测，修改了一下源码支持对目录的递归检测，可以支持多级目录下的文件变动
ReliableSpoolingFileEventReader类增加以下下方法
/**
* add by
*
* @param files
* @param dir
* @param filter
*/
private void listDirFiles(List<File> files, File dir, FileFilter filter) {
File[] chi ...
配置项配置说明
storm.zookeeper.serversZooKeeper服务器列表
storm.zookeeper.portZooKeeper连接端口
storm.local.dirstorm使用的本地文件系统目录(必须存在并且storm进程可读写)
storm.cluster.modeStorm集群运行模式([distributed|local])
storm.local.mode.zmqLocal模式下是否使用ZeroMQ作消息系统，如果设置为false则使用java消息系统。默认为false
storm.zookeeper.rootZooKeeper中Storm ...
package com.feng.scheduler.log;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.lang.StringUtils;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hba ...
cd /export/app
tar –zxvf pcre-8.12.tar.gz
cd pcre-8.12
./configure –prefix=/usr/local/pcre
make && make install
cd /export/a
tar –zxvf zlib-1.2.8.tar.gz
cd zlib-1.2.8
./configure –prefix=/usr/local/zlib
make && make install
cd /export/app
tar –zxvf open ...
mybatis-generator-usage