{网络编程}和{多线程}应用：基于TCP协议【实现多个客户端发送文件给一个服务器端】--练习

实现多个客户端发送文件给一个服务器端

提示：多个人创建客户端发送文件，服务端循环接收socket，从socket中获取文件

package Homework4;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
public static void main(String[] args) {
System.out.println("客户端已启动");
File file=new File("Example");
file.mkdirs();
File file2=new File("Example\\a.txt");
Socket socket=null;
InputStream is=null;
OutputStream os=null;
FileInputStream fis=null;
try {
socket=new Socket("10.16.152.24",7777);
is=socket.getInputStream();
fis=new FileInputStream(file2);
os=socket.getOutputStream();

byte[] bs=new byte[1024];
int count=0;
//发送文件
while((count=fis.read(bs))!=-1){
os.write(bs, 0, count);
os.flush();
}
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch<
1029c
/span> (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
if(is!=null){
try {
is.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(os!=null){
try {
os.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(fis!=null){
try {
fis.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(socket!=null){
try {
socket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}

}

package com.qf.demo3;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {

public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(8888);
while(true){
Socket socket = serverSocket.accept();
MyThread thread = new MyThread(socket);
thread.start();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
}

class MyThread extends Thread{

Socket socket ;
public MyThread(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
InputStream is =  null;
FileOutputStream fos = null;
try {
is = socket.getInputStream();
byte[] bs = new byte[1024];
int count = 0;
long l = System.currentTimeMillis();
fos = new FileOutputStream(new File(l+".txt"));
while((count = is.read(bs))!=-1){
fos.write(bs, 0, count);
fos.flush();
}
System.out.println("接收文件完毕");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
if(fos!=null){
try {
fos.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(is!=null){
try {
is.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(socket!=null){
try {
socket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}
}