Java編程實現(xiàn)多線程TCP服務器完整實例
相關Java類
Socket
public class Socket extends Object
·功能:TCP客戶端套接字 ·構造方法: Socket(InetAddress address, int port) 創(chuàng)建一個流套接字并將其連接到指定 IP 地址的指定端口號 ·常用方法: 1.getInetAddress 獲得InetAddress的相關信息 2.getInputStream 獲得此TCP連接的輸入流 3.getOutPutStream 獲得此TCP連接的輸出流
ServerSocket
public class ServerSocket extends Object
·功能: TCP服務端套接字 ·構造方法: ServerSocket(int port) 創(chuàng)建綁定到特定端口的服務器套接字。 ·常用方法: 1.accept 獲得TCP連接的客戶端的socket 2.isClosed 獲得ServerSocket的關閉狀態(tài)
TCP服務器端
TcpServer.java
服務器端采用多線程的方式,每建立一個連接就啟動一個java線程,發(fā)送圖片給客戶端,之后關閉此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, 傳輸圖片數(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);
//寫出數(shù)據(jù)
}
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();
// 寫入數(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);
}
//關閉資源
out.close();
socket.close();
}
}
結果
首先,命令行啟動服務器端,之后啟動客戶端,結果如下:

圖片比較小,速度很快!
總結
以上就是本文關于Java編程實現(xiàn)多線程TCP服務器完整實例的全部內容,希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站其他相關專題,如有不足之處,歡迎留言指出。感謝朋友們對本站的支持!
相關文章
Java之Springcloud Gateway內置路由案例講解
這篇文章主要介紹了Java之Springcloud Gateway內置路由案例講解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下2021-08-08
在SpringBoot中如何利用Redis實現(xiàn)互斥鎖
當我們利用Redis存儲熱點數(shù)據(jù)時,突然就過期失效或者被刪除了,導致大量請求同時訪問數(shù)據(jù)庫,增加了數(shù)據(jù)庫的負載,為減輕數(shù)據(jù)庫的負載我們利用互斥鎖,本文重點介紹在SpringBoot中如何利用Redis實現(xiàn)互斥鎖,感興趣的朋友一起看看吧2023-09-09
Springboot?整合?RabbitMQ?消息隊列?詳情
這篇文章主要介紹了Springboot整合RabbitMQ?消息隊列詳情,文章為榮啊主題展開詳細的內容介紹,具有一定的參考價值,需要的小伙伴可以參考一下2022-08-08
Java StringBuffer類與StringBuilder類用法實例小結
這篇文章主要介紹了Java StringBuffer類與StringBuilder類用法,結合實例形式總結分析了Java StringBuffer類與StringBuilder類的功能、原理及添加、刪除、替換、截取等操作實現(xiàn)技巧,需要的朋友可以參考下2019-03-03

