快捷導(dǎo)航

Java編程實(shí)現(xiàn)多線程TCP服務(wù)器完整實(shí)例

更新時(shí)間：2018年01月05日 11:38:33 作者：GavinZhou_xd

這篇文章主要介紹了Java編程實(shí)現(xiàn)多線程TCP服務(wù)器完整實(shí)例，具有一定借鑒價(jià)值,需要的朋友可以參考下

相關(guān)Java類

Socket

public class Socket extends Object

·功能:TCP客戶端套接字
·構(gòu)造方法: 
  Socket(InetAddress address, int port) 
  創(chuàng)建一個(gè)流套接字并將其連接到指定 IP 地址的指定端口號(hào)
·常用方法: 
  1.getInetAddress 
  獲得InetAddress的相關(guān)信息
  2.getInputStream 
  獲得此TCP連接的輸入流
  3.getOutPutStream 
  獲得此TCP連接的輸出流

ServerSocket

public class ServerSocket extends Object

·功能: TCP服務(wù)端套接字
·構(gòu)造方法: 
  ServerSocket(int port) 
  創(chuàng)建綁定到特定端口的服務(wù)器套接字。
·常用方法: 
  1.accept 
  獲得TCP連接的客戶端的socket
  2.isClosed 
  獲得ServerSocket的關(guān)閉狀態(tài)

TCP服務(wù)器端

TcpServer.java

服務(wù)器端采用多線程的方式,每建立一個(gè)連接就啟動(dòng)一個(gè)java線程,發(fā)送圖片給客戶端,之后關(guān)閉此TCP連接

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地址和主機(jī)名
			String clientAddress = clientSocket.getInetAddress().getHostAddress();
			String clientHostName = clientSocket.getInetAddress().getHostName();
			System.out.println(clientHostName + "(" + clientAddress + ")" + " 連接成功!");
			System.out.println("Now, 傳輸圖片數(shù)據(jù)...........");
			long startTime = System.currentTimeMillis();
			//獲取客戶端的OutputStream
			OutputStream out = clientSocket.getOutputStream();
			//傳出圖片數(shù)據(jù)
			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);
				//寫(xiě)出數(shù)據(jù)
			}
			long endTime = System.currentTimeMillis();
			//提示信息
			System.out.println(clientHostName + "(" + clientAddress + ")" + " 圖片傳輸成功," + "用時(shí):" + ((endTime-startTime)) + "ms");
			//關(guān)閉資源
			in.close();
			clientSocket.close();
			System.out.println("連接關(guān)閉!");
		}
		catch (IOException e) {
			e.printStackTrace();
		}
	}
	public static void main(String[] args) throws IOException {
		//建立TCP連接服務(wù),綁定端口
		ServerSocket tcpServer = new ServerSocket(9090);
		//接受連接,傳圖片給連接的客戶端,每個(gè)TCP連接都是一個(gè)java線程
		while(true){
			Socket clientSocket = tcpServer.accept();
			new TcpServer(clientSocket).start();
		}
	}
}

TCP客戶端

TcpClient

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服務(wù)
		// 連接本機(jī)的TCP服務(wù)器
		Socket socket = new Socket(InetAddress.getLocalHost(), 9090);
		// 獲得輸入流
		InputStream inputStream = socket.getInputStream();
		// 寫(xiě)入數(shù)據(jù)
		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);
		}
		//關(guān)閉資源
		out.close();
		socket.close();
	}
}

結(jié)果

首先,命令行啟動(dòng)服務(wù)器端,之后啟動(dòng)客戶端,結(jié)果如下: