集深数据单独服务器部署java应用如何交互

整个架构部署用到了集群部署（1:2）、动静分离、缓存服务、拆分数据库等高并发处理技术，属于大型系统的模型。

据我所知，集群1:2是1负载分发器、2web服务器，（以Apachetomcat集群为例），那么Directorserver应该安装Apache，而RealServer应该安装tomcat，至于javaweb项目在tomcat下面即可。

而你的架构图中还有动静分离机制，理论上静态文件服务器也应该有javaweb项目才对，不然静态文件服务器如何取静态文件呢。tomcat对静态文件处理不是很好，所以很多人推荐用Nginx作为载体。

缓存和集群数据库我不了解，不发表任何谬论。

session会话就是指的>

建议看下一些集群架构方面的书籍，比如《大型网站系统与java中间件实践》。

(1) Android应用程序

许多Android应用程序都是由Java程序员和开发人员开发的。尽管Android使用不同的jvm和不同的封装方法，但是代码仍然是用Java语言编写的。相当数量的手机支持Java游戏，这让很多非程序员都懂Java。

(2) 在金融业应用的服务器程序

Java在金融服务业得到了广泛的应用。许多第三方交易系统、银行和金融机构选择使用Java进行开发，因为Java相对安全[39]。大型跨国投资银行使用java编写前后电子交易系统、结算与确认系统、数据处理项目等项目。

在大多数情况下，Java用于服务器端开发，但大多数都没有任何前端。它们通常从一个服务器(上层)接收数据并将其发送到另一个处理系统(下一级)。

(3) 网站

Java在电子商务和网站开发领域占有一定的地位。开发人员可以使用许多不同的框架来创建web项目、springmvc、struts20和框架。

即使是简单的servlets、JSP和struts网站也经常用于政府项目。比如医疗、保险、教育、国防等部门都是基于Java的。

(4)嵌入式领域

Java在嵌入式领域发展空间很大。在这个平台上，只需130KB就能够使用Java技术(在智能卡或者传感器上)。

(5)大数据技术

Hadoop以及其他大数据处理技术很多都是用Java，例如Apache的基于Java的HBase和Accumulo以及 ElasticSearchas。

朋友让我帮忙写个程序从文本文档中导入数据到oracle数据库中,技术上没有什么难度,文档的格式都是固定的只要对应数据库中的字段解析就行了,关键在于性能。
数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用SystemcurrentTimeMillis()在最后一个子进程结束后记录当前时间,两次一减得到的时间差即为总共的用时,代码如下

Java代码  

long tStart = SystemcurrentTimeMillis();

Systemoutprintln(ThreadcurrentThread()getName() + "开始");//打印开始标记

for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程

Runnable r = new Runnable(){

@Override

public void run(){

Systemoutprintln(ThreadcurrentThread()getName() + "开始");

//做一些事情 

Systemoutprintln(ThreadcurrentThread()getName() + "结束");

}

}

Thread t = new Thread(r);

tstart();

}

Systemoutprintln(ThreadcurrentThread()getName() + "结束");//打印结束标记

long tEnd = SystemcurrentTimeMillis();

Systemoutprintln("总共用时:"+ (tEnd - tStart) + "millions");

结果是几乎在for循环结束的瞬间就执行了主线程打印总共用时的语句,原因是所有的子线程是并发执行的,它们运行时主线程也在运行,这就引出了一个问题即本文标题如何"让主线程等待所有子线程执行完毕"。试过在每个子线程开始后加上tjoin(),结果是所有线程都顺序执行,这就失去了并发的意义了,显然不是我想要的。
网上Google了很久也没有找到解决方案,难道就没有人遇到过这种需求吗还是这个问题太简单了无耐只得自己想办法了
最后我的解决办法是,自定义一个ImportThread类继承自javalangThread,重载run()方法,用一个List属性保存所有产生的线程,这样只要判断这个List是否为空就知道还有没有子线程没有执行完了,类代码如下：

Java代码  

public class ImportThread extends Thread {

private static List<Thread> runningThreads = new ArrayList<Thread>();

public ImportThread() {

}

@Override

public void run() {

regist(this);//线程开始时注册

Systemoutprintln(ThreadcurrentThread()getName() + "开始");//打印开始标记

//做一些事情 

unRegist(this);//线程结束时取消注册

Systemoutprintln(ThreadcurrentThread()getName() + "结束");//打印结束标记

}

public void regist(Thread t){

synchronized(runningThreads){

runningThreadsadd(t);

}

}

public void unRegist(Thread t){

synchronized(runningThreads){

runningThreadsremove(t);

}

}

public static boolean hasThreadRunning() {

return (runningThreadssize() > 0);//通过判断runningThreads是否为空就能知道是否还有线程未执行完

}

}

