目的：在RedHat下，需要定时执行一个数据同步任务。
OS：RedHat5(64位)。
相关配置如下：
1、JDK环境变量，如果需要，可以在CLASSPATH加入相关驱动包。
export JAVA_HOME=/usr/java/jdk1.6.0_24
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib:/j2ee/test/sqljdbc.jar
2、测试目录及相关文件。
/j2
一、卸载jdk1.4
由于Redhat Enterprise Linux 5.6 中自带安装了jdk1.4.2的，所以在安装jdk1.6前我把jdk1.4.2的卸了，步骤如下：
1、打开终端输入 yum remove java
终端显示 Is this ok [y/N]:
输入y ，按回车。
终端显示 Complete! 此时jdk1.4已被卸了。
二、安装jdk1.6
1、把jdk-6u24-linux-x64-rpm.bin拷贝到 /j2ee/java目录下。
ESB协同管理平台是一个基于Struts+Spring+Hibernate的B/S系统，是我在学习JAVA、使用JAVA的过程中，为了减少重复性的开发工作，在2013年编写的一个通用开发框架，已经内置了邮件、客户管理、销售管理、服务管理、知识管理、工作流程（自定义流程、自定义表单、自定义数据表）、综合办公（调查）、系统管理（自定义首页、部门管理、用户管理、角色管理、群组管理）。
1、系统管理
2、工作流程
package thread.map;
import java.util.concurrent.ConcurrentHashMap;
public class Consumer implements Runnable {
private String name;
private ConcurrentHashMap<String, String> map;
private int fromIndex;
public Consumer(String name, C
package thread.linkedqueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.CountDownLatch;
public class Worker implements Runnable {
private CountDownLatch downLatch;
private String name;
private Concurrent
package thread.schedule;
/**
* 实现Runnable接口
* @author add by jzh 2011-12-28
*
*/
public class Hello implements Runnable {
private String name;
public Hello(String name) {
this.name = name;
}
@Override
public void run() {
Sys
package thread.semaphore;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class Test {
/**
* @author jzh 2011-12-27
* @param args
*/
public static voi
package thread.latch;
import java.util.concurrent.CountDownLatch;
public class Leader implements Runnable {
private CountDownLatch downLatch;
public Leader(CountDownLatch downLatch) {
this.downLatch = downLatch;
}
public void run() {
package thread.group;
public class SayThread extends Thread {
public SayThread(ThreadGroup group, String name) {
super(group, name);
}
public void run() {
for (int i = 0; i < 5; i++) {
System.out.println(getName() + ” = ” + i);
try
package thread.exchanger;
import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Test {
/**
* @author jzh 2011-12-27
* @param args
*/
public static voi
package thread.control;
public class ConsumerThread extends Thread {
private Warehouse warehouse;
private int number;
public ConsumerThread(Warehouse obj, int number) {
warehouse = obj;
this.number = number;
}
public void run() {
in
package thread.barrier;
import java.util.concurrent.ConcurrentHashMap;
public interface MasterDao {
public void count(ConcurrentHashMap<String, SaleReport> map);
}
package thread.barrier;
import java.util.Iterator;
import java.
package thread.readwrite;
import java.util.List;
public class Read implements Runnable {
private String name;
private RWLogic logic;
public Read(String name, RWLogic logic) {
this.name = name;
this.logic = logic;
}
public void run()
package thread.lock;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class BoundedBuffer {
// 可重入锁
final Lock lock = new ReentrantLock();
// 两个
package thread.queue;
import java.text.SimpleDateFormat;
public class Consumer implements Runnable {
private String name;
private Warehouse queue;
public Consumer(String name, Warehouse warehouse) {
this.name = name;
this.queue = wareho
package thread.pool;
import java.util.concurrent.Callable;
/**
* Callable 和 Future接口
* Callable是类似于Runnable的接口，实现Callable接口的类和实现Runnable的类都是可被其它线程执行的任务。
* Callable和Runnable有几点不同：
* （1）Callable规定的方法是call()，而Runnable规定的方法是run().
* （2）Call
package thread.sync;
public class NumMake {
private int i = 0;
int getNext() {
return i++;
}
}
package thread.sync;
public class NumTest {
/**
* @author jzh 2011-12-19
* @param args
*/
public static void main(String[] args)
package thread;
/**
* 继承Thread类创建线程
* @author add by jzh 2011-12-17
*
*/
public class SayThread extends Thread {
public SayThread(String name) {
super(name);
}
public void run() {
for (int i = 0; i < 5; i++) {
System.out.pr
package thread;
/**
* 实现Runnable接口
* @author add by jzh 2011-12-17
*
*/
public class HelloThread implements Runnable {
private String name;
public HelloThread(String name) {
this.name = name;
}
@Override
public void run() {
sqlitejdbc-v056.jar。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class Test {
/**
* @author jzh
* @remark sqlite jdbc 测试
* @