3种下载文件程序的思考，为何使用NIO进行异步网络通讯(二)

client.start();
}
}
}

class Client extends Thread {

int i;

@Override
public void run() {

// 1.建立scoket连接
Socket client;
try {
client = new Socket("127.0.0.1", 9999);

// 2.打开socket的流信息，准备下面的操作
OutputStream os = client.getOutputStream();

// 3.写信息
os.write(("d://film//2.rmvb").getBytes());

String filmName = "c://io"+i+".rmvb";

FileOutputStream fileOutputStream = new FileOutputStream(filmName);

// 3.1接收服务器端的反馈
InputStream is = client.getInputStream();
byte b[] = new byte[1024];

while(is.read(b)>0){
fileOutputStream.write(b);
}

// 4.关闭socket
// 先关闭输出流
os.close();

// 最后关闭socket
client.close();
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}
客户端启动了2个线程进行下载电影的工作，先启动服务端，再运行客户端，会看笔者本地的硬盘C分区到有如下效果。

可以看到线程2的下载任务一直是0字节，等第一个线程下载完成后呢，线程2的下载任务才能进行。

服务端的代码造成的问题就是使用传统的sokect网络通讯，那么另一个客户端的线程请求到server端的时候就发生了阻塞的情况，也就是说，服务端相当一个厕所，厕所就有只有一个坑位，来了一个人，相当于客户端请求，那这个人相当于就把坑位给占了，write操作和read操作会阻塞，这个人还没解决完问题呢，下个人就来了，没办法，哥们儿先在门外等等啊，等前一个客户爽完了再给您提供服务好吧。那么如何解决这个占着坑位不让别人用的情况呢？
3. 阻塞的多线程
为了解决以上问题，那么之后很多Server肯定不可能像以上程序那么做，不过以前很多Server都是基于单线程服务改造一下，做成多线程的Server的通讯，修改一下上面的Server代码，如下
Java代码
package server;

import java.io.FileInputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;

import java.net.Socket;

/**
*
*/
public class FilmServerNewThread {

public static void main(String[] args) {
FilmServerNewThread ms = new FilmServerNewThread();
try {
ms.server();
} catch (Exception e) {
e.printStackTrace();
}
}

/**
* 服务器端响应请求
*
* @throws Exception
*/
public void server() throws Exception {

// 0.建立服务器端的server的socket
ServerSocket ss = new ServerSocket(9999);

while (true) {

// 1.打开socket连接
// 等待客户端的请求
final Socket server = ss.accept();

System.out.println("服务-----------请求开始start");

// 2.打开socket的流信息，准备下面的操作
final InputStream is = server.getInputStream();
byte b[] = new byte[1024];

int readCount = is.read(b);

String str = new String(b);

str = str.trim();

final String serverFileName = str;

// 3.对流信息进行读写操作
System.out.println("客户端传过来的信息是：" + str);

if (readCount > 0) {
new Thread() {

@Override
public void run() {

System.out.println("线程"
+ Thread.currentThread().getName() + "启动");

try {

FileInputStream fileInputStream = new FileInputStream(
serverFileNa