Java,Socket&TCP编程 实现多线程端对端通信与文件传输

做了一个Java的项目，利用TCP实现了端对端通信与文件传输。下面是实现的效果：



然后开启四个客户端：



实现群聊效果：



实现私聊效果：



实现屏蔽效果：



实现文件群发效果：



实现端对端文件传输：



服务器工作过程：



实现过程主要是利用Java里面的TCP与Socket套接字进行编程，在服务器建立一个Hash表用于存储每个客户端的名字以及IP地址。

群聊等传输功能都是在服务器端实现，现在把客户端的代码附在下面：

package testClient;

import java.io.*;
import java.net.*;

public class testClient implements Runnable{
static Socket socket = null;
static PrintWriter pw = null;
BufferedReader bufferedReader;
Client client;
private static String string = "";
public static int m=0;

public testClient(){
try {
socket = new Socket(InetAddress.getLocalHost(),5678);// set socket
System.out.println("connected");
pw = new PrintWriter(socket.getOutputStream());//set outputstream
pw.println("client1");
pw.flush();
client = new Client(socket);
client.start();
} catch (Exception e) {
System.out.println("connect failed");
}
}

@Override
public void run() {
bufferedReader = new BufferedReader(new InputStreamReader(System.in));
while (true) {
try {
string = bufferedReader.readLine();

if(string.equals("end")){
testClient.Close();
break;
}
else if(!"".equals(string)){

pw.println(InetAddress.getLocalHost()+ ":" +string);
pw.flush();
}
} catch (IOException e) {
}
}
}
public static void sendFile(String filePath,Socket socket){
DataOutputStream dos=null;
DataInputStream dis=null;
try {
File file=new File(filePath);

dos=new DataOutputStream(socket.getOutputStream());
dis=new DataInputStream(new BufferedInputStream(new FileInputStream(filePath)));

int buffferSize=1024;
byte[]bufArray=new byte[buffferSize];
dos.writeUTF(file.getName());
dos.flush();
dos.writeLong((long) file.length());
dos.flush();
while (true) {
int read = 0;
if (dis!= null) {
read = dis.read(bufArray);
}

if (read == -1) {
break;
}
dos.write(bufArray, 0, read);
}
dos.flush();
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
try {
if (dos != null)
dos.close();
} catch (IOException e) {
}
try {
if (dis != null)
dis.close();
} catch (IOException e) {
}
}
}

class Client extends Thread{//client thread
Socket client;
BufferedReader bufferedReader;
PrintWriter printWriter;

public Client (Socket socket) throws IOException{
this.client = socket;
bufferedReader = new BufferedReader(new InputStreamReader(client.getInputStream()));//getinput
printWriter = new PrintWriter(client.getOutputStream());//get output

}

public void run(){
String line = "" ;
try {
while(true){
if(string.equals("end")){ //end and break
break;
}
else{
line = bufferedReader.readLine();//get input
System.out.println(line);//print input
}
}

} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
System.out.println("Server disconnects");
}

}
}

public static  void  Close() throws IOException{
pw.println(InetAddress.getLocalHost() + ":" +string);
pw.flush();
socket = null;
}

public static void main(String args[]){
testClient myClient01 = new testClient();
myClient01.run();

}

}