主线程中代码：

Java代码  

long tStart = SystemcurrentTimeMillis();

Systemoutprintln(ThreadcurrentThread()getName() + "开始");//打印开始标记

for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程

Thread t = new ImportThread();

tstart();

}

while(true){//等待所有子线程执行完

if(!ImportThreadhasThreadRunning()){

break;

}

Threadsleep(500);

}

Systemoutprintln(ThreadcurrentThread()getName() + "结束");//打印结束标记

long tEnd = SystemcurrentTimeMillis();

Systemoutprintln("总共用时:"+ (tEnd - tStart) + "millions");

打印的结果是：
main开始
Thread-1开始
Thread-5开始
Thread-0开始
Thread-2开始
Thread-3开始
Thread-4开始
Thread-5结束
Thread-4结束
Thread-2结束
Thread-0结束
Thread-3结束
Thread-1结束
main结束
总共用时:20860millions
可以看到main线程是等所有子线程全部执行完后才开始执行的。
==================================================以下为第二次编辑===============================================
上面的方法有一个隐患:如果线程1开始并且结束了,而其他线程还没有开始此时runningThreads的size也为0,主线程会以为所有线程都执行完了。解决办法是用一个非简单类型的计数器来取代List型的runningThreads,并且在线程创建之前就应该设定好计数器的值。
MyCountDown类

Java代码  

public class MyCountDown {

private int count;

public MyCountDown(int count){

thiscount = count;

}

public synchronized void countDown(){

count--;

}

public synchronized boolean hasNext(){

return (count > 0);

}

public int getCount() {

return count;

}

public void setCount(int count) {

thiscount = count;

}

}

ImportThread类

Java代码  

public class ImportThread extends Thread {

private MyCountDown c;

public ImportThread(MyCountDown c) {

thisc = c;

}

@Override

public void run() {

Systemoutprintln(ThreadcurrentThread()getName() + "开始");//打印开始标记

//Do something

ccountDown();//计时器减1

Systemoutprintln(ThreadcurrentThread()getName() + "结束 还有" + cgetCount() + " 个线程");//打印结束标记

}

}

主线程中

Java代码  

Systemoutprintln(ThreadcurrentThread()getName() + "开始");//打印开始标记

MyCountDown c = new MyCountDown(threadNum);//初始化countDown

for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程

Thread t = new ImportThread(c);

tstart();

}

while(true){//等待所有子线程执行完

if(!chasNext()) break;

}

Systemoutprintln(ThreadcurrentThread()getName() + "结束");//打印结束标记

打印结果:
main开始
Thread-2开始
Thread-1开始
Thread-0开始
Thread-3开始
Thread-5开始
Thread-4开始
Thread-5结束 还有5 个线程
Thread-1结束 还有4 个线程
Thread-4结束 还有3 个线程
Thread-2结束 还有2 个线程
Thread-3结束 还有1 个线程
Thread-0结束 还有0 个线程
main结束
更简单的方法:使用javautilconcurrentCountDownLatch代替MyCountDown,用await()方法代替while(true){}
ImportThread类

Java代码  

public class ImportThread extends Thread {

private CountDownLatch threadsSignal;

public ImportThread(CountDownLatch threadsSignal) {

thisthreadsSignal = threadsSignal;

}

@Override

public void run() {

Systemoutprintln(ThreadcurrentThread()getName() + "开始");

//Do somethings

threadsSignalcountDown();//线程结束时计数器减1

Systemoutprintln(ThreadcurrentThread()getName() + "结束 还有" + threadsSignalgetCount() + " 个线程");

}

}

主线程中

Java代码

CountDownLatch threadSignal = new CountDownLatch(threadNum);//初始化countDown

for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程

final Iterator<String> itt = itget(ii);

Thread t = new ImportThread(itt,sql,threadSignal);

tstart();

}

threadSignalawait();//等待所有子线程执行完

Systemoutprintln(ThreadcurrentThread()getName() + "结束");//打印结束标记

打印结果:
main开始
Thread-1开始
Thread-0开始
Thread-2开始
Thread-3开始
Thread-4开始
Thread-5开始
Thread-0结束 还有5 个线程
Thread-1结束 还有4 个线程
Thread-4结束 还有3 个线程
Thread-2结束 还有2 个线程
Thread-5结束 还有1 个线程
Thread-3结束 还有0 个线程
main结束