Java编程实现多线程TCP服务器完整实例

·功能:TCP客户端套接字·构造方法:   Socket(InetAddress address, int port)   创建一个流套接字并将其连接到指定 IP 地址的指定端口号·常用方法:   1.getInetAddress   获得InetAddress的相关信息  2.getInputStream   获得此TCP连接的输入流  3.getOutPutStream   获得此TCP连接的输出流

·功能: TCP服务端套接字·构造方法:   ServerSocket(int port)   创建绑定到特定端口的服务器套接字。·常用方法:   1.accept   获得TCP连接的客户端的socket  2.isClosed   获得ServerSocket的关闭状态

package cn.xidian.tcpSocket;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;public class TcpServer extends Thread{	Socket clientSocket;	public TcpServer(Socket clientSocket) {		super();		this.clientSocket = clientSocket;	}	@Override	  public void run() {		try {			//获得客户端的ip地址和主机名			String clientAddress = clientSocket.getInetAddress().getHostAddress();			String clientHostName = clientSocket.getInetAddress().getHostName();			System.out.println(clientHostName + "(" + clientAddress + ")" + " 连接成功!");			System.out.println("Now, 传输图片数据...........");			long startTime = System.currentTimeMillis();			//获取客户端的OutputStream			OutputStream out = clientSocket.getOutputStream();			//传出图片数据			FileInputStream in = new FileInputStream(new File("/home/gavinzhou/test.jpg"));			byte[] data = new byte[4096];			int length = 0;			while((length = in.read(data)) != -1){				out.write(data, 0, length);				//写出数据			}			long endTime = System.currentTimeMillis();			//提示信息			System.out.println(clientHostName + "(" + clientAddress + ")" + " 图片传输成功," + "用时:" + ((endTime-startTime)) + "ms");			//关闭资源			in.close();			clientSocket.close();			System.out.println("连接关闭!");		}		catch (IOException e) {			e.printStackTrace();		}	}	public static void main(String[] args) throws IOException {		//建立TCP连接服务,绑定端口		ServerSocket tcpServer = new ServerSocket(9090);		//接受连接,传图片给连接的客户端,每个TCP连接都是一个java线程		while(true){			Socket clientSocket = tcpServer.accept();			new TcpServer(clientSocket).start();		}	}}

package cn.xidian.tcpSocket;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.net.InetAddress;import java.net.Socket;public class TcpClient {	public static void main(String[] args) throws IOException {		// 建立TCP服务		// 连接本机的TCP服务器		Socket socket = new Socket(InetAddress.getLocalHost(), 9090);		// 获得输入流		InputStream inputStream = socket.getInputStream();		// 写入数据		FileOutputStream out = new FileOutputStream(new File("../save.jpg"));		byte[] data = new byte[4096];		int length = 0;		while((length = inputStream.read(data)) != -1){			out.write(data, 0, length);		}		//关闭资源		out.close();		socket.close();	}}