Java編程實現多線程TCP服務器完整實例

相關Java類

Socket

public class Socket extends Object

・功能:TCP客戶端套接字・構造方法: Socket(InetAddress address, int port) 創建一個流套接字並將其連接到指定IP 地址的指定端口號・常用方法: 1.getInetAddress 獲得InetAddress的相關信息2.getInputStream 獲得此TCP連接的輸入流3.getOutPutStream 獲得此TCP連接的輸出流

ServerSocket

public class ServerSocket extends Object

・功能: TCP服務端套接字・構造方法: ServerSocket(int port) 創建綁定到特定端口的服務器套接字。・常用方法: 1.accept 獲得TCP連接的客戶端的socket 2.isClosed 獲得ServerSocket的關閉狀態

TCP服務器端

TcpServer.java

服務器端採用多線程的方式,每建立一個連接就啟動一個java線程,發送圖片給客戶端,之後關閉此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地址和主機名String clientAddress = clientSocket.getInetAddress().getHostAddress();String clientHostName = clientSocket.getInetAddress().getHostName();System.out.println(clientHostName + "(" + clientAddress + ")" + " 連接成功!");System.out.println("Now, 傳輸圖片數據...........");long startTime = System.currentTimeMillis();//獲取客戶端的OutputStreamOutputStream 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();}}}

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服務// 連接本機的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();}}

結果

首先,命令行啟動服務器端,之後啟動客戶端,結果如下:

圖片比較小,速度很快!

總結

以上就是本文關於Java編程實現多線程TCP服務器完整實例的全部內容，希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題，如有不足之處，歡迎留言指出。感謝朋友們對本站的支持！