liyonghui160com
- 浏览: 779567 次
- 性别:
- 来自: 北京
-
最新评论
-
liyonghui160com：
RAYFUXK 写道您好，我最近也在使用Canal，但是遇到了 ...
canal使用配置详解 -
xinglianxlxl：
订阅发布对我有用
redis-2.8.13 jedis实现订阅发布-publish/subscribe -
liyonghui160com：
这个不能按照一条一条的读取数据。使用需要完善。
flume文件监控的source，支持断点续传功能 -
RAYFUXK：
您好，我最近也在使用Canal，但是遇到了一个问题。ERROR ...
canal使用配置详解 -
yicong：
非常感谢！发现github里面的log4net版本太 ...
Zookeeper .Net客户端代码
文章列表
Apache的commons-codec
DigestUtils.shaHex(tmpStr);
package michael.utils;
import java.security.MessageDigest;
/**
* blog www.micmiu.com
*
* @author Michael
*
*/
public class EncoderHandler {
private static final String ALGORITHM = "MD5";
private sta ...
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbsae.client.Table;
int main() {
// create a new hbase configur ...
1:解压
[yy@feixiang ~]$ tar zxf sqoop-1.99.3-bin-hadoop100.tar.gz
[yy@feixiang ~]$ ls
apache-ant-1.9.4 hbase-0.94.21.tar.gz sqoop-1.99.3-bin-hadoop100
apache-ant-1.9.4-bin.tar.gz input sqoop-1.99.3-bin-hado ...
可以使用java中的ProcessBuilder执行本地命令或脚本等工作：
以下是一个简单的使用java调用本地python脚本的例子。从某工程代码中整理出来的，未封装，仅供参考。
List<String> commands=new ArrayList();
commands.add("python");
commands.add(pkg);
commands.add("--ad=test");
//...其它参数添加
processBuilder.command(commands) ...
从jdk1.5开始我们可以利用Future来跟踪异步计算的结果。在此之前主线程要想获得工作线程（异步计算线程）的结果是比较麻烦的事情，需要我们进行特殊的程序结构设计，比较繁琐而且容易出错。有了Future我们就可以设计出比较优雅的异步计算程序结构模型：根据分而治之的思想，我们可以把异步计算的线程按照职责分为3类：
1. 异步计算的发起线程（控制线程）：负责异步计算任务的分解和发起，把分解好的任务交给异步计算的work线程去执行，发起异步计算后，发起线程可以获得Futrue的集合，从而可以跟踪异步计算结果
2. 异步计算work线程：负责具体的计算任务
3. 异步计算结果收集线程：从 ...
public class Test {
public static void main(String[] args) {
ExecutorService executor = Executors.newCachedThreadPool();
Task task = new Task();
Future<Integer> result = executor.submit(task);
executor.shutdown();
try {
...
创建一个静态Hashtable用于保存key和value,对于cache过期后的方法回调，在cache过期后，再访问cache的时候进行，避免了使用定时器轮询过期时间，进行cache清除的效率损耗。 使用synchronized关键字进行多线程同步。 包括二个类和一个接口： cache类：里面都是静态方法,提供基于key,value的方法进行cache的添加，修改，访问,进行cache过期后调用callback方法。 cacheitem类：用于管理每个条目的cache内容和超时时间回调方法 ICacheMethod接口：cache到期回调方法需要实现的接口 cache类：里面 ...
1. 先写一个Controller
package com.myapp.web.controller;
import javax.servlet.http.HttpServletRequest;
import org.directwebremoting.annotations.RemoteMethod;
import org.directwebremoting.annotations.RemoteProxy;
import org.springframework.stereotype.Cont ...
一、单个参数：
public List<XXBean> getXXBeanList(String xxCode);
<select id="getXXXBeanList" parameterType="java.lang.String" resultType="XXBean">
select t.* from tableName t where t.id= #{id}
</select>
其中方法名和ID一致，#{}中的参数名与方法中的参数名一直， ...
String myBC_DB_URL = "mybc:hive2://my-test-001:10000/default;"
+ "principal=" + loginUserPrinc + ";kerberosAuthType=kerberos;hive.server2.proxy.user=" + proxtUser;
Connection con = DriverManager.getConnection(myBC_DB_URL);
final ...
Curator框架是最好用，最流行的zookeeper的客户端。
它有以下三个优点
1.提供了一套非常友好的操作API;
2. 提供一些高级特性（包括但不仅限于前篇文章中提到的）的封装
3.易测试
maven依赖如下
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>2.5.0</ ...
1、windows下改intellij安装目录下bin\idea.exe.vmoptions文件
加上 -Dfile.encoding=UTF-8
limux 打开下面的配置文件：
/Applications/IntelliJ IDEA 12.app/Contents/Info.plist
在IntelliJ IDEA 12.app文件右键选择“Show Contents”即可看到Contents目录。
找到key等于VMOptions位置，这里设置的虚拟机的参数，在后面追加下面的参数保存文件。
-Dfile.encoding=UTF-8
2、设置IDE ...
telnet 10.0.0.162 11211
stats
服务器STATS信息
参数 值 描述
pid
7862
memcache服务器进程ID
uptime
12617972
服务器已运行秒数
time
1320756409
一、XMemcached是什么？
经常碰到的一个问题是很多朋友对memcached不了解，误以为xmemcached本身是一个缓存系统。Memcached是一个开源的，C写 的分布式key-value缓存，XMemcached只是它的一个访问客户端。Memcached通过网络协议跟客户端 ...
package xmemcache;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
import net.rubyeye.xmemcached.Counter;
import net.rubyeye.xmemcached.GetsResponse;
import net.rubyeye.xmemcached.MemcachedClient;
import net.rubyeye.xmemcached.MemcachedClientBuilder;
import n ...